Можно ли отправить задачу в очередь повторного запуска pyRQ в асинхронном / ожидающем режиме? - PullRequest
Новая
       19

Можно ли отправить задачу в очередь повторного запуска pyRQ в асинхронном / ожидающем режиме?

1 голос
/ 11 апреля 2019

Можно ли отправить задачу в очередь pyRQ redis в асинхронном / ожидающем режиме?

Я использую tornado framework, который поддерживает новые функции python await / async.

Посмотрите на этот пример: 

@job(`default`, connection=redis_conn)
def add(a: int, b: int):
    logger.info('Dummy adding task for {} and {}'.format(a, b))
    import time
    time.sleep(1)
    return a + b

Теперь в моем RequestHandler я могу сделать это: 

add.delay(2, 3)

Строка выше производит блок ввода-вывода из-за возможности подключенияпроцесс с Redis.Кто-нибудь имеет идеи, как я могу изменить @job декоратор на async версию, а затем иметь такие строки: 

await add.delay(2, 3)
...