diff --git a/dags/pull_here.py b/dags/pull_here.py index 18fe490bf..f68230e4a 100644 --- a/dags/pull_here.py +++ b/dags/pull_here.py @@ -87,7 +87,7 @@ def load_data_run()->str: os.environ['HOST'] = conn.host os.environ['USER'] = conn.login os.environ['PGPASSWORD'] = conn.password - return '''curl $DOWNLOAD_URL | gunzip | psql -h $HOST -U $USER -d bigdata -c "\COPY here.ta_view FROM STDIN WITH (FORMAT csv, HEADER TRUE);" ''' + return '''curl $DOWNLOAD_URL | gunzip | psql -h $HOST -U $USER -d bigdata -c "\\COPY here.ta_view FROM STDIN WITH (FORMAT csv, HEADER TRUE);" ''' # Create a task group for triggering the DAGs @task_group(group_id='trigger_dags_tasks') diff --git a/dags/pull_here_path.py b/dags/pull_here_path.py index e675fff36..508e91cc1 100644 --- a/dags/pull_here_path.py +++ b/dags/pull_here_path.py @@ -82,7 +82,7 @@ def load_data()->str: os.environ['HOST'] = conn.host os.environ['USER'] = conn.login os.environ['PGPASSWORD'] = conn.password - return '''curl $DOWNLOAD_URL | gunzip | psql -h $HOST -U $USER -d bigdata -c "\COPY here.ta_path_view FROM STDIN WITH (FORMAT csv, HEADER TRUE);" ''' + return '''curl $DOWNLOAD_URL | gunzip | psql -h $HOST -U $USER -d bigdata -c "\\COPY here.ta_path_view FROM STDIN WITH (FORMAT csv, HEADER TRUE);" ''' load_data()