Function create_in_transaction

tests/test_concurrency.py:66–68

()

    """Test concurrent transactions with multiple operations."""

    async def create_in_transaction():
        async with in_transaction():
            await asyncio.gather(*[Tournament.create(name="Test") for _ in range(100)])

    await asyncio.gather(*[create_in_transaction() for _ in range(10)])
    count = await Tournament.all().count()