in message_flow/sagas/orchestration_simple_dsl/saga_execution_state_json_serde.py [0:0]
def from_dict(state: Dict[str, Any]) -> SagaExecutionState:
saga_execution_state = SagaExecutionState(
state.get("currently_executing", -1),
state.get("compensating", False),
)
saga_execution_state.end_state = state.get("end_state", False)
saga_execution_state.failed = state.get("failed", False)
return saga_execution_state