|
@@ -61,6 +61,9 @@ class AcdService:
|
|
|
all_task = []
|
|
|
for k, v in self.holdsQueue.items():
|
|
|
self.logger.info("AcdService tryTransferAgent start, queue.k:%s, queue.v:%s", k, v.qsize())
|
|
|
+ if v.qsize() <= 0:
|
|
|
+ self.holdsQueue.pop(k, None)
|
|
|
+ continue
|
|
|
all_task.append(self.pool.submit(self.holds_one_queue, k, v))
|
|
|
wait(all_task, timeout=6, return_when=ALL_COMPLETED)
|
|
|
|