Commit f353ec3a authored by Siarhei Khaletski (EPAM)'s avatar Siarhei Khaletski (EPAM) 🚩
Browse files

Merge branch 'add-support-data-partition-id-for-csv' into 'master'

Added support of one more lookup for data-partition-id (e.g. CSV parser uses)

See merge request !43
parents a7c3ebee 503e364a
Pipeline #66240 passed with stages
in 1 minute and 49 seconds
......@@ -34,6 +34,14 @@ class Context:
:rtype: Context
"""
ctx_payload = ctx.pop('Payload')
try:
data_partition_id = ctx_payload['data-partition-id']
except KeyError:
data_partition_id = ctx['dataPartitionId'] # to support some DAGs payload interface
ctx_obj = cls(app_key=ctx_payload['AppKey'],
data_partition_id=ctx_payload['data-partition-id'])
data_partition_id=data_partition_id)
return ctx_obj
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