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

updated test-worker script and moved to tools 

--HG--
extra : convert_revision : svn%3Ab85faa78-f9eb-468e-a121-7cced6da292c%40327
This commit is contained in:
Pablo Hoffman 2008-10-22 17:14:07 +00:00
parent 1c74260752
commit 57848d46b2
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
scrapy/branches/cluster-refactor/scrapy/contrib/pbcluster/worker/testworker.py → scrapy/branches/cluster-refactor/scrapy/contrib/pbcluster/tools/test-worker.py
View File

@ -1,9 +1,10 @@
#!/usr/bin/python2.5
import sys
import pprint
from twisted.spread import pb
from twisted.internet import reactor
from twisted.python import util
import sys
factory = pb.PBClientFactory()
reactor.connectTCP("localhost", 8789, factory)
@ -11,15 +12,13 @@ d = factory.getRootObject()
sys.argv.pop(0)
if not sys.argv:
if not sys.argv or sys.argv[0] == '--status':
d.addCallback(lambda object: object.callRemote("status"))
elif sys.argv[0] == "-s":
elif sys.argv[0] == "--stop":
d.addCallback(lambda object: object.callRemote("stop", sys.argv[1]))
elif sys.argv[0] == "-r":
elif sys.argv[0] == "--run":
d.addCallback(lambda object: object.callRemote("run", sys.argv[1]))
elif sys.argv[0] == "-t":
d.addCallback(lambda object: object.callRemote("statistics"))
d.addCallbacks(callback = util.println, errback = lambda reason: 'error: '+str(reason.value))
d.addCallbacks(callback=pprint.pprint, errback=lambda reason:'error: ' + str(reason.value))
d.addCallback(lambda _: reactor.stop())
reactor.run()