MODULE REFERENCE

local

anomx.execution.backends.local

Interchangeable persistence for run lifecycle and step events.

CallbackBackend

CallbackBackend(callback: Callable[[dict[str, Any]], Any])

Adapt an existing worker transport or application-specific event sink.

Signature parameters
ParameterTypeDefault
callbackCallable[[dict[str, Any]], Any]required

Members

writemethod
write(event: Mapping[str, Any]) -> None
Signature parameters
ParameterTypeDefault
eventMapping[str, Any]required

Returns None

JsonlBackend

JsonlBackend(path: str | Path)

Append portable JSON events to a local file (offline by default).

Signature parameters
ParameterTypeDefault
pathstr | Pathrequired

Members

writemethod
write(event: Mapping[str, Any]) -> None
Signature parameters
ParameterTypeDefault
eventMapping[str, Any]required

Returns None