code: def parse_file(filename):  # used for the local run
      res = []
      for line in open(filename):
          line = line.strip()
          if line[-1] == ":":
              movie_id = int(line[:-1])
          else:
              res.append(parse_line(line, movie_id))
      return res
  
file_path: pipelinedp/examples/movie_view_ratings/common_utils.py
imports: from dataclasses import dataclass
  import os
  import shutil
  from typing import List, Any
  import apache_beam
label_desc: Use image node_id 3 for calling a global function with example usage: parse_file(filename) and returns: res