code: def test_execute(self, mock_s3_hook, mock_mongo_hook):
      operator = self.mock_operator
  
      mock_mongo_hook.return_value.find.return_value = iter(
          MOCK_MONGO_RETURN
      )
      mock_s3_hook.return_value.load_string.return_value = True
  
      operator.execute(None)
  
      mock_mongo_hook.return_value.find.assert_called_once_with(
          mongo_collection=MONGO_COLLECTION,
          query=MONGO_QUERY,
          find_one=False,
          mongo_db=None,
          projection=None,
      )
  
      op_stringify = self.mock_operator._stringify
      op_transform = self.mock_operator.transform
  
      s3_doc_str = op_stringify(op_transform(MOCK_MONGO_RETURN))
  
      mock_s3_hook.return_value.load_string.assert_called_once_with(
          string_data=s3_doc_str,
          key=S3_KEY,
          bucket_name=S3_BUCKET,
          replace=False,
          compression=COMPRESSION,
      )
  
file_path: airflow/tests/providers/amazon/aws/transfers/test_mongo_to_s3.py
imports: from __future__ import annotations
  from unittest import mock
  import pytest
  from airflow.models import DAG, DagRun, TaskInstance
  from airflow.providers.amazon.aws.transfers.mongo_to_s3 import MongoToS3Operator
  from airflow.utils import timezone
label_desc: Use image node_id 5 for calling the TestMongoToS3Operator obj's underlying member method code with example usage: obj.test_execute(mock_s3_hook, mock_mongo_hook) without return types