If someone from prefect is listening to this channel, in the future, I would be very happy to see the info above (scheduled maintenance) on status.prefect.io ; and also a link to status.prefect.io from prefect.io site - it took me too long to figure out what was happening.

This is an absolute joke. Scheduled maintenance brings down everything, outages brings down everything and this is happening WAY too often. It's like every second week we have to go in and cancel all our flows manually one by one as they just get stuck in a running or pending state.

@Janet Carson split thread 🧵

Hi! Could I get someone to take a quick look at github.com/conda-forge/prefect-feedstock/pull/454 to make the latest prefect version 3.8.0 available on Conda. Thanks!

Continuing the maintenance conversations -- how are folks handling maintenance windows? Do you shut down your deployments in advance or just log in afterwards and recover?

Hi there! I added a zombie flow detection automation

{
  "type": "event",
  "match": {
    "prefect.resource.id": "prefect.flow-run.*"
  },
  "match_related": {
    "prefect.resource.id": [
      "prefect.flow.5dec07f4-f468-4cdf-99a3-5016aa05c383",
      "prefect.flow.acdba04f-fc39-4e67-990b-b9ff25947e24",
      "prefect.flow.baebc35a-bcaf-47ab-9819-a80f873d88b5",
      "prefect.flow.400db30b-8136-48b0-93bf-f391bded4377",
      "prefect.flow.d0b6d613-82d4-42a4-b2c0-113b186d817b",
      "prefect.flow.ee31395e-3769-4db5-a72c-6fe6a0470e1a",
      "prefect.flow.50bc3efe-2c90-4d06-b82b-08db0faf1a8b",
      "prefect.flow.b992f437-56c4-4644-90a8-4ef6305993c4",
      "prefect.flow.293b63ca-651d-4e8a-b518-9c63d124bf5a"
    ],
    "prefect.resource.role": "flow"
  },
  "after": [
    "prefect.flow-run.heartbeat"
  ],
  "expect": [
    "prefect.flow-run.*"
  ],
  "for_each": [
    "prefect.resource.id"
  ],
  "posture": "Proactive",
  "threshold": 1,
  "within": 600
}

For some reason, a couple minutes after the flow run completes successfully, I can see the flow still triggers, which I would have not expected. I can see a

prefect.flow-run.Completed

event for one flow at 124950 EST and the automation still triggered at 125807 EST for that particular flow. What am I doing wrong? I feel like this is a Prefect Cloud bug 🤔

Hi everyone

@flow(log_prints=True)
async def load_wso_industry_codes(as_of_date: date | None = None) -> None:
    as_of_date = date.today() - timedelta(days=1) if as_of_date is None else as_of_date
    issuer_ids = get_issuer_ids(as_of_date)
    # print(f'done getting issuer id from db. Count: {len(issuer_ids)}')
    sem = asyncio.Semaphore(20) # avoid blasting WSO server, 20 is sufficiently fast
    async with httpx.AsyncClient(timeout=30) as client:
        token = await get_wso_token(client)
        client.headers['Authorization'] = f"Bearer {token}"

        issuers = await work(sem, client, issuer_ids, wait_for=[issuer_ids])

        print('saving industry codes')
        await save_industry_codes(as_of_date, issuers, wait_for=[issuers])

why my prefect dependency graph is showing a dependency arrow betwen save_industry_codes and get_issuer_ids? also I have to explicitly add

wait_for

for it to show the dependency arrows. It should automatically discover the dependency since I'm passing the result of a task to another one already...

Hi! I’m trying to upgrade to the Prefect Horizon Enterprise plan because I’d like to use a custom domain. I contacted sales@prefect.io, but the automated reply directed me to the contact form, and the form keeps flagging my submission as a test or fake request. Could someone from the Prefect team help me get in touch with sales or the right person for the upgrade? Thanks!

How do you guys monitor for file arrival to trigger a job in Prefect. Do you have long-running or frequently occuring deployments, or use external tools like crontab or systemd services with watchdog to trigger Prefect flows via API?

Hi, I’m having an issue provisioning a custom domain for my Horizon MCP server. The certificate validation keeps failing. Could someone from the Horizon team help me check this? I can share the domain and DNS configuration privately via DM.

Hi, Is there anyone who will work for our startup bussiness?

How are you guys handling the dev/prod workflow with Prefect Cloud and a single workspace? Right now we run most dev workflows locally and send the logs to Prefect Cloud but some of the stuff needs to run in dev but on the cloud (for access/resource reasons). We upload those deployments with proper tags and use a dedicated dev worker for it but I'm not sure if it's optimal or not.

I am going through a HITRUST r2 Certification and one evidence request is to show the Session Timeout Settings for Prefect. Is there a default config settings I can see in my portal? If yes, please point me in the ight direction to view. Thanks.

Hello Prefect+dbt users. Do you wrap PrefectDbtRunner in a method (possibly task) then using it so it's "reusable" or just call it wherever you need it since the boilerplate for using it is very low? What I mean is this image vs calling the runner directly. I'm tempted by calling it directly unless I need reusability across flows but I'm not quite sure yet.

Hello, I'm wondering whether or not's possible to automatically pop up a modal window when a user is watching a flow run in real-time in the UI and a task calls

