I m having a task fail when running on an agent within a flo

Question

I m having a task fail when running on an agent within a flow The task takes the current working directory and uploads that as a string value into a string block Any idea why this could be This started when I updated to 2 4 1

John Kang · Answer

Error is 09 30 33 788 | ERROR | Task run Register Current Prefect flow run temporary directory 2e345798 0 Finished in state Failed Task run encountered an exception 09 30 33 788 | ERROR | Flow run nice cockatoo Encountered exception during execution Traceback most recent call last File C Users jkang1 conda envs Capacity venv lib site packages prefect engine py line 596 in orchestrate flow run result = await run sync flow call File C Users jkang1 conda envs Capacity venv lib site packages prefect utilities asyncutils py line 57 in run sync in worker thread return await thread run sync call cancellable=True File C Users jkang1 conda envs Capacity venv lib site packages anyio to thread py line 28 in run sync return await get asynclib run sync in worker thread func args cancellable=cancellable File C Users jkang1 conda envs Capacity venv lib site packages anyio backends asyncio py line 818 in run sync in worker thread return await future File C Users jkang1 conda envs Capacity venv lib site packages anyio backends asyncio py line 754 in run result = context run func args File main python files w wrapper update data py line 342 in wrapper data update function change previous temporary directory current working directory File C Users jkang1 conda envs Capacity venv lib site packages prefect tasks py line 295 in call return enter task run engine File C Users jkang1 conda envs Capacity venv lib site packages prefect engine py line 736 in enter task run engine return run async from worker thread begin run File C Users jkang1 conda envs Capacity venv lib site packages prefect utilities asyncutils py line 137 in run async from worker thread return anyio from thread run call File C Users jkang1 conda envs Capacity venv lib site packages anyio from thread py line 35 in run return asynclib run async from thread func args File C Users jkang1 conda envs Capacity venv lib site packages anyio backends asyncio py line 847 in run async from thread return f result File C Users jkang1 conda envs Capacity venv lib concurrent futures base py line 444 in result return self get result File C Users jkang1 conda envs Capacity venv lib concurrent futures base py line 389 in get result raise self exception File C Users jkang1 conda envs Capacity venv lib site packages prefect engine py line 874 in get task call return value return await future result File C Users jkang1 conda envs Capacity venv lib site packages prefect futures py line 237 in result return final state result raise on failure=raise on failure File C Users jkang1 conda envs Capacity venv lib site packages prefect orion schemas states py line 145 in result raise data File C Users jkang1 conda envs Capacity venv lib site packages prefect engine py line 1221 in orchestrate task run result = await run sync task fn args kwargs File C Users jkang1 conda envs Capacity venv lib site packages prefect utilities asyncutils py line 57 in run sync in worker thread return await thread run sync call cancellable=True File C Users jkang1 conda envs Capacity venv lib site packages anyio to thread py line 28 in run sync return await get asynclib run sync in worker thread func args cancellable=cancellable File C Users jkang1 conda envs Capacity venv lib site packages anyio backends asyncio py line 818 in run sync in worker thread return await future File C Users jkang1 conda envs Capacity venv lib site packages anyio backends asyncio py line 754 in run result = context run func args File C Users jkang1 AppData Local Temp tmpn0w8m9xiprefect main python files gcs register prefect temp folder py line 24 in change previous temporary directory change previous temporary directory block save File C Users jkang1 conda envs Capacity venv lib site packages prefect utilities asyncutils py line 208 in wrapper return run async from worker thread async fn args kwargs File C Users jkang1 conda envs Capacity venv lib site packages prefect utilities asyncutils py line 137 in run async from worker thread return anyio from thread run call File C Users jkang1 conda envs Capacity venv lib site packages anyio from thread py line 35 in run return asynclib run async from thread func args File C Users jkang1 conda envs Capacity venv lib site packages anyio backends asyncio py line 847 in run async from thread return f result File C Users jkang1 conda envs Capacity venv lib concurrent futures base py line 444 in result return self get result File C Users jkang1 conda envs Capacity venv lib concurrent futures base py line 389 in get result raise self exception File C Users jkang1 conda envs Capacity venv lib site packages prefect blocks core py line 813 in save document id = await self save name=name overwrite=overwrite client=client File C Users jkang1 conda envs Capacity venv lib site packages prefect client orion py line 80 in with injected client return await fn args kwargs File C Users jkang1 conda envs Capacity venv lib site packages prefect blocks core py line 761 in save await self register type and schema client=client File C Users jkang1 conda envs Capacity venv lib site packages prefect client orion py line 80 in with injected client return await fn args kwargs File C Users jkang1 conda envs Capacity venv lib site packages prefect blocks core py line 685 in register type and schema client = client or client from context NameError name client from context is not defined

John Kang · Answer

When I run this task separately outside of a flow and not in an agent it works fine

John Kang · Answer

``` task name= Register Current Prefect flow run temporary directory description= Registers the directory that is housing the current prefect flow run temporary directory retries=3 retry delay seconds=10 def change previous temporary directory working directory str gt None Change the temporary directory of the last prefect flow run change previous temporary directory block = String value=working directory change previous temporary directory block save name= previous prefect flow directory overwrite=True Print out the value of the temporary directory last temporary directory = String load previous prefect flow directory value print f Prefect last temporary directory last temporary directory ``` The code for the task is really simple Not sure what could be going on

alex · Answer

Hey < John Kang> This looks like it could be a bug Can you open an issue in GitHub so that we can investigate this further

John Kang · Answer

< alex> Sure thing Thanks for the heads up

alex · Answer

Hey < John Kang> we ve released version 2 4 2 of Prefect to fix this bug Let us know if you have any other issues

John Kang · Answer

< alex> Great Thanks so much for the quick response I ll install once my flow runs are complete