Hotfix dataflow nil pointer

CHANGELOG.md

@@ -10,11 +10,13 @@
 
 ### Fixed Bugs
 
+- [PR #167](https://github.com/Orange-OpenSource/nifikop/pull/167) - **[Operator/NiFiDataflow]** Fix nil pointer exception case whe sync Dataflow.
+
 ## v0.7.5
 
 ### Added
 
-- [PR #161](https://github.com/Orange-OpenSource/nifikop/pull/162) - **[Operator/NiFiParameterContext]** Support declarative sensitive value out of secret.
+- [PR #162](https://github.com/Orange-OpenSource/nifikop/pull/162) - **[Operator/NiFiParameterContext]** Support declarative sensitive value out of secret.
 
 ### Fixed Bugs
 

controllers/nifidataflow_controller.go

@@ -443,7 +443,7 @@ func (r *NifiDataflowReconciler) Reconcile(ctx context.Context, req ctrl.Request
 	r.Log.Info("Ensured Dataflow")
 
 	r.Recorder.Event(instance, corev1.EventTypeWarning, "Reconciled",
-		fmt.Sprintf("Reconciled failed dataflow %s based on flow {bucketId : %s, flowId: %s, version: %s}",
+		fmt.Sprintf("Success fully ensured dataflow %s based on flow {bucketId : %s, flowId: %s, version: %s}",
 			instance.Name, instance.Spec.BucketId,
 			instance.Spec.FlowId, strconv.FormatInt(int64(*instance.Spec.FlowVersion), 10)))
 

pkg/clientwrappers/dataflow/dataflow.go

@@ -315,7 +315,8 @@ func SyncDataflow(
 				updateRequest2Status(updateRequest, t)
 		}
 
-		if err := clientwrappers.ErrorGetOperation(log, err, "Get version-request"); err != nificlient.ErrNifiClusterReturned404 || !updateRequest.Request.Complete {
+		if err := clientwrappers.ErrorGetOperation(log, err, "Get version-request"); err != nificlient.ErrNifiClusterReturned404 ||
+			(updateRequest != nil && updateRequest.Request != nil && !updateRequest.Request.Complete) {
 			if err != nil {
 				return &flow.Status, err
 			}