From fa7aee311e53a080e2c79cedc077f05700e934a8 Mon Sep 17 00:00:00 2001 From: "jiang,yinyuan" Date: Mon, 8 Apr 2019 21:20:04 +0800 Subject: [PATCH] two bug fix --- pyspider/libs/utils.py | 1 + pyspider/scheduler/scheduler.py | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/pyspider/libs/utils.py b/pyspider/libs/utils.py index 1c653b17d..ad9881179 100644 --- a/pyspider/libs/utils.py +++ b/pyspider/libs/utils.py @@ -434,6 +434,7 @@ def python_console(namespace=None): def check_port_open(port, addr='127.0.0.1'): sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) result = sock.connect_ex((addr, port)) + sock.close() if result == 0: return True else: diff --git a/pyspider/scheduler/scheduler.py b/pyspider/scheduler/scheduler.py index 084baff28..de94dfd72 100644 --- a/pyspider/scheduler/scheduler.py +++ b/pyspider/scheduler/scheduler.py @@ -349,7 +349,7 @@ def _check_task_done(self): '''Check status queue''' cnt = 0 try: - while True: + while cnt <= self.LOOP_LIMIT: task = self.status_queue.get_nowait() # check _on_get_info result here if task.get('taskid') == '_on_get_info' and 'project' in task and 'track' in task: