async def METHOD_NAME(session, late_run):
    assert late_run.state.name == "Scheduled"
    st = late_run.state.state_details.scheduled_time
    assert (
        late_run.next_scheduled_start_time == st
    ), "Next scheduled time is set by orchestration rules correctly"
    await MarkLateRuns(handle_signals=False).start(loops=1)
    await session.refresh(late_run)
    assert late_run.state.name == "Late"
    st2 = late_run.state.state_details.scheduled_time
    assert st == st2, "Scheduled time is unchanged"