Hi everyone, I am wondering if any of you know if there is a way within the prefect UI to send an email alert to people if /when a flow fails to run properly. thank you

Hi all 👋 Just a quick question, haven’t explored much yet - curious whether it would be possible to sync the Calendar from Prefect Server with GCal 🤔 I assume this data would be available in one of the Postgres tables when tasks are scheduled?

Hey - I am registering a flow like with these arguments/parameters => 🧵

Hi All, Incase if anyone is using the dask gateway in combination with prefect. Any idea when is the end of support date for dask-gateway 0.9.0 version

Hi, are there any SSO Options for Prefect Cloud?

Hi, is there any more detailed information available on running long-running flows in Prefect 2.0? Or are they exactly the same as regular ones and I can simply do

while True:

if x:

my_task()

And deploy & manage as usual?

Small typo in Blog: https://www.prefect.io/guide/blog/getting-started-prefect-2/

Should prefect clean up the jobs created in k8's - created a scheduled job but the jobs get left in an 'Active' state even thought he pod is completed

Hi community~! I have a question about PermissionError. I am trying to create a virtual environment in a separately created account in Linux and run prefect flow there. In my flow, there is a task that needs to go to a specific folder and save the task's result as a csv file, and a permissionError occurs in this process. Maybe I think it's normal. If i want to create, modify, or delete data in that folder, i must enter 'sudo' and something, but flow does not include that task(sudo ~~). How can i solve this problem?

Can you delete a storage?

prefect storage delete my-s3-storage

seeing this error: raise exceptions.from_http_status(response.status_code, message, response=response) google.api_core.exceptions.BadRequest: 400 PUT https://storage.googleapis.com/upload/storage/v1/b/uat-pvr-data-prefect-gcs/o?uploadType=resumable&amp;upload_id=ADPycdtTsfUe4rNUbqxBn59GhS-wvYByENDQ_Sx0uT8u1ekPASue0EnpTYTZws2ULMcX3_rkBzdvnxf9ySecwbAhZzOK205Y4YOT: Invalid request. There were 22287 byte(s) in the request body. There should have been 22839 byte(s) (starting at offset 0 and ending at offset 22838) according to the Content-Range header.: ('Request failed with status code', 400, 'Expected one of', <HTTPStatus.OK: 200>, <HTTPStatus.PERMANENT_REDIRECT: 308>) when trying to use script as storage with GCS

any ideas?

have both key and local storage path

local script path

Can you use self-managed S3 server as prefect storage?

Bucket name must match the regex "^[a-zA-Z0-9.\-_]{1,255}$" or be an ARN matching the regex "^arn:(aws).*:(s3|s3-object-lambda):[a-z\-0-9]*:[0-9]{12}:accesspoint[/:][a-zA-Z0-9\-.]{1,63}$|^arn:(aws).*:s3-outposts:[a-z\-0-9]+:[0-9]{12}:outpost[/:][a-zA-Z0-9\-]{1,63}[/:]accesspoint[/:][a-zA-Z0-9\-]{1,63}$"

Hi, There are should be doc and example about how to trigger a flow run on Prefect Cloud with HTTP Request. This is very important to me. Not just a https://orion-docs.prefect.io/api-ref/rest-api/#prefect-rest-api-reference

