Skip to content

GitLab

A
Airflow
Commit dc8256c8 authored by Timothy Ardha's avatar Timothy Ardha
Browse files
Options

update history finish

parent bd01ebb9
Show whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
1_t24_interface.py
View file @ dc8256c8
...@@ -258,7 +258,7 @@ with DAG("APJ_1_t24_interface", ...@@ -258,7 +258,7 @@ with DAG("APJ_1_t24_interface",
sql=f""" sql=f"""
UPDATE ds_conf."Datasource_history" UPDATE ds_conf."Datasource_history"
SET status = 'DONE', finish_time = '{datetime.now().strftime('%Y-%m-%d %H:%M:%S')}'::timestamp with time zone SET status = 'DONE', finish_time = '{datetime.now().strftime('%Y-%m-%d %H:%M:%S')}'::timestamp with time zone
WHERE source = '{POSTGRES_SCHEMA}' and status = 'WAITING.NOMINATIF'; WHERE source = '{POSTGRES_SCHEMA}' and status = 'ONPROCESS';
""", """,
task_id="history_finish", task_id="history_finish",
postgres_conn_id=POSTGRES_CONN_ID, postgres_conn_id=POSTGRES_CONN_ID,
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment