Commit 5e53a1ab authored by Roque Porchetto's avatar Roque Porchetto

erp5_wendelin_telecom_ingestion: fix handle invalid data streams

parent 974fc6ff
...@@ -22,15 +22,15 @@ for data_set in portal_catalog(**kw_dict): ...@@ -22,15 +22,15 @@ for data_set in portal_catalog(**kw_dict):
log("Invalidating data set") log("Invalidating data set")
data_set.setReference(data_set.getReference() + "_invalid") data_set.setReference(data_set.getReference() + "_invalid")
# data arrays # data streams
kw_dict = {"portal_type": "Data Array", kw_dict = {"portal_type": "Data Stream",
"validation_state": "Invalidated"} "validation_state": "Invalidated"}
for data_array in portal_catalog(**kw_dict): for data_stream in portal_catalog(**kw_dict):
if not data_array.getReference().endswith("_invalid"): if not data_stream.getReference().endswith("_invalid"):
log("Ivalid Data Array: " + str(data_array.getReference())) log("Ivalid Data Stream: " + str(data_stream.getReference()))
context.logEntry("Ivalid Data Array: " + str(data_array.getReference())) context.logEntry("Ivalid Data Stream: " + str(data_stream.getReference()))
portal.ERP5Site_invalidateIngestionObjects(data_array.getReference()) portal.ERP5Site_invalidateIngestionObjects(data_stream.getReference())
......
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