async def METHOD_NAME(
    session, late_run, late_run_2
):
    assert late_run.state.name == "Scheduled"
    assert late_run_2.state.name == "Scheduled"
    await MarkLateRuns(handle_signals=False).start(loops=1)
    await session.refresh(late_run)
    await session.refresh(late_run_2)
    assert late_run.state_name == "Late"
    assert late_run_2.state_name == "Late"