Restructure redis returner, since it did notwork before anyway

This commit is contained in:
Thomas S Hatch 2012-11-01 01:11:51 -06:00
parent 1ef1b2fdc8
commit 4425aa1170

View File

@ -41,7 +41,6 @@ def returner(ret):
Return data to a redis data store Return data to a redis data store
''' '''
serv = _get_serv() serv = _get_serv()
serv.sadd('{0}:jobs'.format(ret['id'])) serv.set('{0}:{1}'.format(ret['id'], ret['jid']), json.dumps(ret))
serv.set('{0}:{1}'.format(ret['jid'], json.dumps(ret['return']))) serv.lpush('{0}:{1}'.format(ret['id'], ret['fun']), ret['jid'])
serv.sadd('jobs', ret['jid']) serv.sadd('minions', ret['id'])
serv.sadd(ret['jid'], ret['id'])