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