async def METHOD_NAME(job_manager, connector, mocker, queues, channels):
    event = mocker.Mock()
    await job_manager.listen_for_jobs(queues=queues, event=event)
    assert connector.notify_event is event
    assert connector.notify_channels == channels