supabase / etl / 29081800273

73%

Build Type

push

github

Committed by web-flow

Commit Message

feat(etl): Add scripted fault injection for destination tests (#893)

* feat(etl): Add destination fault injection test primitives

FaultInjector holds per-operation FIFO queues of scripted FaultAction
values (FailDispatch, FailResult, HoldResult, DelayResult). HoldGate and
HoldHandle let tests observe a held async result and release it with the
captured inner result or an injected error.

* feat(etl): Wire fault injection into TestDestinationWrapper

Each destination method consumes scripted faults: dispatch failures
return before the inner destination runs, result faults apply between
the inner result and the apply loop. startup is now forwarded to the
inner destination, and shutdown_called is recorded before faults so
tests can assert the invocation. Adds the first pipeline consumer:
destination_shutdown_error_is_returned_by_shutdown_and_wait.

* test(etl): Cover drop_table_for_copy failure on both channels

Dispatch failure leaves the inner destination untouched; result failure
applies the drop but the apply loop observes an error. Both leave the
table Errored with timed retry, keep schemas in the store, and recopy
cleanly on retry.

* ref(etl): Tighten fault test comments and docs

Single-line GIVEN/WHEN/THEN comments without marker decoration, variant
docs on FaultyOp, trimmed InjectedError doc.

* ref(etl): Rename fault actions to destination-behavior vocabulary

Reject, FailAfterWrite, HoldResponse, and RespondSlowly replace
FailDispatch, FailResult, HoldResult, and DelayResult. Document that
holds are indefinite and test-controlled unlike RespondSlowly, and
replace the Default derive on FaultInjector with the conventional
manual impl.

Coverage Stats

172 of 187 new or added lines in 2 files covered. (91.98%)

778 existing lines in 18 files now uncovered.

40672 of 55904 relevant lines covered (72.75%)

1643.17 hits per line