async def METHOD_NAME(self, batch_id: bytes) -> None:
    def cont() -> None:
        with self._conn, closing(self._conn.cursor()) as cursor:
            cursor.execute(sql("insert", "batch"), {"rowid": batch_id})
    async with self._lock:
        await self._ex.submit(cont)