Commit bc683f1e authored by Roque's avatar Roque

erp5_wendelin_data_lake_ingestion: filter invalidated ingestions in get data stream list script

parent 99206e2d
...@@ -17,7 +17,7 @@ except Exception as e: # fails because unauthorized access ...@@ -17,7 +17,7 @@ except Exception as e: # fails because unauthorized access
data_stream_dict = {} data_stream_dict = {}
for stream in data_set.DataSet_getDataStreamList(): for stream in data_set.DataSet_getDataStreamList():
if not portal.ERP5Site_checkReferenceInvalidated(stream) and stream.getValidationState() != "draft": if stream and not portal.ERP5Site_checkReferenceInvalidated(stream) and stream.getValidationState() != "draft":
data_stream_info_dict = { 'id': 'data_stream_module/'+stream.getId(), data_stream_info_dict = { 'id': 'data_stream_module/'+stream.getId(),
'size': stream.getSize(), 'size': stream.getSize(),
'hash': stream.getVersion() } 'hash': stream.getVersion() }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment