JK
06/30/2022, 9:11 PMKeyError: 'xxx'
Emil Ordoñez
06/30/2022, 10:04 PMyu zeng
07/01/2022, 3:32 AMOliver Mannion
07/01/2022, 8:02 AMCamilo Fernandez
07/01/2022, 8:56 AMIuliia Volkova
07/01/2022, 12:47 PMCarlos Cueto
07/01/2022, 1:28 PMPrefectSecret
explicitly but make use of secrets in other ways, such as Git
storage git_clone_url_secret_name=<secret_key>
.
The error is the following:
ClientError([{'path': ['secret_value'], 'message': 'An unknown error occurred.', 'extensions': {'code': 'INTERNAL_SERVER_ERROR'}}])
The error is very vague and it's very difficult to understand what the error is exactly. Any help is appreciated, this is affecting our production workflows that sometimes take hours to run.Sergey Goncharov
07/01/2022, 2:41 PMTim Enders
07/01/2022, 2:59 PMGCSResult
for my Task results. Does anybody know if there is a way to catch exceptions with it? We are seeing occasional failures on the GCS side and I don't want my flows failing because of it.Wieger Opmeer
07/01/2022, 4:40 PMhaven
07/01/2022, 4:46 PMClusterNotFound
but haven't gotten anywhere. i'd immensely appreciate it if anyone would have any insights! details in threadhaven
07/02/2022, 6:34 AMFaheem Khan
07/02/2022, 9:50 AMjars
07/03/2022, 6:16 AMWilliam Jamir
07/03/2022, 7:46 AMTask A
to do an upload and Task B
to monitor if everything went fine after the upload from Task A.
I noticed that using LocalDaskExecutor, only 10 tasks are processed at a time
It’s possible to run more than 10 mapped tasks in parallel?
Using LocalDaskExecutor with Prefect 1.2.2Isara Ovin
07/03/2022, 2:53 PMDenis Sh
07/03/2022, 8:56 PMDenis Sh
07/03/2022, 8:59 PMRajvir Jhawar
07/03/2022, 11:36 PMFaheem Khan
07/03/2022, 11:40 PMShivam Bhatia
07/04/2022, 5:24 AMkomal azram
07/04/2022, 6:21 AMBlack Spy
07/04/2022, 7:37 AMTom Matthews
07/04/2022, 9:16 AMthreads
scheduler? 🙏Michele Rossi
07/04/2022, 9:33 AMJoshua Greenhalgh
07/04/2022, 9:36 AMRobin Weiß
07/04/2022, 1:20 PM...
File "/usr/local/lib/python3.9/site-packages/prefect/client.py", line 834, in read_work_queue_by_name
...
httpx.ReadTimeout
An exception occurred.
• The agent gives these weird log messages:
MarkLateRuns took 26.306307 seconds to run, which is longer than its loop interval of 5.0 seconds.
FlowRunNotifications took 30.444981 seconds to run, which is longer than its loop interval of 4 seconds.
MarkLateRuns took 30.619028 seconds to run, which is longer than its loop interval of 5.0 seconds.
My guess is that something is really slowing the container down so that it runs into connection timeout issues as it doesn’t reply in time. Does anyone have any idea where to look further? The error message unfortunately gives me zero insights on the matter 😞
Thanks!Rajvir Jhawar
07/04/2022, 1:29 PMSurya
07/04/2022, 4:01 PMShivam Bhatia
07/05/2022, 5:42 AM$ # start python REPL with native await functionality
$ python -m asyncio
>>> from prefect.client import get_client
>>> async with get_client() as client:
... response = await client.hello()
... print(response.json())
👋
and I got this error:
Traceback (most recent call last):
File "/usr/lib/python3.9/concurrent/futures/_base.py", line 440, in result
return self.__get_result()
File "/usr/lib/python3.9/concurrent/futures/_base.py", line 389, in __get_result
raise self._exception
File "<console>", line 1, in <module>
File "/home/shivam/.local/lib/python3.9/site-packages/prefect/client.py", line 111, in get_client
ctx = prefect.context.get_settings_context()
File "/home/shivam/.local/lib/python3.9/site-packages/prefect/context.py", line 272, in get_settings_context
raise MissingContextError("No settings context found.")
prefect.exceptions.MissingContextError: No settings context found.
Am I missing something in the setup?