class_docstr: Create or replace objects belonging to documents.
  
  In real-world scenarios, information sources like Airflow docs, Stack Overflow, or other issues
  are considered 'documents' here. It's crucial to keep the database objects in sync with these sources.
  If any changes occur in these documents, this function aims to reflect those changes in the database.
  
  .. note::
  
      This function assumes responsibility for identifying changes in documents, dropping relevant
      database objects, and recreating them based on updated information. It's crucial to handle this
      process with care, ensuring backups and validation are in place to prevent data loss or
      inconsistencies.
  
  Provides users with multiple ways of dealing with existing values.
  replace: replace the existing objects with new objects. This option requires to identify the
  objects belonging to a document. which by default is done by using document_column field.
  skip: skip the existing objects and only add the missing objects of a document.
  error: raise an error if an object belonging to a existing document is tried to be created.
  
  :param data: A single pandas DataFrame or a list of dicts to be ingested.
  :param class_name: Name of the class in Weaviate schema where data is to be ingested.
  :param existing: Strategy for handling existing data: 'skip', or 'replace'. Default is 'skip'.
  :param document_column: Column in DataFrame that identifying source document.
  :param uuid_column: Column with pre-generated UUIDs. If not provided, UUIDs will be generated.
  :param vector_column: Column with embedding vectors for pre-embedded data.
  :param batch_config_params: Additional parameters for Weaviate batch configuration.
  :param tenant: The tenant to which the object will be added.
  :param verbose: Flag to enable verbose output during the ingestion process.
  :return: list of UUID which failed to create
class_docstr_tok: ["Create","or","replace","objects","belonging","to","documents",".","In","real-world","scenarios",",","information","sources","like","Airflow","docs",",","Stack","Overflow",",","or","other","issues","are","considered","'documents","'","here",".","It","'s","crucial","to","keep","the","database","objects","in","sync","with","these","sources",".","If","any","changes","occur","in","these","documents",",","this","function","aims","to","reflect","those","changes","in","the","database",".","..","note",":",":","This","function","assumes","responsibility","for","identifying","changes","in","documents",",","dropping","relevant","database","objects",",","and","recreating","them","based","on","updated","information",".","It","'s","crucial","to","handle","this","process","with","care",",","ensuring","backups","and","validation","are","in","place","to","prevent","data","loss","or","inconsistencies",".","Provides","users","with","multiple","ways","of","dealing","with","existing","values",".","replace",":","replace","the","existing","objects","with","new","objects",".","This","option","requires","to","identify","the","objects","belonging","to","a","document",".","which","by","default","is","done","by","using","document_column","field",".","skip",":","skip","the","existing","objects","and","only","add","the","missing","objects","of","a","document",".","error",":","raise","an","error","if","an","object","belonging","to","a","existing","document","is","tried","to","be","created",".",":","param","data",":","A","single","pandas","DataFrame","or","a","list","of","dicts","to","be","ingested",".",":","param","class_name",":","Name","of","the","class","in","Weaviate","schema","where","data","is","to","be","ingested",".",":","param","existing",":","Strategy","for","handling","existing","data",":","'skip","'",",","or","'replace","'",".","Default","is","'skip","'",".",":","param","document_column",":","Column","in","DataFrame","that","identifying","source","document",".",":","param","uuid_column",":","Column","with","pre-generated","UUIDs",".","If","not","provided",",","UUIDs","will","be","generated",".",":","param","vector_column",":","Column","with","embedding","vectors","for","pre-embedded","data",".",":","param","batch_config_params",":","Additional","parameters","for","Weaviate","batch","configuration",".",":","param","tenant",":","The","tenant","to","which","the","object","will","be","added",".",":","param","verbose",":","Flag","to","enable","verbose","output","during","the","ingestion","process",".",":","return",":","list","of","UUID","which","failed","to","create"]
code: def execute(self, context: Context) -> list:
      self.log.debug("Total input objects : %s", len(self.input_data))
      insertion_errors = self.hook.create_or_replace_document_objects(
          data=self.input_data,
          class_name=self.class_name,
          document_column=self.document_column,
          existing=self.existing,
          uuid_column=self.uuid_column,
          vector_column=self.vector_col,
          batch_config_params=self.batch_config_params,
          tenant=self.tenant,
          verbose=self.verbose,
      )
      return insertion_errors
  
file_path: airflow/airflow/providers/weaviate/operators/weaviate.py
imports: from __future__ import annotations
  import warnings
  from functools import cached_property
  from typing import TYPE_CHECKING, Any, Sequence
  from airflow.exceptions import AirflowProviderDeprecationWarning
  from airflow.models import BaseOperator
  from airflow.providers.weaviate.hooks.weaviate import WeaviateHook
label_desc: Use image node_id 3 for calling the WeaviateDocumentIngestOperator obj's underlying member method code with example usage: obj.execute(context) and returns: insertion_errors