Skip to content
This repository was archived by the owner on Jun 10, 2024. It is now read-only.

Commit 6634729

Browse files
authored
Merge pull request #800 from binux/binux-patch-1
fix #799
2 parents 124ffef + 8646179 commit 6634729

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

pyspider/scheduler/scheduler.py

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -110,10 +110,11 @@ def update(self, project_info):
110110
self.updatetime = project_info['updatetime']
111111

112112
md5sum = utils.md5string(project_info['script'])
113-
if (self.md5sum != md5sum or self.waiting_get_info) and self.active:
114-
self._send_on_get_info = True
113+
if self.md5sum != md5sum:
115114
self.waiting_get_info = True
116-
self.md5sum = md5sum
115+
self.md5sum = md5sum
116+
if self.waiting_get_info and self.active:
117+
self._send_on_get_info = True
117118

118119
if self.active:
119120
self.task_queue.rate = project_info['rate']
@@ -1269,4 +1270,4 @@ def _load_put_task(self, project, taskid):
12691270

12701271
def run_once(self):
12711272
super(ThreadBaseScheduler, self).run_once()
1272-
self._wait_thread()
1273+
self._wait_thread()

0 commit comments

Comments
 (0)