Function push_data

tests/unit/storages/test_storage_instance_manager.py:143–146

(data: dict)

    barrier = Barrier(2)

    async def push_data(data: dict) -> None:
        await barrier.wait()
        dataset = await Dataset.open(name='concurrent-storage')
        await dataset.push_data(data)

    await asyncio.gather(
        push_data({'test_1': '1'}),