|
@@ -53,7 +53,7 @@ class InboundClient:
|
|
|
self.executors = {x: concurrent.futures.ThreadPoolExecutor(max_workers=1, thread_name_prefix="client-event-pool") for x in range(self.thread_num)}
|
|
|
self.delay_action_executor = concurrent.futures.ThreadPoolExecutor(max_workers=5)
|
|
|
self.delay_action_scheduler = BackgroundScheduler()
|
|
|
- self.delay_action_scheduler.add_job(self.submit_delay_action, 'interval', seconds=1, max_instances=1)
|
|
|
+ self.delay_action_scheduler.add_job(self.submit_delay_action, 'interval', seconds=1, max_instances=1, name='delay_action_daemon')
|
|
|
self.delay_action_scheduler.start()
|
|
|
threading.Thread(target=self.start, args=()).start()
|
|
|
|
|
@@ -632,7 +632,7 @@ class OutboundClient:
|
|
|
|
|
|
self.cache_job_scheduler = BackgroundScheduler()
|
|
|
self.cache_job_scheduler.add_job(self.update_cache_job, run_date=datetime.now())
|
|
|
- self.cache_job_scheduler.add_job(self.update_cache_job, 'interval', seconds=60, max_instances=1)
|
|
|
+ self.cache_job_scheduler.add_job(self.update_cache_job, 'interval', seconds=60, max_instances=1, name='cache_job_daemon')
|
|
|
self.cache_job_scheduler.start()
|
|
|
|
|
|
def update_cache_job(self):
|