PrefectHQ/prefect - CodSpeed

prefect

Blog Docs Changelog

Performance History

Latest Results

Make PrefectFutureList.result() fail-fast using as_completed Refactor PrefectFutureList.result() to process futures via as_completed() instead of sequentially iterating. This surfaces errors immediately when any future fails, rather than waiting for earlier slow futures to finish. Result ordering is preserved by mapping each unique future to its original indices. Duplicate futures (same object at multiple positions) are also handled correctly. Closes #20564 https://claude.ai/code/session_015BN7CFHM4zwPr4iamoBDeV

claude/implement-issue-20564-C00KE

7 hours ago

Add retry loop in wait_for_flow_run as defense-in-depth The subscriber fix (retry counter reset) handles repeated idle-timeout disconnections. This commit adds a retry loop in wait_for_flow_run that catches RETRYABLE_EXCEPTIONS and re-creates the subscriber, so the watch never crashes from ConnectionClosedError even if the subscriber eventually gives up. Co-Authored-By: alex.s@prefect.io <ajstreed1@gmail.com>

devin/1770412331-fix-websocket-timeout-watching

1 day ago

Move websocket timeout fix into PrefectEventSubscriber Revert the retry loop in wait_for_flow_run and instead fix the root cause in PrefectEventSubscriber.__anext__: the retry counter now resets after each successful reconnection so the subscriber can survive unlimited idle-timeout disconnections (as long as each reconnection succeeds), rather than giving up after reconnection_attempts total drops. Closes https://github.com/PrefectHQ/prefect/issues/18428 Co-Authored-By: alex.s@prefect.io <ajstreed1@gmail.com>

devin/1770412331-fix-websocket-timeout-watching

2 days ago

Add attribution headers to SDK API requests (#20508) Co-authored-by: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

main

2 days ago

Add test coverage for websocket reconnection in wait_for_flow_run Two tests covering the retry behavior: - test_wait_for_flow_run_reconnects_on_connection_error: subscriber fails with ConnectionClosedError on first attempt, succeeds on second with a completion event - test_wait_for_flow_run_detects_completion_after_reconnect: subscriber fails, flow completes while disconnected, detected via state check on reconnect Co-Authored-By: alex.s@prefect.io <ajstreed1@gmail.com>

devin/1770412331-fix-websocket-timeout-watching

2 days ago

Move get_attribution_headers import to module level The attribution module already defers its own imports internally, so no need to defer the import at the call site. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

zach/cloud-3239-attribution-headers

2 days ago

Add selector resolution and node filtering for per-node dbt orchestration (#20579) Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com>

main

2 days ago

feat(cli): migrate config, profile, version to cyclopts (wave 1) (#20585) Co-authored-by: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

main

2 days ago

Active Branches

Make PrefectFutureList.result() fail-fast using as_completed

last run

7 hours ago

0%

Fix websocket timeout when watching long-running flow runs

last run

1 day ago

0%

Add `replaces` field for renaming schedule slugs

last run

2 days ago

0%

© 2026 CodSpeed Technology

Home Terms Privacy Docs