async def METHOD_NAME(job_manager, job_factory, connector):
    job = job_factory()
    await job_manager.defer_job_async(job=job)
    await job_manager.fetch_job(queues=None)
    connector.events[1][-1]["at"] = conftest.aware_datetime(2000, 1, 1)
    expected_job = job.evolve(id=1, status="doing")
    assert await job_manager.get_stalled_jobs(nb_seconds=1000) == [expected_job]