Skip to content

A
airflow-dags-hub
Commit b7c1c60c authored by 吴升宇's avatar 吴升宇
Browse files
Options

fix task

parent 5f3686ae
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 3 deletions
dags/psql/create_table_per_day.py
View file @ b7c1c60c
...@@ -53,7 +53,7 @@ sql3 = """ ...@@ -53,7 +53,7 @@ sql3 = """
print(sql3) print(sql3)
t1 = PostgresOperator( t1: PostgresOperator = PostgresOperator(
task_id='psql_auto_create_table_per_day_task_01', task_id='psql_auto_create_table_per_day_task_01',
postgres_conn_id='postgres-test', postgres_conn_id='postgres-test',
sql=sql1, sql=sql1,
...@@ -74,5 +74,5 @@ t3 = PostgresOperator( ...@@ -74,5 +74,5 @@ t3 = PostgresOperator(
dag=dag, dag=dag,
database='ruler') database='ruler')
t3 >> t2 t1 >> t2
t2 >> t1 t2 >> t3
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