Hi prefect community, I am looking for a way to set up a slack alert for flows that their runtimes pass a certain expected time while the flow is still running, would appreciate your suggestions or best ways to achieve this, We are on prefect 1 and we use python for our flow runs and we already have slack alerts for failed runs but that is using flow run state changes which is not useful for this case.

You could use some custom logic with the prefect context values

scheduled_start_time

and

date

https://docs-v1.prefect.io/api/latest/utilities/context.html#context-2 https://discourse.prefect.io/t/how-to-use-the-datetimeparameter-task-and-how-to-retrieve-the-scheduled-start-time-from-within-the-flow/487

You could also use GraphQL to see which flows are running as well, if you’re interested in observing run times for all flows

Thank you for the suggestions, @Serina I like the GraphQl idea for all flows, I tried the graphql UI and I composed the query and I get the expected results, when I try to replicate the same thing in python, I am not sure if I am setting all the required params correctly for the client(). I used this code:

from prefect import Client

client = Client(api_key="our cloud API key")
response = client.graphql("my exact query string that works on UI")
print(response)

Passing our cloud API key to the client as param and it times out after retries, so I suspect I am still missing some other params or settings maybe. (I am running this locally on a container) any guidance here?

Do you have multiple tenants? You may want to try running

client.tenant_id

to determine the default tenant associated with the API key

oh wow, it worked 🙂 Thank you so much for your help! 🎉🙏