The HTTP API doesn’t seem working with Prefect Cloud 2.0 (https://beta.prefect.io/api/hello) it work fine on Local Prefect Server (http://localhost:4200/api/hello)

OK I get it

Seem like the Prefect 2.0 REST API is mostly for Orion Client? I have no idea how to use them. Seem like I could use AWS API Gateway + Lambda(Python) + Prefect to make a API endpoint, then I can send a http request to that API endpoint -> AWS API Gateway -> Lambda -> Prefect. Seem a bit over complicated

Hi, I'm trying too create a Prefect Docker Agent in a container passing the docker.sock to do some DinD Is there a way to mount volumes to the children spawned containers ? I tried to mount a volume when starting with --volume option but doesn't seems to work

Hi all 👋 what happens if I register a flow with Github storage, where the storage points to a ref that's different from the ref I'm registering? In other words: 1. I have a

flow.py

flow with

storage=Github(..., ref='main')

2. I checkout a new branch

my-feature-branch

, and make some edits to the flow 3. I re-register the flow from this new branch, but still leave

ref='main'

...so when the Flow is run, the version registered to the Prefect backend is from

my-feature-branch

, but the agent running the flow will have pulled down the version from the

main

branch? Thanks in advance!

Hi can someone help me understand why these flows are failing trying to access cloud secrets - just had 4 in a row; • https://cloud.prefect.io/dat-eng/flow-run/304e4a56-47c4-43e7-a0ff-56712b35ac61 • https://cloud.prefect.io/dat-eng/flow-run/57204063-5800-402e-b4e2-6cc3d6cefca2

prefect.exceptions.ClientError: [{'path': ['secret_value'], 'message': 'An unknown error occurred.', 'extensions': {'code': 'INTERNAL_SERVER_ERROR'}}]

Trying to use DbtShellTask on windows but get the following error:

[2022-06-27 17:16:15+0200] ERROR - prefect.DbtShellTask | /bin/bash: C:UsersUSERAD~1AppDataLocalTempprefect-6rbqzzlx: No such file or directory

This line in prefect.tasks.shell.py generates a strange path:

with tempfile.NamedTemporaryFile(prefix="prefect-") as tmp:

Hi all! I am having this error . Any suggestions? Traceback (most recent call last): File "/home/centos/.local/lib/python3.8/site-packages/prefect/agent/agent.py", line 328, in _submit_deploy_flow_run_jobs flow_runs = self._get_flow_run_metadata(flow_run_ids) File "/home/centos/.local/lib/python3.8/site-packages/prefect/agent/agent.py", line 688, in _get_flow_run_metadata result = self.client.graphql(query) File "/home/centos/.local/lib/python3.8/site-packages/prefect/client/client.py", line 464, in graphql raise ClientError(result["errors"]) prefect.exceptions.ClientError: [{'path': ['flow_run', 0, 'id'], 'message': 'Cannot return null for non-nullable field flow_run.id.', 'extensions': {'code': 'INTERNAL_SERVER_ERROR'}}]

Hi! In prefect 2.0 I notice that if we pass

future

to another task, the task automatically receives the future result value as a variable which is the expected behavior. However this is not the case when we have a flow with subflows and we pass a prefect state from a flow run (that has a return value) to a flow downwards (where we should manually call `.result().result()`to extract the flows result's value) Is this the expected behavior? If yes this seems a little bit counter intuitive to me, where in the case of passing data from tasks Prefect automatically extracts the result value but not when this result is coming from a flow run

Moving this from another thread since it was unrelated to the original. I registered a new version of a flow this morning that started failing with

Failed to retrieve task state with error: ClientError([{'path': ['get_or_create_task_run_info'], 'message': 'Expected type UUID!, found ""; Could not parse UUID: ', 'extensions': {'code': 'INTERNAL_SERVER_ERROR', 'exception': {'message': 'Expected type UUID!, found ""; Could not parse UUID: ', 'locations': [{'line': 2, 'column': 101}], 'path': None}}}])

@Mason Menges Pointed me to https://discourse.prefect.io/t/how-to-fix-the-error-prefect-exceptions-clienterror-message-expected-type-uuid-found-could-not-parse-uuid/832 to assist. I ended up having to register the flow 3 times for it to start working. The first registration was the only time there were changes to the flow, I had to register an additional two times with zero changes to get the error to stop. Is there an issue related to this article or anything that can be done to dig into what exactly is going on?

is there a way to set KV store values in the config or with environment variables so that the KV doesn't need to be called? in other words, how can we do fully local execution if the KV store must call the cloud?

Hello prefect community, I am using "manual_only" trigger for the first time and I noticed that when I resume the flow, the variables computed downstream the manual task are not kept in memory. Is that the correct behaviour or am i doing something wrong?Should i take a look how to persistently cache these previous results (https://docs.prefect.io/core/advanced_tutorials/using-results.html) or there is a simpler solution? Thank you for your help!

Hello! I am attempting to set up DBTShellTask and having a problem with locating the dbt_project.yml file. It is located in the dbt/ directory that is cloned from my github repo. I do not see a variable I can use to change to dbt/. The profiles.yml is created in . so it is found without a problem.

dbt_project.yml file [ERROR not found]