@Marvin may i know why its getting crashed?

Your message was too long, here's your message at the allowed limit: 1 Apr 23 2026 2 INFO 3 Worker 'ProcessWorker 50173b80-737d-45f4-a480-22f1e4a34e57' submitting flow run 'e3835fb6-635a-4ca4-827c-ce978065393e' 4 8 44 30 PM 5 prefect flow_runs worker 6 INFO 7 Starting flow run process 8 8 44 39 PM 9 prefect flow_runs runner 10 INFO 11 Flow run 'iron-griffin' submitted to infrastructure 12 8 44 39 PM 13 prefect flow_runs worker 14 INFO 15 Downloading flow code from storage at ' ' 16 8 44 44 PM 17 prefect flow_runs 18 ERROR 19 Unexpected exception encountered when trying to load flow 20 Traceback (most recent call last) 21 File <frozen importlib _bootstrap_external> line 1022 in exec_module 22 File <frozen importlib _bootstrap_external> line 1159 in get_code 23 File <frozen importlib _bootstrap_external> line 1217 in get_data 24 FileNotFoundError [Errno 2] No such file or directory 'C \\Users\\ASUSVI~1\\AppData\\Local\\Temp\\tmpl5fc28rzprefect\\tmp_issue_20441 py' 25 26 The above exception was the direct cause of the following exception 27 28 Traceback (most recent call last) 29 File D \company\prefect\src\prefect\engine py line 165 in <module> 30 flow Flow[ Any] = load_flow(flow_run) 31 ~~~~~~~~~^^^^^^^^^^ 32 File D \company\prefect\src\prefect\flow_engine py line 233 in load_flow 33 flow = run_coro_as_sync( 34 load_flow_from_flow_run(flow_run use_placeholder_flow=False) 35 ) 36 File D \company\prefect\src\prefect\utilities\asyncutils\__init__ py line 207 in run_coro_as_sync 37 return call result() 38 ~~~~~~~~~~~^^ 39 File D \company\prefect\src\prefect\_internal\concurrency\calls py line 365 in result 40 return self future result(timeout=timeout) 41 ~~~~~~~~~~~~~~~~~~^^^^^^^^^^^^^^^^^ 42 File D \company\prefect\src\prefect\_internal\concurrency\calls py line 192 in result 43 return self __get_result() 44 ~~~~~~~~~~~~~~~~~^^ 45 File C \Python313\Lib\concurrent\futures\_base py line 401 in __get_result 46 raise self _exception 47 File D \company\prefect\src\prefect\_internal\concurrency\calls py line 441 in _run_async 48 result = await coro 49 ^^^^^^^^^^ 50 File D \company\prefect\src\prefect\utilities\asyncutils\__init__ py line 188 in coroutine_wrapper 51 return await task 52 ^^^^^^^^^^ 53 File D \company\prefect\src\prefect\client\utilities py line 69 in wrapper 54 return await func(client *args **kwargs) 55 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ 56 File D \company\prefect\src\prefect\flows py line 3163 in load_flow_from_flow_run 57 flow = await run_sync_in_worker_thread( 58 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ 59 <3 lines> 60 ) 61 ^ 62 File D \company\prefect\src\prefect\utilities\asyncutils\__init__ py line 233 in run_sync_in_worker_thread 63 result = await <http //anyio to|anyio to>_thread run_sync( 64 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ 65 call_with_mark call abandon_on_cancel=True limiter=get_thread_limiter() 66 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ 67 ) 68 ^ 69 File D \company\prefect\ venv\Lib\site-packages\anyio\to_thread py line 63 in run_sync 70 return await get_async_backend() run_sync_in_worker_thread( 71 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ 72 func args abandon_on_cancel=abandon_on_cancel limiter=limiter 73 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ 74 ) 75 ^ 76 File D \company\prefect\ venv\Lib\site-packages\anyio\_backends\_asyncio py line 2518 in run_sync_in_worker_thread 77 return await future 78 ^^^^^^^^^^^^ 79 File D \company\prefect\ venv\Lib\site-packages\anyio\_backends\_asyncio py line 1002 in run 80 result = context run(func *args) 81 File D \company\prefect\src\prefect\utilities\asyncutils\__init__ py line 243 in call_with_mark 82 return call() 83 File D \company\prefect\src\prefect\flows py line 2838 in load_flow_from_entrypoint 84 flow Flow[P Any] = import_object(entrypoint) # pyright ignore[reportRedeclaration] 85 ~~~~~~~~~~~~~^^^^^^^^^^^^ 86 File D \company\prefect\src\prefect\utilities\importtools py line 153 in import_object

S D:\company\prefect>

> $env:PREFECT_API_URL="http://127.0.0.1:4200/api"

> uv run prefect worker start --pool test-missing-block --type process

