Skip to content

Commit

Permalink
add skip for generate_dbt_docs_gcs
Browse files Browse the repository at this point in the history
  • Loading branch information
jbandoro committed Oct 24, 2023
1 parent 750eb6d commit 1e9f33b
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion dev/dags/dbt_docs.py
Original file line number Diff line number Diff line change
Expand Up @@ -58,6 +58,11 @@ def which_upload():
downstream_tasks_to_run += ["generate_dbt_docs_azure"]
except AirflowNotFoundException:
pass
try:
BaseHook.get_connection(GCS_CONN_ID)
downstream_tasks_to_run += ["generate_dbt_docs_gcs"]
except AirflowNotFoundException:
pass

return downstream_tasks_to_run

Expand Down Expand Up @@ -94,4 +99,4 @@ def which_upload():
bucket_name="cosmos-docs",
)

which_upload() >> [generate_dbt_docs_aws, generate_dbt_docs_azure]
which_upload() >> [generate_dbt_docs_aws, generate_dbt_docs_azure, generate_dbt_docs_gcs]

0 comments on commit 1e9f33b

Please sign in to comment.