Hello guys I m blocked with the problem MissingResult State

Question

Hello guys I m blocked with the problem MissingResult State data is missing DaskTaskRunner When I try to run multiple flows ~30 in the same moment some flows are failed with this error It should not be the problem of Dask cluster because on the same cluster I can run ~50 flows with prefect1 run without any problem The problem is that it s a random error the flow which had this problem previous run won t have it on the next one I add a stack trace in threads I see on GitHub that problem exists is more than one year <https github com PrefectHQ prefect dask issues 67|MissingResult State data is missing Issue 67 PrefectHQ prefect dask GitHub> Any suggestions I m on the last prefect 2 7 12

Aleksandr Liadov · Answer

```Encountered exception during execution Traceback most recent call last File opt pysetup venv lib python3 8 site packages prefect engine py line 637 in orchestrate flow run result = await run sync flow call File opt pysetup venv lib python3 8 site packages prefect utilities asyncutils py line 91 in run sync in worker thread return await anyio to thread run sync File opt pysetup venv lib python3 8 site packages anyio to thread py line 31 in run sync return await get asynclib run sync in worker thread File opt pysetup venv lib python3 8 site packages anyio backends asyncio py line 937 in run sync in worker thread return await future File opt pysetup venv lib python3 8 site packages anyio backends asyncio py line 867 in run result = context run func args File app flows 2 sub flows features execution py line 263 in features execution flow features results = state result for state in states features File app flows 2 sub flows features execution py line 263 in lt listcomp gt features results = state result for state in states features File opt pysetup venv lib python3 8 site packages prefect client schemas py line 107 in result return get state result self raise on failure=raise on failure fetch=fetch File opt pysetup venv lib python3 8 site packages prefect states py line 73 in get state result return get state result state raise on failure=raise on failure File opt pysetup venv lib python3 8 site packages prefect utilities asyncutils py line 226 in coroutine wrapper return run async from worker thread async fn args kwargs File opt pysetup venv lib python3 8 site packages prefect utilities asyncutils py line 177 in run async from worker thread return anyio from thread run call File opt pysetup venv lib python3 8 site packages anyio from thread py line 49 in run return asynclib run async from thread func args File opt pysetup venv lib python3 8 site packages anyio backends asyncio py line 970 in run async from thread return f result File usr lib python3 8 concurrent futures base py line 444 in result return self get result File usr lib python3 8 concurrent futures base py line 389 in get result raise self exception File opt pysetup venv lib python3 8 site packages prefect states py line 88 in get state result raise await get state exception state File opt pysetup venv lib python3 8 site packages prefect dask task runners py line 269 in wait return await future result timeout=timeout File opt pysetup venv lib python3 8 site packages distributed client py line 289 in result raise exc with traceback tb File opt pysetup venv lib python3 8 site packages prefect engine py line 1307 in begin task run state = await orchestrate task run File opt pysetup venv lib python3 8 site packages prefect engine py line 1382 in orchestrate task run resolved parameters = await resolve inputs parameters File opt pysetup venv lib python3 8 site packages prefect engine py line 1672 in resolve inputs return await run sync in worker thread File opt pysetup venv lib python3 8 site packages prefect utilities asyncutils py line 91 in run sync in worker thread return await anyio to thread run sync File opt pysetup venv lib python3 8 site packages anyio to thread py line 31 in run sync return await get asynclib run sync in worker thread File opt pysetup venv lib python3 8 site packages anyio backends asyncio py line 937 in run sync in worker thread return await future File opt pysetup venv lib python3 8 site packages anyio backends asyncio py line 867 in run result = context run func args File opt pysetup venv lib python3 8 site packages prefect utilities collections py line 285 in visit collection items = visit nested k visit nested v for k v in expr items File opt pysetup venv lib python3 8 site packages prefect utilities collections py line 285 in lt listcomp gt items = visit nested k visit nested v for k v in expr items File opt pysetup venv lib python3 8 site packages prefect utilities collections py line 251 in visit nested return visit collection File opt pysetup venv lib python3 8 site packages prefect utilities collections py line 280 in visit collection items = visit nested o for o in expr File opt pysetup venv lib python3 8 site packages prefect utilities collections py line 280 in lt listcomp gt items = visit nested o for o in expr File opt pysetup venv lib python3 8 site packages prefect utilities collections py line 251 in visit nested return visit collection File opt pysetup venv lib python3 8 site packages prefect utilities collections py line 259 in visit collection result = visit fn expr File opt pysetup venv lib python3 8 site packages prefect engine py line 1670 in resolve input return state result raise on failure=False fetch=True if return data else None File opt pysetup venv lib python3 8 site packages prefect client schemas py line 107 in result return get state result self raise on failure=raise on failure fetch=fetch File opt pysetup venv lib python3 8 site packages prefect states py line 73 in get state result return get state result state raise on failure=raise on failure File opt pysetup venv lib python3 8 site packages prefect utilities asyncutils py line 226 in coroutine wrapper return run async from worker thread async fn args kwargs File opt pysetup venv lib python3 8 site packages prefect utilities asyncutils py line 177 in run async from worker thread return anyio from thread run call File opt pysetup venv lib python3 8 site packages anyio from thread py line 49 in run return asynclib run async from thread func args File opt pysetup venv lib python3 8 site packages anyio backends asyncio py line 970 in run async from thread return f result File usr lib python3 8 concurrent futures base py line 444 in result return self get result File usr lib python3 8 concurrent futures base py line 389 in get result raise self exception File opt pysetup venv lib python3 8 site packages prefect states py line 100 in get state result raise MissingResult prefect exceptions MissingResult State data is missing Typically this occurs when result persistence is disabled and the state has been retrieved from the API ```

Aleksandr Liadov · Answer

With debug level I see a warning msg just before this crash ```Task run 32dc1400 a878 4691 8ddf ca2efd07bd4a received abort during orchestration This run cannot transition to the RUNNING state from the RUNNING state Task run is in RUNNING state ```