Commit d4956cde authored by Klaus Wölfel's avatar Klaus Wölfel

Fix ingestion without bucket reference

Ingestion operations which write to data stream do not
have bucket_reference parameter. Now we do only pass
this parameter if we get it from the tag parsing script.
parent 93e652dc
......@@ -159,7 +159,9 @@ else:
data_operation = operation_line.getResourceValue()
parameter_dict = {
input_line.getReference(): \
{v.getPortalType(): v for v in input_line.getAggregateValueList()},
'bucket_reference': movement_dict.get('bucket_reference', None)}
{v.getPortalType(): v for v in input_line.getAggregateValueList()}}
bucket_reference = movement_dict.get('bucket_reference', None)
if bucket_reference is not None:
parameter_dict['bucket_reference'] = bucket_reference
return data_operation, parameter_dict
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