Skip to content

Commit ff47077

Browse files
authored
Merge branch 'main' into dependabot/pip/pylint-3.3.8
2 parents c68e364 + c8ded3f commit ff47077

File tree

2 files changed

+1
-3
lines changed

2 files changed

+1
-3
lines changed

cob_datapipeline/gencon_ingest_dag.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@
6666

6767
INDEX_GENCON = BashOperator(
6868
task_id="index_gencon",
69-
bash_command="/opt/airflow/dags/cob_datapipeline/scripts/ingest_gencon.sh ",
69+
bash_command=AIRFLOW_HOME + "/dags/cob_datapipeline/scripts/ingest_gencon.sh ",
7070
retries=1,
7171
env={
7272
"AWS_ACCESS_KEY_ID": AIRFLOW_S3.login,

cob_datapipeline/scripts/ingest_gencon.sh

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,8 +14,6 @@ export PATH="$AIRFLOW_USER_HOME/.rbenv/shims:$AIRFLOW_USER_HOME/.rbenv/bin:$PATH
1414
export SOLR_URL="${SOLR_WEB_URL//\/\////$SOLR_AUTH_USER:$SOLR_AUTH_PASSWORD@}"
1515
export GENCON_INDEX_PATH="$PWD/gencon_index"
1616

17-
echo ">>> My Dreictory: $PWD"
18-
1917
# Get the raw CSV files from S3
2018
aws s3 sync $GENCON_CSV_S3 $GENCON_TEMP_PATH --include "*.csv"
2119

0 commit comments

Comments
 (0)