async def METHOD_NAME(session, now_run):
    # The 'now' time check during the run will be after the 'now' scheduled time on the
    # run, but it should still be within the 'mark late after' buffer.
    assert now_run.state.name == "Scheduled"
    st = now_run.state.state_details.scheduled_time
    assert (
        now_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(now_run)
    assert now_run.state.name == "Scheduled"
    st2 = now_run.state.state_details.scheduled_time
    assert st == st2, "Scheduled time is unchanged"