Enable user context ingestion

• ADR : home#52 (closed)

In accordance with the above ADR change involves consuming the userId passed from Airflow Conf and setting the on-behalf-of header

Related MR - osdu/platform/system/lib/core/os-core-common!165 (merged)

User Id is a part of execution context, but is not a mandatory requirement

osdu_ingestion/libs/context.py

@@ -16,6 +16,7 @@
 """Context module."""
 
 import dataclasses
+import typing
 
 
 @dataclasses.dataclass
@@ -24,7 +25,7 @@ class Context:
 
     data_partition_id: str
     app_key: str
-
+    user_id: typing.Optional[str]
     @classmethod
     def populate(cls, ctx: dict) -> 'Context':
         """
@@ -40,8 +41,12 @@ class Context:
         except KeyError:
             data_partition_id = ctx['dataPartitionId'] # to support some DAGs payload interface
 
+        user_id = ctx.get('userId')
+        print(f"user_id in Context Initialization is {user_id}")
+
         ctx_obj = cls(app_key=ctx_payload['AppKey'],
-                      data_partition_id=data_partition_id)
+                      data_partition_id=data_partition_id,
+                      user_id=user_id)
 
         return ctx_obj