store.py 文件源码

def push(self, queue, task, eta=None):
        assert ':' not in queue, 'Queue name must not contain colon: "{}"'.format(queue)
        body = dumps(task, use_bin_type=True)  # TODO: may be better to move task packing to manager
        if eta:
            self.client.zadd(SCHEDULE_KEY, eta, sitem(queue, body))
        else:
            self.client.rpush(rqname(queue), body)