Hi I have a flow that runs a databricks job once it has fini

Question

Hi I have a flow that runs a databricks job once it has finished runs a shell command by calling `shell run command` task When this task is called I have the following error ```Encountered exception during execution Traceback most recent call last File home sgonzalez venv lib python3 7 site packages prefect engine py line 669 in orchestrate flow run result = await flow call aresult File home sgonzalez venv lib python3 7 site packages prefect internal concurrency calls py line 181 in aresult return await asyncio wrap future self future File home sgonzalez venv lib python3 7 site packages prefect internal concurrency calls py line 194 in run sync result = self fn self args self kwargs File flows flows landbaron py line 149 in generate lb sites flow ps details timestamp = shell run command command=get ps details timestamp command export version File home sgonzalez venv lib python3 7 site packages prefect tasks py line 491 in call mapped=False File home sgonzalez venv lib python3 7 site packages prefect engine py line 972 in enter task run engine return from sync wait for call in loop thread begin run File home sgonzalez venv lib python3 7 site packages prefect internal concurrency api py line 137 in wait for call in loop thread return call result File home sgonzalez venv lib python3 7 site packages prefect internal concurrency calls py line 173 in result return self future result timeout=timeout File usr lib python3 7 concurrent futures base py line 428 in result return self get result File usr lib python3 7 concurrent futures base py line 384 in get result raise self exception File home sgonzalez venv lib python3 7 site packages prefect internal concurrency calls py line 218 in run async result = await coro File home sgonzalez venv lib python3 7 site packages prefect engine py line 1137 in get task call return value return await future result File home sgonzalez venv lib python3 7 site packages prefect futures py line 241 in result return await final state result raise on failure=raise on failure fetch=True File home sgonzalez venv lib python3 7 site packages prefect states py line 91 in get state result raise await get state exception state File home sgonzalez venv lib python3 7 site packages prefect engine py line 1551 in orchestrate task run result = await call aresult File home sgonzalez venv lib python3 7 site packages prefect internal concurrency calls py line 181 in aresult return await asyncio wrap future self future File home sgonzalez venv lib python3 7 site packages prefect internal concurrency calls py line 218 in run async result = await coro File home sgonzalez venv lib python3 7 site packages prefect shell commands py line 98 in shell run command shell command env=current env cwd=cwd File home sgonzalez venv lib python3 7 site packages anyio core subprocesses py line 135 in open process start new session=start new session File home sgonzalez venv lib python3 7 site packages anyio backends asyncio py line 1112 in open process start new session=start new session File usr lib python3 7 asyncio subprocess py line 217 in create subprocess exec stderr=stderr kwds File usr lib python3 7 asyncio base events py line 1544 in subprocess exec bufsize kwargs File usr lib python3 7 asyncio unix events py line 193 in make subprocess transport self child watcher callback transp File usr lib python3 7 asyncio unix events py line 941 in add child handler Cannot add child handler RuntimeError Cannot add child handler the child watcher does not have a loop attached```

Santiago Gonzalez · Answer

Here there is an example of the code ``` flow def flow jar downloaded = jar uploaded to databricks = jar uploaded to job = job state = jobs runs wait for completion if job state get result state == SUCCESS result = shell run command command= aws s3 ls <s3 my bucket > | awk gsub $2 print $$2 | tail n 1 ```

David Anderson · Answer

Did you discover a solution here Running into a similar issue

Santiago Gonzalez · Answer

Not yet

Santiago Gonzalez · Answer

I found a solution by doing ```from prefect shell import ShellOperation from prefect import flow get run logger flow def flow result list = ShellOperation commands= something run get run logger info f Result result ```