Commit b7084be3 authored by Eteri's avatar Eteri

add compatibility to new catalog version

parent e6a81470
......@@ -25,7 +25,7 @@ query = AndQuery(
Query(simulation_state = stream_simulation_state,
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:
continue
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