I have deployed my flow to prefect cloud and when I run the flow I get an issue when trying to execute the sub flow. the sub flow starts but gets stuck in pending and the parent flow errors out with AttributeError: 'Flow' object has no attribute 'result_storage'
‘result storage’ is not listed in any of my flow attributes
Encountered exception during execution:
Traceback (most recent call last):
File "/home/ec2-user/prefect-worker/.venv/prefect/lib/python3.10/site-packages/prefect/engine.py", line 841, in orchestrate_flow_run
result = await flow_call.aresult()
File "/home/ec2-user/prefect-worker/.venv/prefect/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 293, in aresult
return await asyncio.wrap_future(self.future)
File "/home/ec2-user/prefect-worker/.venv/prefect/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 318, in _run_sync
result = self.fn(*self.args, **self.kwargs)
File "/tmp/tmpcesn65bbprefect/flows/direct-mail-sync.py", line 142, in direct_mail_sync
history_conversion(
File "/home/ec2-user/prefect-worker/.venv/prefect/lib/python3.10/site-packages/prefect/flows.py", line 1097, in __call__
return enter_flow_run_engine_from_flow_call(
File "/home/ec2-user/prefect-worker/.venv/prefect/lib/python3.10/site-packages/prefect/engine.py", line 283, in enter_flow_run_engine_from_flow_call
retval = from_sync.wait_for_call_in_loop_thread(
File "/home/ec2-user/prefect-worker/.venv/prefect/lib/python3.10/site-packages/prefect/_internal/concurrency/api.py", line 243, in wait_for_call_in_loop_thread
return call.result()
File "/home/ec2-user/prefect-worker/.venv/prefect/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 284, in result
return self.future.result(timeout=timeout)
File "/home/ec2-user/prefect-worker/.venv/prefect/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 168, in result
return self.__get_result()
File "/usr/local/lib/python3.10/concurrent/futures/_base.py", line 403, in __get_result
raise self._exception
File "/home/ec2-user/prefect-worker/.venv/prefect/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 355, in _run_async
result = await coro
File "/home/ec2-user/prefect-worker/.venv/prefect/lib/python3.10/site-packages/prefect/client/utilities.py", line 51, in with_injected_client
return await fn(*args, **kwargs)
File "/home/ec2-user/prefect-worker/.venv/prefect/lib/python3.10/site-packages/prefect/engine.py", line 653, in create_and_begin_subflow_run
result_factory = await ResultFactory.from_flow(
File "/home/ec2-user/prefect-worker/.venv/prefect/lib/python3.10/site-packages/prefect/client/utilities.py", line 51, in with_injected_client
return await fn(*args, **kwargs)
File "/home/ec2-user/prefect-worker/.venv/prefect/lib/python3.10/site-packages/prefect/results.py", line 180, in from_flow
result_storage=flow.result_storage or ctx.result_factory.storage_block,
AttributeError: 'Flow' object has no attribute 'result_storage'
01:54:23 PM
prefect.flow_runs
Finished in state Failed("Flow run encountered an exception. AttributeError: 'Flow' object has no attribute 'result_storage'")
This is the full error message