Код
def zappa_async(func):
print('here')
@wraps(func)
@task(capture_response=True)
def func_wrap_async(*args, **kwargs):
return func(*args, **kwargs)
def func_wrap_async_response_id(*args, **kwargs):
return func_wrap_async(*args, **kwargs).response_id
return func_wrap_async_response_id
Ожидаемое поведение
Возьмите функцию и верните новую функцию, которая является асинхронной и возвращает ее идентификатор ответа
Фактическое поведение
Модуль лямбда-бросков «rap_stats.MapReduce» не имеет атрибута «func_wrap_async»: AttributeError
Update
Работает, когда я удаляю «@task» и «.response_id», но они мне нужны по порядкудля правильной работы асинхронно