wangkun преди 2 години
родител
ревизия
aaea563467
променени са 1 файла, в които са добавени 1 реда и са изтрити 1 реда
  1. 1 1
      scheduling/scheduling_main/crawler_scheduling.py

+ 1 - 1
scheduling/scheduling_main/crawler_scheduling.py

@@ -50,7 +50,7 @@ class Scheduling:
     @classmethod
     def get_redis(cls, log_type, crawler, env, machine):
         redis_data = RedisHelper.redis_pop(env, machine)
-        if redis_data is None:
+        if redis_data is None or len(redis_data) == 0:
             Common.logger(log_type, crawler).info("Redis为空,等待1秒")
             time.sleep(1)
         else: