Skip to content

Commit 66df362

Browse files
fix(dagster): support dagster v1.9.6 (#12189)
1 parent eceb799 commit 66df362

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

metadata-ingestion-modules/dagster-plugin/src/datahub_dagster_plugin/client/dagster_generator.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -522,7 +522,7 @@ def generate_datajob(
522522
# Also, add datahub inputs/outputs if present in input/output metatdata.
523523
for input_def_snap in op_def_snap.input_def_snaps:
524524
job_property_bag[f"input.{input_def_snap.name}"] = str(
525-
input_def_snap._asdict()
525+
input_def_snap.__dict__
526526
)
527527
if Constant.DATAHUB_INPUTS in input_def_snap.metadata:
528528
datajob.inlets.extend(
@@ -533,7 +533,7 @@ def generate_datajob(
533533

534534
for output_def_snap in op_def_snap.output_def_snaps:
535535
job_property_bag[f"output_{output_def_snap.name}"] = str(
536-
output_def_snap._asdict()
536+
output_def_snap.__dict__
537537
)
538538
if (
539539
Constant.DATAHUB_OUTPUTS in output_def_snap.metadata

0 commit comments

Comments
 (0)