Giacomo Chiarella

08/02/2023, 1:14 PM
By using
Copy code
await client.read_flow_runs(flow_run_filter=FlowRunFilter(expected_start_time={
    "after_": after, "before_": before}))
would this give all the flow_runs or I will need to execute another call passing offset = len(previous flow runs)?
I have some dags stuck in pending (due to ec2 instance terminated and replaced by the autoscaling group) which are not returned by the statement above. Meanwhile, other dags are returned. Why is this happening?
any Prefect developer here?

Chris Reuter

08/04/2023, 12:04 PM
Hi @Giacomo Chiarella - there isn't enough information here to answer your question. I recommend getting in touch with a Prefect product advocate, by emailing or by scheduling time via Calendly.

Giacomo Chiarella

08/04/2023, 12:07 PM
Hi @Chris Reuter, thank you for your answer. Unfortunately there is no other information I can provide. It is quite strange behaviour. Maybe when the instance got terminated, database data related to these flow runs was not consistent. Let’s see if it happens again, I will try to save the backup to investigate more
👍 1