1

コード

    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 を返す新しい関数を返す

実際の動作

ラムダがモジュール 'rap_stats.MapReduce' に属性 'func_wrap_async' がありません: AttributeError をスローします

アップデート

「@task」と「.response_id」を削除すると機能しますが、非同期で適切に機能させるにはこれらが必要です

4

1 に答える 1