代码
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
预期行为
获取一个函数并返回一个异步的新函数并返回其响应 id
实际行为
lambda 抛出模块“rap_stats.MapReduce”没有属性“func_wrap_async”:AttributeError
更新
当我删除“@task”和“.response_id”时它可以工作,但我需要这些才能使其异步正常运行