|
@@ -57,9 +57,11 @@ class AcdService:
|
|
self.cache.add_call_info(call_info)
|
|
self.cache.add_call_info(call_info)
|
|
|
|
|
|
def try_transfer_agent(self):
|
|
def try_transfer_agent(self):
|
|
- # self.logger.info("AcdService tryTransferAgent start")
|
|
|
|
|
|
+ print("AcdService tryTransferAgent start", len(self.holdsQueue), flush=True)
|
|
|
|
+ self.logger.info("AcdService tryTransferAgent start")
|
|
all_task = []
|
|
all_task = []
|
|
for k, v in self.holdsQueue.items():
|
|
for k, v in self.holdsQueue.items():
|
|
|
|
+ print("AcdService tryTransferAgent start, queue.k:%s, queue.v:%s"% (k, v.qsize()), flush=True)
|
|
self.logger.info("AcdService tryTransferAgent start, queue.k:%s, queue.v:%s", k, v.qsize())
|
|
self.logger.info("AcdService tryTransferAgent start, queue.k:%s, queue.v:%s", k, v.qsize())
|
|
if v.qsize() <= 0:
|
|
if v.qsize() <= 0:
|
|
self.holdsQueue.pop(k, None)
|
|
self.holdsQueue.pop(k, None)
|