Skip to content

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

update

parent 0c3b2f22
Show whitespace changes
Inline Side-by-side
Showing with 3 additions and 6 deletions
dags/psql/create_table_per_day.py
View file @ 5f3686ae
...@@ -58,24 +58,21 @@ t1 = PostgresOperator( ...@@ -58,24 +58,21 @@ t1 = PostgresOperator(
postgres_conn_id='postgres-test', postgres_conn_id='postgres-test',
sql=sql1, sql=sql1,
dag=dag, dag=dag,
database='ruler', database='ruler')
pool='pricing_pool')
t2 = PostgresOperator( t2 = PostgresOperator(
task_id='psql_auto_create_table_per_day_task_02', task_id='psql_auto_create_table_per_day_task_02',
postgres_conn_id='postgres-test', postgres_conn_id='postgres-test',
sql=sql2, sql=sql2,
dag=dag, dag=dag,
database='ruler', database='ruler')
pool='pricing_pool')
t3 = PostgresOperator( t3 = PostgresOperator(
task_id='psql_auto_create_table_per_day_task_03', task_id='psql_auto_create_table_per_day_task_03',
postgres_conn_id='postgres-test', postgres_conn_id='postgres-test',
sql=sql3, sql=sql3,
dag=dag, dag=dag,
database='ruler', database='ruler')
pool='pricing_pool')
t3 >> t2 t3 >> t2
t2 >> t1 t2 >> t1
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