#7080 feat(runs): async abort reconciler with retry and crash recovery Pull request opened by AdilFayyaz Why are the changes needed? AbortRun/AbortAction previously called actionsClient.Abort() synchronously after updating the DB. If the call failed, the DB showed ABORTED but the pod kept running with no retry path. Abort needed to be made reliable without blocking the user-facing response. What changes were proposed in this pull request? • Add three columns to actions (abort_requested_at, abort_attempt_count, abort_reason); DB update is immediate so the UI sees ABORTED optimistically • Introduce AbortReconciler — a background worker pool that drives pod termination to completion with exponential backoff and a configurable max-attempts cap; uses a deduplicated in-memory queue so concurrent pushes for the same action are no-ops • AbortRun/AbortAction push directly to the reconciler queue after the DB update; startup scan re-enqueues any pending aborts left over from a process crash • Scope all abort-related DB queries with run_name to correctly target individual actions when node names (e.g. a0) repeat across runs How was this patch tested? • go test ./runs/... passes • TestAbortReconciler_SuccessOnFirstAttempt — happy path: worker calls actionsClient.Abort, clears DB flag • TestAbortReconciler_RetriesOnFailure — fails N−1 times, succeeds on Nth attempt • TestAbortReconciler_GivesUpAtMaxAttempts — always fails; flag cleared after max attempts with no further calls • TestAbortReconciler_DeduplicatesQueue — same action pushed twice; actionsClient.Abort called exactly once • TestAbortReconciler_StartupScanPicksUpPending — pending aborts from before startup are all processed • TestAbortReconciler_NotFoundTreatedAsSuccess — NotFound from actions service clears the flag without retry • Manually ran an example from the sdk and tested the abort functionality Setup process Screenshots Check all the applicable boxes • I updated the documentation accordingly. • All new and existing tests passed. • All commits are signed-off. Related PRs Docs link •

main

• #6583 • feat(runs): async abort reconciler with retry and crash recovery 👈 flyteorg/flyte