Hey folks - hopefully an easy question, just can't see it directly outlined anywhere. If I have a Deployment with default values in terms of how the Flow should be executed, does this mean that the execution will happen on the Agent?

Hey, I am using run_deployment to run multiple child flows from a parent flow. I want the parent flow to NOT wait a results of the child flows. Is this possible?

Hello, I am currently trying to set a prefect orion server in a docker on an EC2, however this error appears on the UI

Can't connect to Orion API at <http://0.0.0.0:80/api>. Check that it's accessible from your machine.

Can't find any help on internet besides doing

prefect config set PREFECT_API_URL=<http://0.0.0.0:80/api>

Any ideas ?

I have changed some things in my infrastructure block and now my flow runs crash with a 403 error:

Crash detected! Execution was interrupted by an unexpected exception: httpx.HTTPStatusError: Client error '403 Forbidden' for url '<https://api.prefect.cloud/api/accounts/uuid/workspaces/uuid/block_types/a8b20987-a71e-4b43-9350-53a9e0d7d467>'
For more information check: <https://httpstatuses.com/403>

uuid contains my respective identifiers. I am a bit confused, because I cant find any block with the id

a8b20987-a71e-4b43-9350-53a9e0d7d467

. Which is apparently what it want to access. Any tips?

Hello guys, I have a problem to connect to my existing dask cluster

my_flow.with_options(
        task_runner=DaskTaskRunner(
            address="<tls://10.4.83.2:8786>"
        )

Log:

prefect.task_runner.dask - Connecting to an existing Dask cluster at <tls://10.4.83.2:8786>
17:20:30.497 | ERROR   | Flow run 'jolly-griffin' - Crash detected! Execution was interrupted by an unexpected exception: TypeError: TLS expects a `ssl_context` argument of type ssl.SSLContext (perhaps check your TLS configuration?) Instead got None

What do I wrong?

In Prefect Live at 3PM Eastern today on Twitch and YouTube, @Ryan Peden, the senior developer experience at Prefect, will talk about how to use cloud events to trigger Prefect automations. Add this event to your calendar so you don’t miss it.

Did anyone have this problem where the python client hangs on trying to set up deployment?

deployment = Deployment.build_from_flow(
    flow=load_data_from_minio,
    name="load_data_from_minio",
    work_queue_name="default",
    schedule=schedule,
    storage=storage_block,
    infrastructure=infra_block,
)

if __name__ == "__main__":
    logging.basicConfig(level=logging.DEBUG)
    deployment.apply()

Running this code just seems to hang forever. No debug logs either. Full code in thread

Hi there, I wanted to check my understanding of feature availability in Prefect Cloud 2.0. Is it possible to send, for specific flow state changes, custom Slack notifications? Ideally using the Slack block kit rather than plain text. Thanks!

it's because the path is a WindowsPath, which has

\

instead of

/

.

Hi! I’ve raised this with our UI team and we are investigating.

Hi. I'm on Prefect 1. What is the simplest way to set a task to run as the terminal task of a flow? One could add requisite

upstream_tasks

but that's laborious when we want the behavior to be independent of the upstream, as long as it is serially the final task execution.

Hi there! I’m looking at transitioning to Prefect 2.0 and trying to wrap my head around some of the new stuff. In my existing workflow, I construct a flow programmatically by walking a set of yaml files. This has the effect of needing the

add_task

method from the

flow

class. I don’t think the new API has this. Is there a way to iteratively add tasks to a flow?

hi everyone! Probably this is straightforward, I'm trying to define a waiter using prefect_aws.client_waiter but I'm getting: Missing required parameter in input: "jobs" Any help would be great!! Traceback in the thread.

Hello, How can I delete a single run of a flow from the history in prefect 1.4 ? Thanks in advance

Hi Torstain, You would need to add the

.submit()

function to call the async task. According to https://docs.prefect.io/tutorials/execution/#asynchronous-execution

Hello , I am trying to set up a prefect Orion server. I am having trouble creating a work queue. I had the error :

Error occured when trying to create new work queue

in a 405 response for a request to

<http://xx.xx.xx.xx:4200/xx.xx.xx.xx:4200/api/work_queues/>

We use this Dockerfile to run the server:

FROM python:3.9.16

RUN pip install prefect prefect[aws]
RUN prefect config set PREFECT_API_URL=http:/xx.xx.xx.xx:4200/api
CMD ["prefect", "orion", "start", "--host", "0.0.0.0"]

Thanks a lot for your help !

Hello, Would it be possible to read all files in a s3 sub-folder ?

Hi folks - I've just written a fairly long blog post introducing how to use Prefect with a real-world example (part of a series I'm creating). Would anybody that's familiar with Prefect do me a solid and proof-read it for me so I can make sure everything I've said is factual? I would be forever in your debt...

https://source.coveo.com/2023/01/04/creating-custom-sentry-block-prefect-2/ Here's my latest blog post on how to integrate Sentry with Prefect 2 using a custom block. Enjoy

Hi, With result persistence on, is it possible to trigger a task-rerun if the persisted result got deleted or corrupted? I am thinking about a case where the cache-key for the orion-DB is available, but the result can't be retrieved from local storage. In such a case I would like to invalidate the cache-key and trigger a new task-run to obtain the missing/corrupted result.

Hi all!

Hi all! Does anyone know how to get the Prefect CLI integrated with shell to allow for autocomplete?

Prefect 1.0 If have a "flow of flows", which calls

wait_for_flow_run

several times. I want this parent flow's success to depend on the success of all child flows. I've tried setting

upstream_tasks

to the result of

wait_for_flow_run

, but I realize that that's a

FlowRunView

object, not a

Task

. From the child flow, I can

get_tasks

, and set

upstream_tasks

to that. But I have some tasks I allow to fail in the child flows (they are not reference tasks of the child flow.) What I'd really like to do is to be able to reference

<child_flow>.state

, and set the parent flow's reference tasks to be expecting a

<Success: "All reference tasks succeeded.">

Is there a way of going about this?

I opened a thread here: https://discourse.prefect.io/t/prefect-2-7-5-2-7-6-flow-stuck-at-pending-forever/2149

Prefect 2.0.

Hey team! I am new to prefect and I using: • EC2 (ubuntu) • S3 storage block • I am build a flow that takes data from mixpanel and dumps into an s3 bucket. I get the following error (trace in thread)

Flow could not be retrieved from deployment.

from boto3 when I try and run the deployment into the ec2 instance. I can deploy to s3 locally and connect to bucket from the ec2 using the AWS cli. Please can anyone help me debug this?

Prefect 2.0 Does Prefect 2.0 support artifacts like 1.0 does? I want to attach some text or a link the a flow as a result. Is there a way to do this?

Anyone able to assist me one that:

Anyone able to assist me on this: after I updated to 2.7.6, all my scheduled flow is not able to run by the local agent.....they will show as Pending forever. I've posted my issue here as well: https://discourse.prefect.io/t/prefect-2-7-5-2-7-6-flow-stuck-at-pending-forever/2149