Skip to content

Commit 33f5947

Browse files
committed
Fix path to ingest script
1 parent 6c1a8b8 commit 33f5947

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

cob_datapipeline/gencon_ingest_dag.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,9 +64,10 @@
6464
Tasks with custom logic are relegated to individual Python files.
6565
"""
6666

67+
AIRFLOW_HOME = "/opt/airflow"
6768
INDEX_GENCON = BashOperator(
6869
task_id="index_gencon",
69-
bash_command="/opt/airflow/dags/cob_datapipeline/scripts/ingest_gencon.sh ",
70+
bash_command="/dags/cob_datapipeline/scripts/ingest_gencon.sh ",
7071
retries=1,
7172
env={
7273
"AWS_ACCESS_KEY_ID": AIRFLOW_S3.login,

0 commit comments

Comments
 (0)