code: def calculate_private_result(movie_views, pipeline_backend):
      if FLAGS.private_partitions:
          return get_private_movies(movie_views, pipeline_backend)
      else:
          return calc_dp_rating_metrics(
              movie_views, pipeline_backend, get_public_partitions()
          )
  
file_path: pipelinedp/examples/movie_view_ratings/run_all_frameworks.py
imports: from absl import app
  from absl import flags
  from apache_beam.runners.portability import fn_api_runner
  import pyspark
  from examples.movie_view_ratings.common_utils import *
  import pipeline_dp
label_desc: Use image node_id 1 for calling a global function with example usage: calculate_private_result(movie_views, pipeline_backend) and returns: get_private_movies, calc_dp_rating_metrics