Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- /Users/edwarddavies/code/Prefect-API-Demo/venv/bin/python /Users/edwarddavies/code/Prefect-API-Demo/src/s3.py
- 12:42:11.456 | INFO | prefect.engine - Created flow run 'magenta-dugong' for flow 's3'
- 12:42:12.853 | INFO | Flow run 'magenta-dugong' - Created task run 'upload_to_s3-37a57047-0' for task 'upload_to_s3'
- 12:42:12.854 | INFO | Flow run 'magenta-dugong' - Executing 'upload_to_s3-37a57047-0' immediately...
- 12:42:13.124 | ERROR | Task run 'upload_to_s3-37a57047-0' - Encountered exception during execution:
- Traceback (most recent call last):
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/engine.py", line 1046, in orchestrate_task_run
- result = await task.fn(*args, **kwargs)
- File "/Users/edwarddavies/code/Prefect-API-Demo/src/s3.py", line 18, in upload_to_s3
- await block.put_directory(path, file_name)
- AttributeError: 'coroutine' object has no attribute 'put_directory'
- 12:42:13.413 | ERROR | Task run 'upload_to_s3-37a57047-0' - Finished in state Failed('Task run encountered an exception.')
- 12:42:13.413 | ERROR | Flow run 'magenta-dugong' - Encountered exception during execution:
- Traceback (most recent call last):
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/engine.py", line 557, in orchestrate_flow_run
- result = await run_sync(flow_call)
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/utilities/asyncutils.py", line 56, in run_sync_in_worker_thread
- return await anyio.to_thread.run_sync(call, cancellable=True)
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/anyio/to_thread.py", line 31, in run_sync
- return await get_asynclib().run_sync_in_worker_thread(
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/anyio/_backends/_asyncio.py", line 937, in run_sync_in_worker_thread
- return await future
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/anyio/_backends/_asyncio.py", line 867, in run
- result = context.run(func, *args)
- File "/Users/edwarddavies/code/Prefect-API-Demo/src/s3.py", line 11, in s3
- upload_to_s3("test.csv", "hubspot")
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/tasks.py", line 294, in __call__
- return enter_task_run_engine(
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/engine.py", line 687, in enter_task_run_engine
- return run_async_from_worker_thread(begin_run)
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/utilities/asyncutils.py", line 136, in run_async_from_worker_thread
- return anyio.from_thread.run(call)
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/anyio/from_thread.py", line 49, in run
- return asynclib.run_async_from_thread(func, *args)
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/anyio/_backends/_asyncio.py", line 970, in run_async_from_thread
- return f.result()
- File "/Users/edwarddavies/.pyenv/versions/3.9.12/lib/python3.9/concurrent/futures/_base.py", line 446, in result
- return self.__get_result()
- File "/Users/edwarddavies/.pyenv/versions/3.9.12/lib/python3.9/concurrent/futures/_base.py", line 391, in __get_result
- raise self._exception
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/engine.py", line 806, in create_task_run_then_submit
- return await future._result()
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/futures.py", line 220, in _result
- return final_state.result(raise_on_failure=raise_on_failure)
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/orion/schemas/states.py", line 145, in result
- raise data
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/engine.py", line 1046, in orchestrate_task_run
- result = await task.fn(*args, **kwargs)
- File "/Users/edwarddavies/code/Prefect-API-Demo/src/s3.py", line 18, in upload_to_s3
- await block.put_directory(path, file_name)
- AttributeError: 'coroutine' object has no attribute 'put_directory'
- 12:42:13.575 | ERROR | Flow run 'magenta-dugong' - Finished in state Failed('Flow run encountered an exception.')
- Traceback (most recent call last):
- File "/Users/edwarddavies/code/Prefect-API-Demo/src/s3.py", line 21, in <module>
- s3()
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/flows.py", line 390, in __call__
- return enter_flow_run_engine_from_flow_call(
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/engine.py", line 152, in enter_flow_run_engine_from_flow_call
- return anyio.run(begin_run)
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/anyio/_core/_eventloop.py", line 70, in run
- return asynclib.run(func, *args, **backend_options)
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/anyio/_backends/_asyncio.py", line 292, in run
- return native_run(wrapper(), debug=debug)
- File "/Users/edwarddavies/.pyenv/versions/3.9.12/lib/python3.9/asyncio/runners.py", line 44, in run
- return loop.run_until_complete(main)
- File "/Users/edwarddavies/.pyenv/versions/3.9.12/lib/python3.9/asyncio/base_events.py", line 647, in run_until_complete
- return future.result()
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/anyio/_backends/_asyncio.py", line 287, in wrapper
- return await func(*args)
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/client.py", line 104, in with_injected_client
- return await fn(*args, **kwargs)
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/engine.py", line 228, in create_then_begin_flow_run
- return state.result()
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/orion/schemas/states.py", line 145, in result
- raise data
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/engine.py", line 557, in orchestrate_flow_run
- result = await run_sync(flow_call)
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/utilities/asyncutils.py", line 56, in run_sync_in_worker_thread
- return await anyio.to_thread.run_sync(call, cancellable=True)
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/anyio/to_thread.py", line 31, in run_sync
- return await get_asynclib().run_sync_in_worker_thread(
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/anyio/_backends/_asyncio.py", line 937, in run_sync_in_worker_thread
- return await future
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/anyio/_backends/_asyncio.py", line 867, in run
- result = context.run(func, *args)
- File "/Users/edwarddavies/code/Prefect-API-Demo/src/s3.py", line 11, in s3
- upload_to_s3("test.csv", "hubspot")
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/tasks.py", line 294, in __call__
- return enter_task_run_engine(
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/engine.py", line 687, in enter_task_run_engine
- return run_async_from_worker_thread(begin_run)
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/utilities/asyncutils.py", line 136, in run_async_from_worker_thread
- return anyio.from_thread.run(call)
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/anyio/from_thread.py", line 49, in run
- return asynclib.run_async_from_thread(func, *args)
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/anyio/_backends/_asyncio.py", line 970, in run_async_from_thread
- return f.result()
- File "/Users/edwarddavies/.pyenv/versions/3.9.12/lib/python3.9/concurrent/futures/_base.py", line 446, in result
- return self.__get_result()
- File "/Users/edwarddavies/.pyenv/versions/3.9.12/lib/python3.9/concurrent/futures/_base.py", line 391, in __get_result
- raise self._exception
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/engine.py", line 806, in create_task_run_then_submit
- return await future._result()
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/futures.py", line 220, in _result
- return final_state.result(raise_on_failure=raise_on_failure)
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/orion/schemas/states.py", line 145, in result
- raise data
- File "/Users/edwarddavies/code/Prefect-API-Demo/venv/lib/python3.9/site-packages/prefect/engine.py", line 1046, in orchestrate_task_run
- result = await task.fn(*args, **kwargs)
- File "/Users/edwarddavies/code/Prefect-API-Demo/src/s3.py", line 18, in upload_to_s3
- await block.put_directory(path, file_name)
- AttributeError: 'coroutine' object has no attribute 'put_directory'
- Process finished with exit code 1
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement