update

task/advertisement_strategy_d.py

@@ -125,7 +125,7 @@ for t in range(0, task_days):
     )a2
     on a2.device_id = a1.cl_id
     AND a2.partition_date=a1.partition_date
-    group by partition_date""".format(start_date=yesterday_str, end_date=today_str, )
+    group by a2.partition_date""".format(start_date=yesterday_str, end_date=today_str, )
     bus_detail_pv_df = spark.sql(bus_detail_pv_sql)
     # bus_detail_pv_df.createOrReplaceTempView("bus_detail_pv_df")
     sql_res = bus_detail_pv_df.collect()