

def working_on(self, job):
    setproctitle(('pyres_minion:%s: working on job: %s' % (os.getppid(), job._payload)))
    self.logger.debug('marking as working on')
    data = {
        'queue': job._queue,
        'run_at': int(time.mktime(datetime.datetime.now().timetuple())),
        'payload': job._payload,
    }
    data = json.dumps(data)
    self.resq.redis[('resque:minion:%s' % str(self))] = data
    self.logger.debug(('minion:%s' % str(self)))

dataset/ETHPy150Open binarydud/pyres/pyres/horde.py Minion.working_on/original