fix(dagster): support dagster v1.9.6 (datahub-project#12189)

acryldata · Dec 20, 2024 · 66df362 · 66df362
1 parent eceb799
commit 66df362
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...a-ingestion-modules/dagster-plugin/src/datahub_dagster_plugin/client/dagster_generator.py b/...a-ingestion-modules/dagster-plugin/src/datahub_dagster_plugin/client/dagster_generator.py
@@ -522,7 +522,7 @@ def generate_datajob(
         # Also, add datahub inputs/outputs if present in input/output metatdata.
         for input_def_snap in op_def_snap.input_def_snaps:
             job_property_bag[f"input.{input_def_snap.name}"] = str(
-                input_def_snap._asdict()
+                input_def_snap.__dict__
             )
             if Constant.DATAHUB_INPUTS in input_def_snap.metadata:
                 datajob.inlets.extend(
@@ -533,7 +533,7 @@ def generate_datajob(
 
         for output_def_snap in op_def_snap.output_def_snaps:
             job_property_bag[f"output_{output_def_snap.name}"] = str(
-                output_def_snap._asdict()
+                output_def_snap.__dict__
             )
             if (
                 Constant.DATAHUB_OUTPUTS in output_def_snap.metadata