|
@@ -132,7 +132,7 @@ class PushTaskWorkerPool:
|
|
def process_generate_tasks(self):
|
|
def process_generate_tasks(self):
|
|
time.sleep(1)
|
|
time.sleep(1)
|
|
while True:
|
|
while True:
|
|
- if self.generate_executor._work_queue.qsize() > self.max_push_workers * 5:
|
|
|
|
|
|
+ if self.generate_executor._work_queue.qsize() > self.max_push_workers * 2:
|
|
logger.warning("Too many generate tasks in queue, consume later")
|
|
logger.warning("Too many generate tasks in queue, consume later")
|
|
time.sleep(10)
|
|
time.sleep(10)
|
|
continue
|
|
continue
|