async def METHOD_NAME(context: ConnectorContext) -> StepResult:
    if context.state == ContextState.SUCCESSFUL:
        return await NoOpStep(context, StepStatus.SUCCESS).run()
    if context.state == ContextState.FAILURE:
        return await NoOpStep(context, StepStatus.FAILURE).run()
    if context.state == ContextState.ERROR:
        return await NoOpStep(context, StepStatus.FAILURE).run()
    raise ValueError(f"Could not convert context state: {context.state} to step status")