|
|
@@ -57,7 +57,7 @@ class AcdService:
|
|
|
# self.logger.info("AcdService tryTransferAgent start")
|
|
|
all_task = []
|
|
|
for k, v in self.holdsQueue.items():
|
|
|
- self.logger.info("AcdService tryTransferAgent start, queue.k:%s, q.v", k, v.qsize())
|
|
|
+ self.logger.info("AcdService tryTransferAgent start, queue.k:%s, queue.v:%s", k, v.qsize())
|
|
|
all_task.append(self.pool.submit(self.holds_one_queue, k, v))
|
|
|
wait(all_task, timeout=6, return_when=ALL_COMPLETED)
|
|
|
|
DavidLiu