update dairyQueueUpdate file

diaryQueueUpdate.py

@@ -106,15 +106,8 @@ def get_score(queue_arg):
     cursor.execute(sql)
     result = cursor.fetchall()
     score_df = pd.DataFrame(list(result)).dropna()
-    if score_df.empty:
-        print("获取的日记列表是空")
-        return False
-    else:
-        score_df = score_df.rename(columns = {0:"score",1:"cid"})
-        print("日记打分表")
-        print(score_df.head(1))
-        db.close()
-        return score_df
+    db.close()
+    return score_df
 
 
 def update_dairy_queue(score_df,predict_score_df):
@@ -221,11 +214,15 @@ def pipe_line(queue_name, queue_arg, device_id):
     predict(queue_name, queue_arg, device_id)
     predict_score_df = save_result(queue_name, queue_arg, device_id)
     score_df = get_score(queue_arg)
-    if score_df:
+    if score_df.empty:
+        print("获取的日记列表是空")
+        return False
+    else:
+        score_df = score_df.rename(columns={0: "score", 1: "cid"})
+        print("日记打分表")
+        print(score_df.head(1))
         diary_queue = update_dairy_queue(score_df, predict_score_df)
         return diary_queue
-    else:
-        return False
 
 
 def user_update(device_id,city_id,data_set_cid):