add print

diaryQueueUpdate.py

@@ -94,7 +94,7 @@ def feature_en(x_list, device_id):
 def transform_ffm_format(df,queue_name):
     with open(DIRECTORY_PATH + "ffm.pkl", "rb") as f:
         ffm_format_pandas = pickle.load(f)
-        data = ffm_format_pandas.transform(df)
+        data = ffm_format_pandas.native_transform(df)
         predict_file_name = DIRECTORY_PATH + "result/{0}_{1}.csv".format(device_id, queue_name)
         data.to_csv(predict_file_name, index=False, header=None)
         # print("done ffm")
@@ -223,7 +223,7 @@ if __name__ == "__main__":
     native_queue_list, nearby_queue_list, nation_queue_list, megacity_queue_list = test_con_sql(device_id)
     name_dict = {"native_queue": native_queue_list, "nearby_queue": nearby_queue_list,
                  "nation_queue": nation_queue_list, "megacity_queue": megacity_queue_list}
-    pool = Pool(4)
+    pool = Pool(1)
     for key in name_dict.keys():
         pool.apply_async(multi_update,(key,name_dict,))
     pool.close()