code: def testLaunchSucceeds(self, mock_docker_client, mock_publisher):
      mock_publisher.return_value.publish_execution.return_value = {}
      mock_run = mock_docker_client.return_value.containers.run
      mock_run.return_value.logs.return_value = []
      mock_run.return_value.wait.return_value = {"StatusCode": 0}
      context = self._create_launcher_context()
  
      execution_info = self._set_up_test_execution_info(
          input_dict={"input": [context["input_artifact"]]}
      )
      context["operator"].run_executor(execution_info)
  
      mock_run.assert_called_once()
      _, mock_kwargs = mock_run.call_args
      self.assertEqual("gcr://test", mock_kwargs["image"])
      self.assertListEqual(
          ["google/" + context["input_artifact"].uri],
          mock_kwargs["command"],
      )
      self.assertEqual(
          ["VAR=1", "ANOTHER_VAR=2"], mock_kwargs["environment"]
      )
      self.assertEqual("TestContainer", mock_kwargs["name"])
      self.assertEqual(True, mock_kwargs["privileged"])
      self.assertEqual("test_user", mock_kwargs["user"])
      self.assertEqual(
          {
              "/home/user1": {"bind": "/mnt/vol2", "mode": "rw"},
              "/var/www": {"bind": "/mnt/vol1", "mode": "ro"},
          },
          mock_kwargs["volumes"],
      )
      self.assertEqual("value1", mock_kwargs["arg1"])
      self.assertEqual("value2", mock_kwargs["arg2"])
  
file_path: tfx/tfx/orchestration/portable/docker_executor_operator_test.py
imports: import os
  from unittest import mock
  import docker
  import tensorflow
  from tfx.orchestration import publisher
  from tfx.orchestration.launcher import test_utils
  from tfx.orchestration.portable import data_types
  from tfx.orchestration.portable import docker_executor_operator
  from tfx.proto.orchestration import executable_spec_pb2
  from tfx.proto.orchestration import pipeline_pb2
  from tfx.proto.orchestration import platform_config_pb2
  from google.protobuf import text_format
  from ml_metadata.proto import metadata_store_pb2
label_desc: Use image node_id 2 for calling the DockerComponentLauncherTest obj's underlying member method code with example usage: obj.testLaunchSucceeds(mock_docker_client, mock_publisher) without return types