in message_flow/sagas/orchestration_simple_dsl/saga_execution_state_json_serde.py [0:0]
def to_dict(state: SagaExecutionState) -> Dict[str, Any]:
return {
"currently_executing": state.currently_executing,
"compensating": state.compensating,
"end_state": state.end_state,
"failed": state.failed,
}