Wendelin datalake fixes

See merge request nexedi/wendelin!73

bt5/erp5_wendelin_data_lake_ingestion/SkinTemplateItem/portal_skins/erp5_wendelin_data_lake/Alarm_checkDataStreamStateConsistency.py

@@ -8,5 +8,5 @@ for data_set in context.portal_catalog(portal_type = "Data Set",
                              aggregate_uid = data_set.getUid())
   for data_ingestion_line in data_ingestion_line_list:
     data_stream = data_ingestion_line.getAggregateValue(portal_type = "Data Stream")
-    if data_stream.getValidationState() == "validated":
+    if data_stream and data_stream.getValidationState() == "validated":
       data_stream.publish()

bt5/erp5_wendelin_data_lake_ingestion/WorkflowTemplateItem/portal_workflow/data_set_interaction_workflow/scripts/DataSet_invalidateDataStreamList.py

@@ -3,4 +3,5 @@
 """
 data_set = state_change['object']
 for data_stream in data_set.DataSet_getDataStreamList():
-  data_stream.activate().invalidate()
+  if data_stream and data_stream.getValidationState() != 'draft':
+    data_stream.activate().invalidate()

bt5/erp5_wendelin_data_lake_ingestion/WorkflowTemplateItem/portal_workflow/data_set_interaction_workflow/scripts/DataSet_publishDataStreamList.py

@@ -3,5 +3,5 @@
 """
 data_set = state_change['object']
 for data_stream in data_set.DataSet_getDataStreamList():
-  if data_stream and not context.getPortalObject().ERP5Site_checkReferenceInvalidated(data_stream) and data_stream.getValidationState() != 'draft':
+  if data_stream and not context.getPortalObject().ERP5Site_checkReferenceInvalidated(data_stream) and data_stream.getValidationState() == 'validated':
     data_stream.activate().publish()