Skip to content

pyuow.unit

Sync flow units.

unit

BaseUnit

Bases: Generic[CONTEXT, OUT], ABC

FlowUnit

FlowUnit()

Bases: BaseUnit[CONTEXT, OUT], ABC

ConditionalUnit

ConditionalUnit(*, on_failure: FlowUnit[CONTEXT, OUT])

Bases: FlowUnit[CONTEXT, OUT]

RunUnit

RunUnit()

Bases: FlowUnit[CONTEXT, OUT]

FinalUnit

FinalUnit()

Bases: FlowUnit[CONTEXT, OUT], ABC

ErrorUnit

ErrorUnit(exc: Exception)

Bases: FinalUnit[CONTEXT, OUT]

CannotReassignUnitError

Bases: Exception

FinalUnitError

Bases: Exception

FlowNotTerminatedError

Bases: Exception

pyuow.unit.aio

aio

BaseUnit

Bases: Generic[CONTEXT, OUT], ABC

FlowUnit

FlowUnit()

Bases: BaseUnit[CONTEXT, OUT], ABC

ConditionalUnit

ConditionalUnit(*, on_failure: FlowUnit[CONTEXT, OUT])

Bases: FlowUnit[CONTEXT, OUT]

RunUnit

RunUnit()

Bases: FlowUnit[CONTEXT, OUT]

FinalUnit

FinalUnit()

Bases: FlowUnit[CONTEXT, OUT], ABC

ErrorUnit

ErrorUnit(exc: Exception)

Bases: FinalUnit[CONTEXT, OUT]