Skip to content

AllStreamOperationsFailedError

Class: warmhub.AllStreamOperationsFailedError

AllStreamOperationsFailedError(result: Mapping[str, Any], *, receipts: Sequence[OperationEventReceipt] = ())

The stream append completed deterministically but every operation failed.

NOT a WarmHubError — see the module docstring.

result is the wire mapping, matching TypeScript’s constructor, but operations is decoded into SubmittedOperation models. Handing back raw mappings would make op.submitted_name and op.error.code — the two things a caller reads on this path — fail with AttributeError, which is exactly what the quickstart does.

Cause. Raised when the append reached the server and every operation in it was rejected. The request itself succeeded; its contents did not.

Retryability. Not retryable as a whole. The outcome is deterministic, so resending the same operations produces the same failures.

Corrective action. Inspect operations; each carries the per-op code and message. Fix the operations the codes name and submit again.

code = 'STREAM_ALL_OPERATIONS_FAILED'

Documentation is not yet available.

name = 'WarmHubError'

Mirrors TypeScript. See the note on name.

message = message

Documentation is not yet available.

result = result

Documentation is not yet available.

receipts = tuple(receipts)

Documentation is not yet available.

operations = operations

Documentation is not yet available.

cause = primary_failure.raw if primary_failure is not None else None

Documentation is not yet available.

status_counts = StreamStatusCounts(applied=(_count(typed, 'applied')), noop=(_count(typed, 'noop')), error=(_count(typed, 'error')))

Documentation is not yet available.