Worker 'ProcessWorker 50173b80-737d-45f4-a480-22f1e4a34e57' started! 204430.525 | INFO | prefect.flow_runs.worker - Worker 'ProcessWorker 50173b80-737d-45f4-a480-22f1e4a34e57' submitting flow run 'e3835fb6-635a-4ca4-827c-ce978065393e' 204439.276 | INFO | prefect.flow_runs.runner - Starting flow run process... 204439.358 | INFO | prefect.flow_runs.worker - Flow run 'iron-griffin' submitted to infrastructure 204444.112 | INFO | Flow run 'iron-griffin' - Downloading flow code from storage at '.' 204444.125 | ERROR | Flow run 'iron-griffin' - Unexpected exception encountered when trying to load flow Traceback (most recent call last): File "<frozen importlib._bootstrap_external>", line 1022, in exec_module File "<frozen importlib._bootstrap_external>", line 1159, in get_code File "<frozen importlib._bootstrap_external>", line 1217, in get_data FileNotFoundError: [Errno 2] No such file or directory: 'C:\\Users\\ASUSVI~1\\AppData\\Local\\Temp\\tmpl5fc28rzprefect\\tmp_issue_20441.py' The above exception was the direct cause of the following exception: Traceback (most recent call last): File "D:\company\prefect\src\prefect\engine.py", line 165, in <module> flow: "Flow[..., Any]" = load_flow(flow_run) ~~~~~~~~~^^^^^^^^^^ File "D:\company\prefect\src\prefect\flow_engine.py", line 233, in load_flow flow = run_coro_as_sync( load_flow_from_flow_run(flow_run, use_placeholder_flow=False) ) File "D:\company\prefect\src\prefect\utilities\asyncutils\__init__.py", line 207, in run_coro_as_sync return call.result() ~~~~~~~~~~~^^ File "D:\company\prefect\src\prefect\_internal\concurrency\calls.py", line 365, in result return self.future.result(timeout=timeout) ~~~~~~~~~~~~~~~~~~^^^^^^^^^^^^^^^^^ File "D:\company\prefect\src\prefect\_internal\concurrency\calls.py", line 192, in result return self.__get_result() ~~~~~~~~~~~~~~~~~^^ File "C:\Python313\Lib\concurrent\futures\_base.py", line 401, in __get_result raise self._exception File "D:\company\prefect\src\prefect\_internal\concurrency\calls.py", line 441, in _run_async result = await coro ^^^^^^^^^^ File "D:\company\prefect\src\prefect\utilities\asyncutils\__init__.py", line 188, in coroutine_wrapper return await task ^^^^^^^^^^ File "D:\company\prefect\src\prefect\client\utilities.py", line 69, in wrapper return await func(client, *args, **kwargs) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ File "D:\company\prefect\src\prefect\flows.py", line 3163, in load_flow_from_flow_run flow = await run_sync_in_worker_thread( ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ...<3 lines>... ) ^ File "D:\company\prefect\src\prefect\utilities\asyncutils\__init__.py", line 233, in run_sync_in_worker_thread result = await anyio.to_thread.run_sync( ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ call_with_mark, call, abandon_on_cancel=True, limiter=get_thread_limiter() ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ) ^ File "D:\company\prefect\.venv\Lib\site-packages\anyio\to_thread.py", line 63, in run_sync return await get_async_backend().run_sync_in_worker_thread( ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ func, args, abandon_on_cancel=abandon_on_cancel, limiter=limiter ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ) ^ File "D:\company\prefect\.venv\Lib\site-packages\anyio\_backends\_asyncio.py", line 2518, in run_sync_in_worker_thread return await future ^^^^^^^^^^^^ File "D:\company\prefect\.venv\Lib\site-packages\anyio\_backends\_asyncio.py", line 1002, in run result = context.run(func, *args) File "D:\company\prefect\src\prefect\utilities\asyncutils\__init__.py", line 243, in call_with_mark return call() File "D:\company\prefect\src\prefect\flows.py", line 2838, in load_flow_from_entrypoint flow: Flow[P, Any] = import_object(entrypoint) # pyright: ignore[reportRedeclaration] ~~~~~~~~~~~~~^^^^^^^^^^^^ File "D:\company\prefect\src\prefect\utilities\importtools.py", line 153, in import_object module = load_script_as_module(script_path) File "D:\company\prefect\src\prefect\utilities\importtools.py", line 118, in load_script_as_module raise ScriptError(user_exc=exc, path=path) from exc prefect.exceptions.ScriptError: Script at 'tmp_issue_20441.py' encountered an exception: FileNotFoundError(2, 'No such file or directory') 204444.231 | ERROR | prefect.engine - Execution of flow run 'e3835fb6-635a-4ca4-827c-ce978065393e' exited with unexpected exception Traceback (most recent call last): File "<frozen importlib._bootstrap_external>", line 1022, in exec_module File "<frozen importlib._bootstrap_external>", line 1159, in get_code File "<frozen importlib._bootstrap_external>", line 1217, in get_data FileNotFoundError: [Errno 2] No such file or directory: 'C:\\Users\\ASUSVI~1\\AppData\\Local\\Temp\\tmpl5fc28rzprefect\\tmp_issue_20441.py' The above exception was the direct cause of the following exception: Traceback (most recent call last): File "D:\company\prefect\src\prefect\engine.py", line 87, in handle_engine_signals yield File "D:\company\prefect\src\prefect\engine.py", line 165, in <module> flow: "Flow[..., Any]" = load_flow(flow_run) ~~~~~~~~~^^^^^^^^^^ File "D:\company\prefect\src\prefect\flow_engine.py", line 233, in load_flow flow = run_coro_as_sync( load_flow_from_flow_run(flow_run, use_placeholder_flow=False) ) File "D:\company\prefect\src\prefect\utilities\asyncutils\__init__.py", line 207, in run_coro_as_sync return call.result() ~~~~~~~~~~~^^ File "D:\company\prefect\src\prefect\_internal\concurrency\calls.py", line 365, in result return self.future.result(timeout=timeout) ~~~~~~~~~~~~~~~~~~^^^^^^^^^^^^^^^^^ File "D:\company\prefect\src\prefect\_internal\concurrency\calls.py", line 192, in result return self.__get_result() ~~~~~~~~~~~~~~~~~^^ File "C:\Python313\Lib\concurrent\futures\_base.py", line 401, in __get_result raise self._exception File "D:\company\prefect\src\prefect\_internal\concurrency\calls.py", line 441, in _run_async result = await coro ^^^^^^^^^^ File "D:\company\prefect\src\prefect\utilities\asyncutils\__init__.py", line 188, in coroutine_wrapper return await task ^^^^^^^^^^ File "D:\company\prefect\src\prefect\client\utilities.py", line 69, in wrapper return await func(client, *args, **kwargs) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ File "D:\company\prefect\src\prefect\flows.py", line 3163, in load_flow_from_flow_run flow = await run_sync_in_worker_thread( ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ...<3 lines>... ) ^ File "D:\company\prefect\src\prefect\utilities\asyncutils\__init__.py", line 233, in run_sync_in_worker_thread result = await anyio.to_thread.run_sync( ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ call_with_mark, call, abandon_on_cancel=True, limiter=get_thread_limiter() ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ) ^ File "D:\company\prefect\.venv\Lib\site-packages\anyio\to_thread.py", line 63, in run_sync return await get_async_backend().run_sync_in_worker_thread( ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ func, args, abandon_on_cancel=abandon_on_cancel, limiter=limiter ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ) ^ File "D:\company\prefect\.venv\Lib\site-packages\anyio\_backends\_asyncio.py", line 2518, in run_sync_in_worker_thread return await future ^^^^^^^^^^^^ File "D:\company\prefect\.venv\Lib\site-packages\anyio\_backends\_asyncio.py", line 1002, in run result = context.run(func, *args) File "D:\company\prefect\src\prefect\utilities\asyncutils\__init__.py", line 243, in call_with_mark return call() File "D:\company\prefect\src\prefect\flows.py", line 2838, in load_flow_from_entrypoint flow: Flow[P, Any] = import_object(entrypoint) # pyright: ignore[reportRedeclaration] ~~~~~~~~~~~~~^^^^^^^^^^^^ File "D:\company\prefect\src\prefect\utilities\importtools.py", line 153, in import_object module = load_script_as_module(script_path) File "D:\company\prefect\src\prefect\utilities\importtools.py", line 118, in load_script_as_module raise ScriptError(user_exc=exc, path=path) from exc prefect.exceptions.ScriptError: Script at 'tmp_issue_20441.py' encountered an exception: FileNotFoundError(2, 'No such file or directory') 204445.246 | ERROR | prefect.flow_runs.runner - Process for flow run 'iron-griffin' exited with status code: 1; Process exited with a general error. 204445.247 | INFO | prefect.flow_runs.runner - Check the flow run logs for an unhandled exception or assertion error. 204445.378 | INFO | prefect.flow_runs.worker - Reported flow run 'e3835fb6-635a-4ca4-827c-ce978065393e' as crashed: Flow run infrastructure exited with non-zero status code 1. Process exited with a general error. 204445.380 | INFO | prefect.flow_runs.worker - Check the flow run logs for an unhandled exception or assertion error. 204445.548 | INFO | prefect.flow_runs.runner - Loading flow to check for on_crashed hooks 204446.096 | INFO | Flow run 'iron-griffin' - Downloading flow code from storage at '.'