I want to schedule two taks to run every using a local Agent. However afer a few these, the angent goes to unheathy and stops all the flows.
It appears the following error:
02:06:44.814 | INFO | Flow run ‘nickel-pug’ - Finished in state Completed(‘All states completed.’)
02:06:45.630 | INFO | prefect.infrastructure.process - Process ‘nickel-pug’ exited cleanly.
Traceback (most recent call last):
File “C:\Users\lisdataf01\Documents\Prefectv2\lib\site-packages\prefect\cli_utilities.py”, line 41, in wrapper
return fn(*args, **kwargs)
File “C:\Users\lisdataf01\Documents\Prefectv2\lib\site-packages\prefect\utilities\asyncutils.py”, line 260, in coroutine_wrapper
return call()
File “C:\Users\lisdataf01\Documents\Prefectv2\lib\site-packages\prefect_internal\concurrency\calls.py”, line 245, in call
return self.result()
File “C:\Users\lisdataf01\Documents\Prefectv2\lib\site-packages\prefect_internal\concurrency\calls.py”, line 173, in result
return self.future.result(timeout=timeout)
File “C:\Users\lisdataf01\AppData\Local\Programs\Python\Python310\lib\concurrent\futures_base.py”, line 451, in result
return self.__get_result()
File “C:\Users\lisdataf01\AppData\Local\Programs\Python\Python310\lib\concurrent\futures_base.py”, line 403, in __get_result
raise self._exception
File “C:\Users\lisdataf01\Documents\Prefectv2\lib\site-packages\prefect_internal\concurrency\calls.py”, line 218, in _run_async
result = await coro
File “C:\Users\lisdataf01\Documents\Prefectv2\lib\site-packages\prefect\cli\agent.py”, line 189, in start
async with anyio.create_task_group() as tg:
File “C:\Users\lisdataf01\Documents\Prefectv2\lib\site-packages\anyio_backends_asyncio.py”, line 662, in aexit
raise exceptions[0]
File “C:\Users\lisdataf01\Documents\Prefectv2\lib\site-packages\prefect\utilities\services.py”, line 46, in critical_service_loop
await workload()
File “C:\Users\lisdataf01\Documents\Prefectv2\lib\site-packages\prefect\agent.py”, line 194, in get_and_submit_flow_runs
responses = await self.client.get_scheduled_flow_runs_for_work_pool(
File “C:\Users\lisdataf01\Documents\Prefectv2\lib\site-packages\prefect\client\orchestration.py”, line 2282, in get_scheduled_flow_runs_for_work_pool
response = await self._client.post(
File “C:\Users\lisdataf01\Documents\Prefectv2\lib\site-packages\httpx_client.py”, line 1845, in post
return await self.request(
File “C:\Users\lisdataf01\Documents\Prefectv2\lib\site-packages\httpx_client.py”, line 1530, in request
return await self.send(request, auth=auth, follow_redirects=follow_redirects)
File “C:\Users\lisdataf01\Documents\Prefectv2\lib\site-packages\prefect\client\base.py”, line 278, in send
response.raise_for_status()
File “C:\Users\lisdataf01\Documents\Prefectv2\lib\site-packages\prefect\client\base.py”, line 135, in raise_for_status
raise PrefectHTTPStatusError.from_httpx_error(exc) from exc.cause
prefect.exceptions.PrefectHTTPStatusError: Client error ‘403 Forbidden’ for url ‘https://api.prefect.cloud/api/accounts/41145b96-f419-40c9-a50e-f9f268e083e8/workspaces/74133c51-e0ee-40bd-8386-f0bb9ab1be10/work_pools/incidencias/get_scheduled_flow_runs’
For more information check: 403 Forbidden - HTTP Status Code Glossary - WebFX
An exception occurred.
Beacse of that we have to run the agent again.
As wel it gets stucks whe a flow need to run…
Does someone know which is the problem?
i want the local agent workin 24/7
Thank you