File tree Expand file tree Collapse file tree 2 files changed +2
-3
lines changed Expand file tree Collapse file tree 2 files changed +2
-3
lines changed Original file line number Diff line number Diff line change 64
64
Tasks with custom logic are relegated to individual Python files.
65
65
"""
66
66
67
+
67
68
AIRFLOW_HOME = "/opt/airflow"
68
69
INDEX_GENCON = BashOperator (
69
70
task_id = "index_gencon" ,
70
- bash_command = "/dags/cob_datapipeline/scripts/ingest_gencon.sh " ,
71
+ bash_command = AIRFLOW_HOME + "/dags/cob_datapipeline/scripts/ingest_gencon.sh " ,
71
72
retries = 1 ,
72
73
env = {
73
74
"AWS_ACCESS_KEY_ID" : AIRFLOW_S3 .login ,
Original file line number Diff line number Diff line change @@ -14,8 +14,6 @@ export PATH="$AIRFLOW_USER_HOME/.rbenv/shims:$AIRFLOW_USER_HOME/.rbenv/bin:$PATH
14
14
export SOLR_URL=" ${SOLR_WEB_URL// \/\/ /// $SOLR_AUTH_USER : $SOLR_AUTH_PASSWORD @ } "
15
15
export GENCON_INDEX_PATH=" $PWD /gencon_index"
16
16
17
- echo " >>> My Dreictory: $PWD "
18
-
19
17
# Get the raw CSV files from S3
20
18
aws s3 sync $GENCON_CSV_S3 $GENCON_TEMP_PATH --include " *.csv"
21
19
You can’t perform that action at this time.
0 commit comments