Append module to operator name in job context (apache#62)

* Append module to operator name in job context Signed-off-by: wslulciuc <willy@datakin.com>
mobuchowski · Sep 15, 2020 · 90cc8ed · 90cc8ed
1 parent dee9bf6
commit 90cc8ed
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/marquez_airflow/dag.py b/marquez_airflow/dag.py
@@ -178,10 +178,11 @@ def report_task(self,
         # If no extractor found or failed to extract metadata,
         # report the task metadata
         if not steps_metadata:
+            operator = f"{task.__class__.__module__}.{task.__class__.__name__}"
             steps_metadata = [StepMetadata(
                 name=task_name,
                 context={
-                    'airflow.operator': task.__class__.__name__,
+                    'airflow.operator': operator,
                     'airflow.task_info': str(task.__dict__)
                 })]