rectalogic
07/21/2022, 3:03 PM__file__
is not defined when prefect cloud runs the flow. Any idea what the issue is?Ellie Redding
07/21/2022, 3:19 PMsnowflake_query
and snowflake_multiquery
are their own tasks, so I can’t use them as part of a different task? Which means that my flow looks like this:
do_some_stuff()
for table_name in tables:
queries = build_queries(table)
snowflake_multiquery(queries)
These tasks are all running sequentially, but there are a lot of tables so I’d like the snowflake_multiquery
tasks for each table to run concurrently. How can I make that happen?Ellie Redding
07/21/2022, 3:23 PMsnowflake_multiquery
was throwing Object of type SecretStr is not JSON serializable
errors from this line of code in the connector, where it dumps the request body, including connection auth info, into the request. I got around this for now by changing the password here from type SecretStr
to str
, but that’s obviously not a great solution 😅 Has anyone else run into this issue?Kha Nguyen
07/21/2022, 3:25 PMJai P
07/21/2022, 3:48 PM2.0b10
) was released yesterday, but don't see associated release notes. was this just a minor bug fix?Yupei Chen
07/21/2022, 4:01 PMTim Enders
07/21/2022, 5:32 PMJai P
07/21/2022, 6:08 PMBilly McMonagle
07/21/2022, 6:15 PMChristian Nuss
07/21/2022, 6:22 PM@task
that across all concurrent flows is a Singleton (e.g only one of that task can run at a time)?Jason
07/21/2022, 6:34 PMFailed to load and execute flow run: ClientError([{'path': ['secret_value'], 'message': 'An unknown error occurred.', 'extensions': {'code': 'INTERNAL_SERVER_ERROR'}}])
Matt Alhonte
07/21/2022, 6:59 PMDaskExecutor
and/or ECSRun
?Chu
07/21/2022, 7:11 PMdatamongus
07/21/2022, 7:37 PMYupei Chen
07/21/2022, 7:53 PMprefect work-queue ls
I get below:
Response: {'detail': 'Request specified API version 0.6.0 but this server only supports version 0.7.0 and below.'}
For more information check: <https://httpstatuses.com/400>
An exception occurred.
Salim Doost
07/21/2022, 9:28 PMalways_run
trigger and skip_on_upstream_skip=False
, whether any of the upstream-tasks failed or were skipped? I need this information in the task-run method.Xavier Babu
07/21/2022, 9:47 PMShaoyi Zhang
07/21/2022, 10:29 PMJeff Hale
07/21/2022, 11:37 PMpip install prefect==1.2.4
.Rahul Kadam
07/22/2022, 3:53 AMbin zhang
07/22/2022, 3:56 AMdavzucky
07/22/2022, 6:01 AMLucien Fregosi
07/22/2022, 7:42 AMAndreas Nigg
07/22/2022, 9:36 AM/usr/local/lib/python3.9/site-packages/prefect/context.py:461: UserWarning: Failed to create the Prefect home directory at /.prefect
with SettingsContext(profile=profile, settings=new_settings) as ctx:
While Agent still starts up and picks up flow-runs, I get the following exception during flow-run
File "/usr/local/lib/python3.9/pathlib.py", line 1323, in mkdir
self._accessor.mkdir(self, mode)
FileNotFoundError: [Errno 2] No such file or directory: '/.prefect/storage'
I guess this has something to do with removing storage/default storage in the latest release? I configured my deployment with a RemoteFileSystem - Packager - not sure why prefect still needs to write something locally?
Find my flow + deployment in the Thread.Abin Joseph
07/22/2022, 9:57 AMCarlos Paiva
07/22/2022, 11:14 AMVadym Dytyniak
07/22/2022, 12:10 PMBenjamin.bgx
07/22/2022, 12:24 PMEd Burroughes
07/22/2022, 12:33 PMBritt Evans
07/22/2022, 2:01 PManyio.BrokenResourceError
and httpcore.ReadError
when the agent is using the orion client. Has anyone else had similar issues?Britt Evans
07/22/2022, 2:01 PManyio.BrokenResourceError
and httpcore.ReadError
when the agent is using the orion client. Has anyone else had similar issues?Kevin Kho
07/22/2022, 2:38 PMBritt Evans
07/22/2022, 2:39 PMKevin Kho
07/22/2022, 2:42 PMBritt Evans
07/22/2022, 2:47 PMKevin Kho
07/22/2022, 2:48 PMBritt Evans
07/22/2022, 2:50 PM