Branches performance
Pull requests
last run
1 hour ago
Wrap as_completed loop in timeout_context for consistent timeout semantics
Re-add timeout_context around the entire loop so that slow result
retrieval (e.g. large data deserialization in future.result()) is also
bounded by the caller's timeout, matching the previous behavior.
https://claude.ai/code/session_015BN7CFHM4zwPr4iamoBDeV
1 hour ago
70380f4
claude/implement-issue-20564-C00KE
0%
last run
1 day 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>
1 day ago
5510e81
devin/1770412331-fix-websocket-timeout-watching
0%
last run
2 days 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>
2 days ago
6939259
feat/per-node-dbt-orchestration-phase-3
0%
last run
2 days 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>
2 days ago
c59bcb7
cli-cyclopts/wave-3
0%