Python asyncio ошибка TypeError: run_in_executor() missing 1 required positional argument: 'executor'

Question

Пытаюсь использовать asyncio для выполнения одной из функций параллельно:

async def _Publish(newslettertext, towhom):
    users_ = await connect.getSpecificUsers(options={'status': 'retail'})
    print(users_) # я получаю необходимый результат на отлично!

И есть функция, которая запускает функцию которая выше:

async def test():
    loop = asyncio.get_event_loop()
    loop.run_in_executor(func=await _Publish(data['newslettertext'], towhom=pressedINFO))

После запуска я получаю результат с функции _Publish, однако по окончанию выполнения функции _Publish, я получаю ошибку:

loop.run_in_executor(func=await _Publish(data['newslettertext'], towhom=pressedINFO))
TypeError: run_in_executor() missing 1 required positional argument: 'executor'

Answer 1

В Функцию run_in_executor можно передать 3 аргумента (исполнитель, функция, аргументы).

Аргумент executor(исполнитель) должен быть экземпляром concurrent.futures.Executor. Если исполнителем является None, то используется исполнитель по умолчанию.

Решение:

Попробуйте первым аргументом в функции передать None.

БЛОГ НА HUSL

Python asyncio ошибка TypeError: run_in_executor() missing 1 required positional argument: 'executor'

Ответы (1 шт):