Asynchrone Datenbank-Isolations-Hooks für Channels-Consumer-Tests

import pytest
from channels.testing import WebsocketCommunicator
from channels.db import database_sync_to_async
from django.db import transaction
 
@pytest.mark.asyncio
@pytest.mark.django_db(transaction=True)
async def test_async_consumer_transaction_isolation(application_factory):
    communicator = WebsocketCommunicator(application_factory(), "/ws/updates/")
    connected, _ = await communicator.connect()
    assert connected
    
    @database_sync_to_async
    def get_atomic_state():
        with transaction.atomic():
            return True
            
    assert await get_atomic_state()
    await communicator.disconnect()