From fbb807c0d42e842a1c116f8ed8fe83f704a5312f Mon Sep 17 00:00:00 2001 From: Steven Robertson Date: Fri, 13 Jan 2012 20:55:44 -0500 Subject: [PATCH] Handle client being suspended --- worker.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/worker.py b/worker.py index 8951f04..8c87c42 100644 --- a/worker.py +++ b/worker.py @@ -67,8 +67,6 @@ def work(server): rev = git_rev() r = redis.StrictRedis(server) wid = uu('workers') - # TODO: store information about this worker in a WID-named string with an - # expiration, and touch/update it every so often r.sadd('renderpool:' + rev + ':workers', wid) r.hmset(wid, { 'host': socket.gethostname(), @@ -95,7 +93,7 @@ def work(server): continue sid, sidx, pid, gid, ftime, ftag = task[1].split(' ', 5) - if pid != last_pid or gid != last_gid: + if pid != last_pid or gid != last_gid or not riter: if riter: push_frame(r, riter.send(None)) gnm = genome.Genome(json.loads(r.get(gid)))