Method acquire

trinity/buffer/writer/sql_writer.py:41–46

(self)

            await storage.write(data)

    async def acquire(self) -> int:
        if self.wrap_in_ray:
            return await self.storage.acquire.remote()
        else:
            storage = await self._get_async_storage()
            return storage.acquire()

    async def release(self) -> int:
        if self.wrap_in_ray: