You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I am encountering an error in Prefect 3.1.7 where using S3 storage with tasks/flows results in: TypeError: object str can't be used in 'await' expression
The same flow code works fine (with no errors) and results are loaded to s3 on Prefect 3.1.6.
It looks as if results are loaded to s3 using 3.1.7 also but I am getting the following error in my logs:
Traceback (most recent call last):
File "/Users/jennifer/opt/anaconda3/envs/py312/lib/python3.12/site-packages/prefect/transactions.py", line 323, in commit
self.store.persist_result_record(
File "/Users/jennifer/opt/anaconda3/envs/py312/lib/python3.12/site-packages/prefect/results.py", line 702, in persist_result_record
return self._persist_result_record(
^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/Users/jennifer/opt/anaconda3/envs/py312/lib/python3.12/site-packages/prefect/utilities/asyncutils.py", line 349, in coroutine_wrapper
return run_coro_as_sync(ctx_call())
^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/Users/jennifer/opt/anaconda3/envs/py312/lib/python3.12/site-packages/prefect/utilities/asyncutils.py", line 209, in run_coro_as_sync
return call.result()
^^^^^^^^^^^^^
File "/Users/jennifer/opt/anaconda3/envs/py312/lib/python3.12/site-packages/prefect/_internal/concurrency/calls.py", line 330, in result
return self.future.result(timeout=timeout)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/Users/jennifer/opt/anaconda3/envs/py312/lib/python3.12/site-packages/prefect/_internal/concurrency/calls.py", line 193, in result
return self.__get_result()
^^^^^^^^^^^^^^^^^^^
File "/Users/jennifer/opt/anaconda3/envs/py312/lib/python3.12/concurrent/futures/_base.py", line 401, in __get_result
raise self._exception
File "/Users/jennifer/opt/anaconda3/envs/py312/lib/python3.12/site-packages/prefect/_internal/concurrency/calls.py", line 403, in _run_async
result = await coro
^^^^^^^^^^
File "/Users/jennifer/opt/anaconda3/envs/py312/lib/python3.12/site-packages/prefect/utilities/asyncutils.py", line 190, in coroutine_wrapper
return await task
^^^^^^^^^^
File "/Users/jennifer/opt/anaconda3/envs/py312/lib/python3.12/site-packages/prefect/utilities/asyncutils.py", line 343, in ctx_call
result = await async_fn(*args, **kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/Users/jennifer/opt/anaconda3/envs/py312/lib/python3.12/site-packages/prefect/results.py", line 685, in _persist_result_record
await self.result_storage.write_path(
TypeError: object str can't be used in 'await' expression
Bug summary
I am encountering an error in Prefect 3.1.7 where using S3 storage with tasks/flows results in:
TypeError: object str can't be used in 'await' expression
The same flow code works fine (with no errors) and results are loaded to s3 on Prefect 3.1.6.
It looks as if results are loaded to s3 using 3.1.7 also but I am getting the following error in my logs:
Flow code:
Version info
Additional context
No response
The text was updated successfully, but these errors were encountered: