更新视图

dags/psql/reflush_per_minute.py

@@ -27,6 +27,8 @@ dag = DAG(
 sql1 = 'refresh materialized view concurrently materialized_doctor_view'
 sql2 = 'refresh materialized view concurrently materialized_hospital_view'
 sql3 = 'refresh materialized view concurrently materialized_plan_view'
+sql4 = 'refresh materialized view concurrently materialized_tag_view'
+sql5 = 'refresh materialized view concurrently materialized_consult_view'
 
 t1: PostgresOperator = PostgresOperator(
     task_id='psql_reflush_per_minute_task_001',
@@ -49,5 +51,17 @@ t3 = PostgresOperator(
     dag=dag,
     database='pims')
 
-t1 >> t2
-t2 >> t3
+t4 = PostgresOperator(
+    task_id='psql_reflush_per_minute_task_04',
+    postgres_conn_id='postgres-test',
+    sql=sql4,
+    dag=dag,
+    database='pims')
+
+
+t5 = PostgresOperator(
+    task_id='psql_reflush_per_minute_task_05',
+    postgres_conn_id='postgres-test',
+    sql=sql5,
+    dag=dag,
+    database='pims')