Skip to content

Commit 2ea18f5

Browse files
committed
🎨client接收到任务后,增加等待10s再接收下一个任务
1 parent 14a6108 commit 2ea18f5

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

client/node/servertask/looprunner.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -193,6 +193,8 @@ def run(self):
193193
kill_task_id = task_params['task_id']
194194
# kill task时进程如果已不存在,会报异常: ProcessLookupError: [Errno 3] No such process
195195
self._terminate_task(kill_task_id)
196+
# 等待一段时间后再接下一个任务
197+
time.sleep(self._get_task_interval)
196198
continue
197199

198200
# 获取到分析任务,向server发送确认信息(kill_task不需要确认)
@@ -229,6 +231,8 @@ def run(self):
229231
task = Task(task_id, task_name, request_file, response_file, task_log, env=self._origin_os_env)
230232
task.start()
231233
self._running_task.append(task)
234+
# 等待一段时间后再接下一个任务
235+
time.sleep(self._get_task_interval)
232236
except:
233237
# 遇到异常,输出异常信息
234238
LogPrinter.exception("task loop encounter error.")

0 commit comments

Comments
 (0)