update

task/spark_test.py

@@ -191,8 +191,8 @@ WHERE spam_pv.device_id IS NULL
         # print(count_user_count, res, portratit_res)
         sql_res_list = con_sql(sql)
         kyc_str_list= []
-        if sql_res:
-            print(sql_res,type(sql_res))
+        if sql_res_list:
+            print(sql_res_list,type(sql_res_list))
             kyc_str_list = sql_res_list[0][1].split(",")
 
         temp_count = 0