code: def test_execute_with_input_json(self, mock_log, operator):
      operator.hook.create_or_replace_document_objects = MagicMock()
  
      operator.execute(context=None)
  
      operator.hook.create_or_replace_document_objects.assert_called_once_with(
          data=[{"data": "sample_data"}],
          class_name="my_class",
          document_column="docLink",
          existing="skip",
          uuid_column="id",
          vector_column="vector",
          batch_config_params={"size": 1000},
          tenant=None,
          verbose=False,
      )
      mock_log.debug.assert_called_once_with(
          "Total input objects : %s", len([{"data": "sample_data"}])
      )
  
file_path: airflow/tests/providers/weaviate/operators/test_weaviate.py
imports: from __future__ import annotations
  from unittest.mock import MagicMock, patch
  import pytest
  from airflow.providers.weaviate.operators.weaviate import WeaviateDocumentIngestOperator, WeaviateIngestOperator
label_desc: Use image node_id 3 for calling the TestWeaviateDocumentIngestOperator obj's underlying member method code with example usage: obj.test_execute_with_input_json(mock_log, operator) without return types