Hello I run flows in dask cluster How it can be possible the

Question

Hello I run flows in dask cluster How it can be possible the flow state is `Completed` orion graph has `red parts` and all my subtasks `crashed` And in logs I see `crashed` Maybe it changes smth I submit with options every task and I add str uuid uuid4 8 before every task name error `Crash detected Execution was interrupted by an unexpected exception concurrent futures base CancelledError 2ae637b0currency symbol 26 99893272733d461fba8a3051f42a13a8 1`

Aleksandr Liadov · Answer

I have put logger level to debug and so the stack trace Crash details ```Traceback most recent call last File opt pysetup venv lib python3 8 site packages prefect engine py line 1689 in report task run crashes yield File opt pysetup venv lib python3 8 site packages prefect engine py line 1320 in begin task run connect error = await client api healthcheck File opt pysetup venv lib python3 8 site packages prefect client orion py line 235 in api healthcheck await self client get health File opt pysetup venv lib python3 8 site packages httpx client py line 1757 in get return await self request File opt pysetup venv lib python3 8 site packages httpx client py line 1533 in request return await self send request auth=auth follow redirects=follow redirects File opt pysetup venv lib python3 8 site packages prefect client base py line 229 in send response = await self send with retry File opt pysetup venv lib python3 8 site packages prefect client base py line 187 in send with retry response = await request File opt pysetup venv lib python3 8 site packages httpx client py line 1620 in send response = await self send handling auth File opt pysetup venv lib python3 8 site packages httpx client py line 1648 in send handling auth response = await self send handling redirects File opt pysetup venv lib python3 8 site packages httpx client py line 1685 in send handling redirects response = await self send single request request File opt pysetup venv lib python3 8 site packages httpx client py line 1722 in send single request response = await transport handle async request request File opt pysetup venv lib python3 8 site packages httpx transports default py line 353 in handle async request resp = await self pool handle async request req File opt pysetup venv lib python3 8 site packages httpcore async connection pool py line 253 in handle async request raise exc File opt pysetup venv lib python3 8 site packages httpcore async connection pool py line 237 in handle async request response = await connection handle async request request File opt pysetup venv lib python3 8 site packages httpcore async connection py line 63 in handle async request stream = await self connect request File opt pysetup venv lib python3 8 site packages httpcore async connection py line 111 in connect stream = await self network backend connect tcp kwargs File opt pysetup venv lib python3 8 site packages httpcore backends auto py line 29 in connect tcp return await self backend connect tcp File opt pysetup venv lib python3 8 site packages httpcore backends asyncio py line 111 in connect tcp stream anyio abc ByteStream = await anyio connect tcp File opt pysetup venv lib python3 8 site packages anyio core sockets py line 189 in connect tcp gai res = await getaddrinfo File opt pysetup venv lib python3 8 site packages anyio core sockets py line 496 in getaddrinfo gai res = await get asynclib getaddrinfo File opt pysetup venv lib python3 8 site packages anyio backends asyncio py line 1754 in getaddrinfo result = await get running loop getaddrinfo File usr lib python3 8 asyncio base events py line 825 in getaddrinfo return await self run in executor asyncio exceptions CancelledError``` < Ryan Peden> I have seen that you already worked for Dask problem maybe you can help me or I can give your more information