no message

Pyspark_job/img_search/img_local_path.py

@@ -38,7 +38,7 @@ class AsinImageLocalPath(object):
     def read_data(self):
         # sql = f"select img_unique from selection.{self.image_table} where state=1;"
         # df = pd.read_sql(sql, con=self.engine_doris)
-        sql = f"SELECT * from us_inv_img_info WHERE updated_at>= CURDATE() - INTERVAL 3 DAY and state =3;"
+        sql = f"SELECT * from us_inv_img_info WHERE updated_at>= CURDATE() - INTERVAL 3 DAY and state =3 and id_segment is not null;"
         df = pd.read_sql(sql, con=self.engine_mysql)
         print(f"sql: {sql}", df.shape)
         return df