update

task/search_strategy_d.py

@@ -122,7 +122,7 @@ for t in range(0, task_days):
             )t2
                 ON t1.device_id = t2.device_id
         )t3
-         group by partition_date,device_id""".format(yesterday_str=yesterday_str,today_str=today_str)
+         group by t3.partition_date,t3.device_id""".format(yesterday_str=yesterday_str,today_str=today_str)
     print(sql_distinct_device_id)
     distinct_device_id_df = spark.sql(sql_distinct_device_id,)
     distinct_device_id_view = distinct_device_id_df.createOrReplaceTempView("distinct_device_id_view")