def METHOD_NAME():
  """Configures and runs a pipeline."""
  args = parse_arguments(sys.argv)
  config = parse_config(
      "CLOUD" if args.cloud else "LOCAL",
      get_relative_path("config.ini"))
  set_logging(config.get("log_level"))
  options = get_pipeline_options(args, config)
  runner = str(config.get("runner"))
  with beam.Pipeline(runner, options=options) as pipeline:
    with beam_impl.Context(
        temp_dir=os.path.join(args.tft_dir, constants.TMP_DIR)):
      preprocess.run(pipeline, args)