RomanNum3ral
/
scrapy
mirror of https://github.com/scrapy/scrapy.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixed bug with non-keepalive execution queues (closes #190)

This commit is contained in:
Pablo Hoffman 2010-08-04 14:20:45 -03:00
parent 49851d7f55
commit daa9506b34
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
scrapy/core/manager.py
View File

@ -42,7 +42,7 @@ class ExecutionManager(object):
self._start_spider(spider, requests)
if self.engine.has_capacity() and not self._nextcall.active():
self._nextcall = reactor.callLater(self.queue.polling_delay, \
self._start_next_spider)
self._spider_closed)
@defer.inlineCallbacks
def _start_spider(self, spider, requests):
@ -64,7 +64,7 @@ class ExecutionManager(object):
@defer.inlineCallbacks
def start(self):
yield defer.maybeDeferred(self.engine.start)
self._nextcall = reactor.callLater(0, self._spider_closed)
self._nextcall = reactor.callLater(0, self._start_next_spider)
reactor.addSystemEventTrigger('before', 'shutdown', self.stop)
if self.control_reactor:
reactor.run(installSignalHandlers=False)