code: def make_prediction_pipeline(pipeline, args):
    
  
    # DF bug: DF does not work with unicode strings
    predicted_values, errors = (
        pipeline |
        'Read CSV Files' >>
        beam.io.ReadFromText(str(args.predict_data),
                             strip_trailing_newlines=True) |
        'Batch Input' >>
        beam.ParDo(EmitAsBatchDoFn(args.batch_size)) |
        'Run TF Graph on Batches' >>
        beam.ParDo(RunGraphDoFn(args.trained_model_dir)).with_outputs('errors', main='main'))
  
    ((predicted_values, errors) |
     'Format and Save' >>
     FormatAndSave(args))
docs: Builds the prediction pipeline.
  
    Reads the csv files, prepends a ',' if the target column is missing, run
    prediction, and then prints the formated results to a file.
  
    Args:
      pipeline: the pipeline
      args: command line args