|
@@ -760,7 +760,7 @@ class AgentStateService:
|
|
|
self.app = app
|
|
|
self.logger = app.logger
|
|
|
self.redis_handler = RedisHandler()
|
|
|
- self.assigned_recycle_millisecond = 60000
|
|
|
+ self.assigned_recycle_millisecond = 10 * 1000
|
|
|
self.state_service_id_data_map = defaultdict(dict)
|
|
|
self.executor = ThreadPoolExecutor(max_workers=10)
|
|
|
self.data_handle_server = DataHandleServer(app)
|