code: def testCompileFullTaxiPipeline(
      self, fake_now, moke_resolve_dependencies
  ):
      fake_now.return_value = datetime.date(2020, 1, 1)
      moke_resolve_dependencies.return_value = None
  
      runner = kubeflow_v2_dag_runner.KubeflowV2DagRunner(
          output_dir=_TEST_DIR,
          output_filename=_TEST_FILE_NAME,
          config=kubeflow_v2_dag_runner.KubeflowV2DagRunnerConfig(
              display_name="my-pipeline",
              default_image="tensorflow/tfx:latest",
          ),
      )
  
      self._compare_against_testdata(
          runner=runner,
          pipeline=test_utils.full_taxi_pipeline(),
          golden_file="expected_full_taxi_pipeline_job.json",
      )
      moke_resolve_dependencies.assert_called()
  
imports: import collections
  import datetime
  import json
  import os
  from unittest import mock
  import tensorflow
  from tfx import version
  from tfx.dsl.components.base import base_component
  from tfx.orchestration import pipeline
  from tfx.orchestration.kubeflow.v2 import kubeflow_v2_dag_runner
  from tfx.orchestration.kubeflow.v2 import test_utils
  from tfx.utils import telemetry_utils
  from tfx.utils import test_case_utils
label_desc: Use image node_id 6 for calling the KubeflowV2DagRunnerTest obj's underlying member method code with example usage: obj.testCompileFullTaxiPipeline(fake_now, moke_resolve_dependencies) without return types