@tasks.loop(seconds=10.0)
async def bulk_insert_loop(self):
    async with self._batch_lock:
        (await self.bulk_insert())
@tasks.loop(seconds=10.0)
async def bulk_insert_loop(self):
    async with self._batch_lock:
        (await self.bulk_insert())