Branches performance
Pull requests
last run
10 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>
10 hours ago
5510e81
devin/1770412331-fix-websocket-timeout-watching
0%
last run
18 hours ago
Add `DbtCoreExecutor` for per-node dbt command execution (Phase 3)
Introduces `ExecutionResult` dataclass, `DbtExecutor` protocol, and
`DbtCoreExecutor` implementation that wraps dbt-core's `dbtRunner` to
execute individual nodes or waves. The executor captures errors as data
(never raises), derives node_ids from actual execution results, and
supports --state/--defer/--favor-state/--threads/--full-refresh flags.
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
18 hours ago
6939259
feat/per-node-dbt-orchestration-phase-3
0%
last run
21 hours ago
feat(cli): migrate flow, flow-run to cyclopts (wave 3)
Native cyclopts implementations for:
- flow (ls, serve)
- flow-run (inspect, ls, delete, cancel, retry, logs, execute)
deploy and deployment remain delegated to typer.
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
21 hours ago
c59bcb7
cli-cyclopts/wave-3
0%
last run
21 hours ago
feat(cli): migrate server, worker, shell to cyclopts (wave 2)
Native cyclopts implementations for:
- server (start, stop, database/*, services/*)
- worker (start with install-policy, health check, etc.)
- shell (watch, serve)
Reuses business logic from typer modules (server helpers, worker class
loading, etc.) while replacing framework-specific argument parsing.
Routes server/worker/shell through cyclopts when PREFECT_CLI_FAST=1.
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
22 hours ago
a8cf31f
cli-cyclopts/wave-2
0%