Hello all I m currently trying to run a code with a dask run

Question

Hello all I m currently trying to run a code with a dask runner I ve set up a dask scheduler and client and tried running with something like the following code for the flow I was just wondering if anyone was familiar with this error Thanks

Kevin Kho · Answer

Hi < Sang Young Noh> this is because your workers can t connect to the database See post for options When you get a chance could you move the flow and traceback to the thread to keep the main channel cleaner

Sang Young Noh · Answer

Sure I ll move it now

Sang Young Noh · Answer

```flow name = ng task runner = DaskTaskRunner address = localhost 8786 def ng daily polling MaxLate=datetime timedelta hours=12 Temporary function to replace the bottom NG daily polling function Args timezone str Timezone for scheduling Defaults to Europe London description str More detailed decription for the particular flow does Defaults to Lorem Ipsum Returns PH Raises Skipping Variables that need to be used later max late = datetime timedelta hours=12 now = datetime datetime now tz=pytz utc ctx FlowRunContext = get run context logger = get run logger INFO level log message ``` But when I look at the docker container for the dask I seem to be getting the following error ```dask worker 2 | Traceback most recent call last dask worker 2 | File usr local lib python3 8 site packages starlette middleware errors py line 162 in call dask worker 2 | await scope receive send dask worker 2 | File usr local lib python3 8 site packages starlette exceptions py line 93 in call dask worker 2 | raise exc dask worker 2 | File usr local lib python3 8 site packages starlette exceptions py line 82 in call dask worker 2 | await scope receive sender dask worker 2 | File usr local lib python3 8 site packages fastapi middleware asyncexitstack py line 21 in call dask worker 2 | raise e dask worker 2 | File usr local lib python3 8 site packages fastapi middleware asyncexitstack py line 18 in call dask worker 2 | await scope receive send dask worker 2 | File usr local lib python3 8 site packages starlette routing py line 670 in call dask worker 2 | await route handle scope receive send dask worker 2 | File usr local lib python3 8 site packages starlette routing py line 266 in handle dask worker 2 | await scope receive send dask worker 2 | File usr local lib python3 8 site packages starlette routing py line 65 in app dask worker 2 | response = await func request dask worker 2 | File usr local lib python3 8 site packages prefect orion utilities server py line 101 in handle response scoped depends dask worker 2 | response = await default handler request dask worker 2 | File usr local lib python3 8 site packages fastapi routing py line 227 in app dask worker 2 | raw response = await run endpoint function dask worker 2 | File usr local lib python3 8 site packages fastapi routing py line 160 in run endpoint function dask worker 2 | return await dependant call values dask worker 2 | File usr local lib python3 8 site packages prefect orion api task runs py line 188 in set task run state dask worker 2 | orchestration result = await models task runs set task run state dask worker 2 | File usr local lib python3 8 site packages prefect orion models task runs py line 282 in set task run state dask worker 2 | raise ValueError f Invalid task run task run id dask worker 2 | ValueError Invalid task run bfaccc7a e983 4780 be34 8af27802ebe4 dask worker 2 | 2022 05 26 13 42 28 502 distributed worker WARNING Compute Failed dask worker 2 | Key Extraction 227e78f8 0 bfaccc7ae9834780be348af27802ebe4 dask worker 2 | Function begin task run dask worker 2 | args dask worker 2 | kwargs task lt prefect tasks Task object at 0xffff9fd5beb0 gt task run TaskRun id=UUID bfaccc7a e983 4780 be34 8af27802ebe4 name= Extraction 227e78f8 0 flow run id=UUID b0643545 7761 41a6 8c1e 592b5a03da1c task key= 227e78f8a94bc7d03dbd490e701bda55 dynamic key= 0 cache key=None cache expiration=None task version=None empirical policy=TaskRunPolicy max retries=0 retry delay seconds=0 0 tags= state id=UUID db026d63 a619 4bb7 bb42 44caaf143993 task inputs= start end max retries retry delay state type=StateType PENDING run count=0 expected start time=datetime datetime 2022 5 26 13 42 28 268661 tzinfo=datetime timezone utc next scheduled start time=None start time=None end time=None total run time=datetime timedelta 0 estimated run time=datetime timedelta 0 estimated start time delta=datetime timedelta microseconds=20339 state=Pending message=None type=PENDING result=None task run id=bfaccc7a e983 4780 be34 8af27802 dask worker 2 | Exception ValueError Invalid task run bfaccc7a e983 4780 be34 8af27802ebe4 ```

Kevin Kho · Answer

Thank you

Sang Young Noh · Answer

Is there a crash course tutorial on this procedure Sorry again but any further pointers on this would be much apprecaited

Kevin Kho · Answer

For using Cloud 2 0 the docs are <https orion docs prefect io ui cloud |here> That will be the easiest and it s free for now and will have a generous free tier also

Sang Young Noh · Answer

Thank you I m sure once its out of beta we d be happy to sign up for prefect 2 cloud