Squashed commit of the following:

commit 70e61ae
Author: bharanidharan14 <[email protected]>
Date:   Fri Apr 22 13:19:23 2022 +0530

    Azure datafactory pipeline run status sensor (#260)

    Add Microsoft ADF dag in master dag

Author: rajaths010494

.circleci/integration-tests/master_dag.py

@@ -163,6 +163,11 @@ def prepare_dag_dependency(task_info, execution_time):
     hive_trigger_tasks, ids = prepare_dag_dependency(hive_task_info, "{{ ds }}")
     dag_run_ids.extend(ids)
     chain(*hive_trigger_tasks)
+    # microsoft Azure Data factory pipeline DAG
+    adf_pipeline_task_info = [{"adf_pipeline_dag": "example_adf_run_pipeline"}]
+    adf_pipeline_trigger_tasks, ids = prepare_dag_dependency(adf_pipeline_task_info, "{{ ds }}")
+    dag_run_ids.extend(ids)
+    chain(*adf_pipeline_trigger_tasks)
 
     report = PythonOperator(
         task_id="get_report",
@@ -187,6 +192,7 @@ def prepare_dag_dependency(task_info, execution_time):
         snowflake_trigger_tasks[0],
         livy_trigger_tasks[0],
         hive_trigger_tasks[0],
+        adf_pipeline_trigger_tasks[0],
     ]
 
     last_task = [
@@ -200,6 +206,7 @@ def prepare_dag_dependency(task_info, execution_time):
         snowflake_trigger_tasks[-1],
         livy_trigger_tasks[-1],
         hive_trigger_tasks[-1],
+        adf_pipeline_trigger_tasks[-1],
     ]
 
     last_task >> end

astronomer/providers/microsoft/azure/example_dags/example_adf_run_pipeline.py

@@ -33,8 +33,8 @@
 default_args = {
     "execution_timeout": timedelta(minutes=30),
     "azure_data_factory_conn_id": "azure_data_factory_default",
-    "factory_name": "ADFProvidersTeamDataFactory",  # This can also be specified in the ADF connection.
-    "resource_group_name": "team_provider_resource_group_test",  # This can also be specified in the ADF connection.
+    "factory_name": "ADFProvidersTeamDataFactoryTest",  # This can also be specified in the ADF connection.
+    "resource_group_name": "team_provider_resource_group_test_1",  # This can also be specified in the ADF connection.
 }
 
 CLIENT_ID = os.getenv("CLIENT_ID", "")