def METHOD_NAME(
    self, client: MLClient, pipelines_registry_client: MLClient
):
    # load_component
    score_func = load_component("./tests/test_configs/pipeline_jobs/job_with_registry_model_as_input/score.yml")
    model_path = Path("./tests/test_configs/model/model_iris.yml")
    model_entity = load_model(model_path)
    try:
        pipeline_score_model = pipelines_registry_client.models.get(
            name=model_entity.name, version=model_entity.version
        )
    except ResourceNotFoundError:
        model_entity = pipelines_registry_client.models.create_or_update(model_entity)
        pipeline_score_model = pipelines_registry_client.models.get(
            name=model_entity.name, version=model_entity.version
        )
    assert_pipeline_job_cancel(client, score_func, pipeline_score_model, self.test_data)