We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c838266 commit 396b33fCopy full SHA for 396b33f
‎dags/kids_first/dbt_bash.py‎
@@ -1,4 +1,5 @@
1
from datetime import datetime, timedelta
2
+from airflow.sdk import Variable
3
import os
4
5
# The DAG object; we'll need this to instantiate a DAG
@@ -44,3 +45,6 @@
44
45
task_id="dbt_version",
46
bash_command=f"{os.environ['AIRFLOW_HOME']}/dbt_venv/bin/dbt --version",
47
)
48
+ t2 = BashOperator(
49
+ task_id="list_files_in_dbt_project",
50
+ bash_command="ls -la " + Variable.get("DBT_PROJECT_DIR"),
0 commit comments