code: def testLatestPolicyModelOp_FailedExecution(self):
      self.push_model(self.model_1)
      model_push_2 = self.push_model(self.model_2)
  
      # This ModelPush artifact was marked as ABANDONED because the Pusher
      # execution failed.
      model_push_3 = self.prepare_tfx_artifact(
          test_utils.ModelPush,
          state=metadata_store_pb2.Artifact.State.ABANDONED,
      )
      self.push_model(self.model_3, model_push=model_push_3)
  
      # LatestPolicyModel should NOT consider self.model_3 as the latest pushed
      # model.
      actual = self._latest_policy_model(_LATEST_PUSHED)
      self.assertArtifactMapsEqual(
          actual,
          {
              "model": [self.model_2],
              "model_push": [model_push_2],
          },
      )
  
imports: from typing import Dict, List, Optional
  from absl.testing import parameterized
  import tensorflow
  from tfx import types
  from tfx.dsl.input_resolution import resolver_op
  from tfx.dsl.input_resolution.ops import latest_policy_model_op
  from tfx.dsl.input_resolution.ops import ops
  from tfx.dsl.input_resolution.ops import test_utils
  from tfx.orchestration.portable.input_resolution import exceptions
  from ml_metadata.proto import metadata_store_pb2
label_desc: Use image node_id 16 for calling the LatestPolicyModelOpTest obj's underlying member method code with example usage: obj.testLatestPolicyModelOp_FailedExecution() without return types