Skip to content

Commit 5c6e8e6

Browse files
committed
all test passed with "resque:" prefix
1 parent b5aae6a commit 5c6e8e6

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

src/pyres/worker.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -168,7 +168,7 @@ def working(cls, host):
168168
for key in total:
169169
value = resq.redis.get(key)
170170
if value:
171-
w = Worker.find(key[7:], resq)
171+
w = Worker.find(key[14:], resq) #resque:worker:
172172
names.append(w)
173173
return names
174174

@@ -198,4 +198,4 @@ def exists(cls, worker_id, resq):
198198
queues = options.queue_list.split(',')
199199
import sys
200200
sys.path.insert(0,'/Users/mgeorge/dev/pyres/src')
201-
Worker.run(queues, options.server)
201+
Worker.run(queues, options.server)

src/tests.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -281,8 +281,6 @@ def test_working(self):
281281
name = "%s:%s:%s" % (os.uname()[1],os.getpid(),'basic')
282282
workers = Worker.working(self.resq)
283283
assert len(workers) == 1
284-
print "...ccc...",str(worker)
285-
print "..ddd...",str(workers[0])
286284
assert str(worker) == str(workers[0])
287285
assert worker != workers[0]
288286

0 commit comments

Comments
 (0)