async def METHOD_NAME(db_connection: SAConnection) -> asyncio.Queue:
    listen_query = f"LISTEN {DB_CHANNEL_NAME};"
    await db_connection.execute(listen_query)
    notifications_queue: asyncio.Queue = db_connection.connection.notifies
    assert notifications_queue.empty()
    yield notifications_queue
    assert (
        notifications_queue.empty()
    ), f"the notification queue was not emptied: {notifications_queue.qsize()} remaining notifications"