From 75aa6e53393cc6393b55abf5d7477878f103c2b5 Mon Sep 17 00:00:00 2001 From: vatsrahul1001 Date: Fri, 12 Apr 2024 08:44:19 +0530 Subject: [PATCH] remove dbt dag from master dag --- .circleci/integration-tests/master_dag.py | 10 ---------- 1 file changed, 10 deletions(-) diff --git a/.circleci/integration-tests/master_dag.py b/.circleci/integration-tests/master_dag.py index 445ca265a..7904d3388 100644 --- a/.circleci/integration-tests/master_dag.py +++ b/.circleci/integration-tests/master_dag.py @@ -360,14 +360,6 @@ def prepare_dag_dependency(task_info, execution_time): dag_run_ids.extend(ids) chain(*sftp_trigger_tasks) - # DBT - dbt_task_info = [ - {"dbt_dag": "example_dbt_cloud"}, - ] - dbt_trigger_tasks, ids = prepare_dag_dependency(dbt_task_info, "{{ ds }}") - dag_run_ids.extend(ids) - chain(*dbt_trigger_tasks) - report = PythonOperator( task_id="get_report", python_callable=get_report, @@ -401,7 +393,6 @@ def prepare_dag_dependency(task_info, execution_time): hive_trigger_tasks[0], azure_trigger_tasks[0], sftp_trigger_tasks[0], - dbt_trigger_tasks[0], ] last_task = [ @@ -424,7 +415,6 @@ def prepare_dag_dependency(task_info, execution_time): hive_trigger_tasks[-1], azure_trigger_tasks[-1], sftp_trigger_tasks[-1], - dbt_trigger_tasks[-1], ] last_task >> report >> end