pause_flow_run(wait_for_input=my_run_input)

?

Is something going on with automations on Prefect Cloud right now? We have a proactive automation that checks it some of our flow runs are running for >4h and it's triggering despite the associated flow runs being completed within 5 minutes. Our automation hasn't changed and I can clearly see the

prefect.flow-run.Completed

event.

{
  "type": "event",
  "posture": "Proactive",
  "match": {
    "prefect.resource.id": "prefect.flow-run.*"
  },
  "matchRelated": [
    {
      "prefect.resource.id": "prefect.tag.dataanalyticsengineering",
      "prefect.resource.role": "tag"
    },
    {
      "prefect.resource.id": "prefect.tag.alerting_on",
      "prefect.resource.role": "tag"
    }
  ],
  "forEach": [
    "prefect.resource.id"
  ],
  "after": [
    "prefect.flow-run.Running"
  ],
  "expect": [
    "prefect.flow-run.Failed",
    "prefect.flow-run.Cancelled",
    "prefect.flow-run.Completed",
    "prefect.flow-run.TimedOut",
    "prefect.flow-run.Crashed"
  ],
  "threshold": 1,
  "within": 14400
}

Hi all, I have a question about Prefect process workers on Windows. I'm evaluating Prefect for orchestrating Python workloads that run on a fleet of Windows VMs. Some workloads need to run inside an actual interactive Windows user session, because they need access to desktop-bound applications and user-profile-specific resources. Prefect process workers can run well on Windows, but one operational gap for us is the lifecycle of the Windows session itself: ensuring that a configured user is logged in, the session is available/unlocked, the process starts in that user’s interactive session rather than a service/session-0 context, and the session can be recovered after reboot or failure. Is there any plan or existing recommended pattern for a “Windows login/session agent” type of capability in Prefect, or is this considered outside Prefect’s scope and something users should build/manage separately? I realize this may be outside the normal workflow orchestration model, but I would be interested to hear if others are solving similar Windows VM worker/session-management problems with Prefect.

@Marvin - In self hosted HA setup with prefect - 3.7.8 version. observed an issue where redis went down for a while and came back online after an hour. But Schedule flows didn't worked until the server and background services are restarted.

@Marvin - In self hosted prefect 3.7.8, cancel proactive automation event is not triggered

@Marvin - In self hosted Prefect workpool, Is there an option where out of 4 worker, make 3 workers to poll from specific queues and other worker from default queue?

@Marvin In Prefect 3.8.2, the V2 UI currently doesn’t list the tags in the Deployments tab when I click into the tags field. Has this already been reported, or is there a fix for it yet? The other issue is something I’ve experienced since the V2 UI was introduced. If a flow has multiple deployments, for example one scheduled every 2 minutes, another every 10 minutes, and another every hour, and I open the flow and then switch to the Deployments modal, I can see the flow view associated with the deployment, but I can’t navigate to it by clicking on it. The field looks clickable, but nothing happens. This works correctly in the current V1 UI.

anyone else not getting a magic code from the login page? cc @Marvin

@Marvin We have noticed that, in some cases, we have pods on our GKE Node that have been stuck in ‘pending’ status for ages, even though the associated flow run has completed. We have observed the same behaviour when flows are stuck in ‘infrastructed pending’ status and we cancel them via the UI. How can we prevent this, or automatically clean up the pods?

Is anyone else experience flow runs getting stuck in pending at the moment?

Hello everyone, I've a PT role and ping me or email if this sounds good. jasoninglet28@gmail.com

Hi, I am victoria, am looking for software developer to work with me from worldwide, if u are interested, feel free to send me message with resume, and salary expectation, @everyone

hi I am Stephe from Ireland

Senior Data & AI Engineer — PivotalStacks We're hiring! Come work on challenging data and AI systems across a modern technology stack. What you'll work on Build data pipelines and platforms using Python, SQL, Spark, and cloud technologies Develop AI/ML solutions, APIs, and data-driven applications Work with machine learning workflows, LLMs, analytics, and data processing Build distributed systems using Kafka, RabbitMQ, Docker, and Kubernetes Work with SQL and NoSQL databases and cloud platforms Collaborate with software, data, and AI teams to take projects from development to production What we're looking for 5+ years of professional experience in Data Engineering, AI/ML Engineering, or Software Engineering Strong Python and SQL skills Experience building production data pipelines and distributed systems Experience with cloud platforms such as AWS, Azure, or GCP Familiarity with ML/AI frameworks, LLMs, APIs, or MLOps Docker/Kubernetes and messaging systems experience is a plus Strong English communication skills What we offer Competitive pay Remote / Hybrid flexibility Work across data engineering, AI, and cloud technologies Opportunities to build production AI and data systems How to apply Email us at careers@pivotalstacks.com with: Updated CV Short video intro (Loom preferred, 2–3 mins) covering: — Brief personal introduction — Most technically challenging data or AI project + how you approached it — A data/AI project you're most proud of We'll review and reach out for a 15–20 min call if there's a fit.

@Marvin I have 3 tasks A, B and C. I want to execute task D if all of them successfully finished or task E if one of them failed. I want to do it without writing spaghetti code with if checking each task state is completed. Is it possible?