调试

common/redis.py

@@ -44,13 +44,13 @@ def get_data(name, feishu_id, feishu_sheet):
         acquire_lock = client.set(lock, 1, ex=60, nx=True)
         if not acquire_lock:
             return None
-        if name == 'pl-gjc':
+        if name == 'dy-pl-gjc' or name == 'ks-pl-gjc':
             data = Material.get_keyword_data(feishu_id, feishu_sheet)
         else:
             data = Material.get_task_data(feishu_id, feishu_sheet)
         client.rpush(task, *data)
     ret = client.lpop(task)
-    if name == 'pl-gjc' or name == 'dd-sp':
+    if name == 'dypl-gjc' or name == 'dd-sp':
         client.rpush(task, ret)
     return ret
 

video_rewriting/video_processor.py

@@ -563,7 +563,7 @@ class VideoProcessor:
                 Common.logger("redis").error(f"{mark}任务开始新的一轮\n")
                 return
             task = json.loads(data)
-            if mark == 'pl-gjc' and task['channel_id'] == '抖音搜索':
+            if mark == 'dy-pl-gjc' and task['channel_id'] == '抖音搜索':
                 mark_count = 'dyss-count'
                 count = get_first_value_with_prefix(mark_count)
                 increment_key(mark_count)