code: def _get_or_run(entrypoint, parameters, git_commit, use_cache=True):
      existing_run = _already_ran(entrypoint, parameters, git_commit)
      if use_cache and existing_run:
          print(
              f"Found existing run for entrypoint={entrypoint} and parameters={parameters}"
          )
          return existing_run
      print(
          f"Launching new run for entrypoint={entrypoint} and parameters={parameters}"
      )
      submitted_run = mlflow.run(
          ".", entrypoint, parameters=parameters, env_manager="local"
      )
      return MlflowClient().get_run(submitted_run.run_id)
  
file_path: mlflow/examples/multistep_workflow/main.py
imports: import os
  import click
  import mlflow
  from mlflow.entities import RunStatus
  from mlflow.tracking import MlflowClient
  from mlflow.tracking.fluent import _get_experiment_id
  from mlflow.utils import mlflow_tags
  from mlflow.utils.logging_utils import eprint
label_desc: Use image node_id 2 for calling a global function with example usage: _get_or_run(entrypoint, parameters, git_commit, use_cache) and returns: MlflowClient, existing_run