Hi there, I noticed that the schedule option has disappeared from the UI Deployment page. After Friday's updates, flows do not run on schedule. Is it a bug, or you move this option to a different place? The schedule will be deprecated in Sep 2024. Also, how can we be aware of the changes you make in advance? Thanks

I don’t see task

state_handlers

functionality in Orion/Prefect2.0. Is is on the roadmap? (or I’m I missing something..) thanks

@Marvin Is it possible to manually rerun tasks via the prefect UI, How would I do this

I'm curious if there is a way to use the

prefect deploy

CLI command non-interactively? I've defined deployments in

./prefect.yaml

and would like the deployments to be created without answering these questions interactively, e.g. in a continuous deployment setting: •

Would you like to build a custom Docker image for this deployment? [y/n] (n):

•

Would you like to save configuration for this deployment for faster deployments in the future? [y/n]:

Hi all, I'm overhauling our current Prefect 2.19.1 to Prefect 3.1.0. Because our codebase dynamically generates a lot of deployments we use Prefect Python and not Prefect YAML to manage everything. Surprisingly the Python code has really stayed mostly the same between versions, which is great. Unsurprisingly some of our side scripts we use to manage the Cloud are now broken. One in particular we use to clear backlogs of Late runs is giving me fits. This code used to work

import asyncio

from prefect.states import State
from prefect.client import get_client

MAX_RUNS_TO_DELETE = 5000
PREFECT_OFFSET_MAX = 200


async def remove_all_flows():
    client = get_client()
    for i in range(0, MAX_RUNS_TO_DELETE, PREFECT_OFFSET_MAX):
        flow_runs = await client.read_flow_runs(offset=i)
        for flow_run in flow_runs:
            if flow_run.state_name == "Late":
                flow_id = flow_run.id
                print("deleting", flow_id)
                await client.set_flow_run_state(flow_run_id=flow_id, state=State(type="CANCELLED"))


asyncio.run(remove_all_flows())

But now returns an error

pydantic.errors.PydanticUserError: `StateCreate` is not fully defined; you should define all referenced types, then call `StateCreate.model_rebuild()`.

No amount of defining State parameters (or passing directly a StateCreate object) fixes the issue. I'm increasingly convinced the old code is now a dead end. Could the Prefect team advise on what the idiomatic way to cancel a Late flow run would be under Prefect 3.1+?

RuntimeError: Timed out while attempting to connect to ephemeral Prefect API server.

Is this a known issue? We wrap controlflow runs via a retriable mechanism, so it eventually completed. But is this potentially something that is on our end?

Hi, Having some problems using getting around CORS issues with Prefect V2.0 accessible to another host on the lan while running in a docker container. Details in thread per @Kevin Kho

Hey guys any working example of how to upload csv files from local machine to S3 using awswrangler? Of course prefect task

Hey everyone! Is there an easy way to delay the execution of a task. Im sending POST calls with a task but then I need to wait 30 sec because parsing the logs for data validation. is there an easy way to do this

im hitting the following http timeout error consistently with my flows. thought i had it solved, but it showed back up this morning and nothing is completing. when searching through slack / github / the forum, it seems a few others are encountering this as well though no one has posted a solution. traceback in the following post.