async def METHOD_NAME(mocker, caplog, connector):
    pool = mocker.Mock(maxsize=1)
    await connector.open_async(pool)
    caplog.clear()
    await connector.listen_notify(None, None)
    assert {e.action for e in caplog.records} == {"listen_notify_disabled"}