Tom Han
10/02/2025, 8:38 PMMarvin
10/02/2025, 8:38 PMMarvin
10/02/2025, 8:42 PMfrom prefect.events import emit_event
emit_event(
event="myapp.heartbeat",
resource={"prefect.resource.id": f"prefect.flow-run.{flow_run_id}"},
)
References:
- Detect zombie flows
- Worker health checks
Quick follow-up: Are you asking about flow run, task run, or worker heartbeats? If you share your goal (auditing, alerting, debugging), I can suggest the cleanest way to surface that signal.Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.
Powered by