|
@@ -29,8 +29,8 @@ class Callback(object):
|
|
|
while not self.is_stopping:
|
|
|
try:
|
|
|
event, call_info, device_info = self.event_queue.get(timeout=1)
|
|
|
- self.logger.info("callback::event=%s", (event.serialize('json') if event else "empty"))
|
|
|
call_type = CallType.get_by_code(call_info.call_type) if call_info else None
|
|
|
+ self.logger.info("callback::call_type=%s, call_info=%s", call_type, call_info)
|
|
|
if call_type is None:
|
|
|
continue
|
|
|
if CallType.BOT_CALL == call_type:
|
|
@@ -81,5 +81,5 @@ class Callback(object):
|
|
|
random_index = abs(mmh3.hash(random_id)) % len(self.executors)
|
|
|
else:
|
|
|
random_index = random.randint(0, len(self.executors) - 1) if self.executors else 0
|
|
|
- # self.logger.info('choose_thread_pool_executor.index=', random_index, call_id, device_id, wdh_device_id)
|
|
|
+ self.logger.info('choose_thread_pool_executor.index=', random_index, call_id, device_id, wdh_device_id)
|
|
|
return self.executors.get(random_index)
|