update index

dags/psql/create_table_per_day.py

@@ -52,6 +52,10 @@ sql3 = """
 """.format(month=month)
 print(sql3)
 
+sql4 = """
+    create index user_id_event_time_events_{month} on events_{month}(user_id, event_time);
+""".format(month=month)
+
 
 t1: PostgresOperator = PostgresOperator(
     task_id='psql_auto_create_table_per_day_task_01',
@@ -74,5 +78,14 @@ t3 = PostgresOperator(
     dag=dag,
     database='ruler')
 
+t4 = PostgresOperator(
+    task_id='psql_auto_create_table_per_month_task_04',
+    postgres_conn_id='postgres-test',
+    sql=sql4,
+    dag=dag,
+    database='ruler')
+
+
 t1 >> t2
 t2 >> t3
+t3 >> t4