fix(microsoft): add missing types for fixing example_adf_run_pipeline.py

this is added in newer version of datafactory lib
astronomer · Oct 16, 2023 · e1037d9 · e1037d9
1 parent 35a7244
commit e1037d9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/astronomer/providers/microsoft/azure/example_dags/example_adf_run_pipeline.py b/astronomer/providers/microsoft/azure/example_dags/example_adf_run_pipeline.py
@@ -123,8 +123,8 @@ def create_adf_storage_pipeline() -> None:
     # Create a copy activity
     blob_source = BlobSource()
     blob_sink = BlobSink()
-    ds_in_ref = DatasetReference(type="DatasetReferenceType", reference_name=DATASET_INPUT_NAME)
-    ds_out_ref = DatasetReference(type="DatasetReferenceType", reference_name=DATASET_OUTPUT_NAME)
+    ds_in_ref = DatasetReference(type="DatasetReference", reference_name=DATASET_INPUT_NAME)
+    ds_out_ref = DatasetReference(type="DatasetReference", reference_name=DATASET_OUTPUT_NAME)
     copy_activity = CopyActivity(
         name=ACTIVITY_NAME, inputs=[ds_in_ref], outputs=[ds_out_ref], source=blob_source, sink=blob_sink
     )