Commit 1f3db135 authored by Eteri's avatar Eteri Committed by Eteri

add compatibility to new catalog version

parent 911a3aff
...@@ -22,7 +22,7 @@ query = AndQuery( ...@@ -22,7 +22,7 @@ query = AndQuery(
Query(simulation_state = stream_simulation_state, Query(simulation_state = stream_simulation_state,
use_relative_url = "use/big_data/ingestion/stream"))) use_relative_url = "use/big_data/ingestion/stream")))
for movement in portal_catalog(query): for movement in portal_catalog(query=query):
if movement.getQuantity() <= 0: if movement.getQuantity() <= 0:
continue continue
if movement.DataIngestionLine_hasMissingRequiredItem(): if movement.DataIngestionLine_hasMissingRequiredItem():
......
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