# Path: video_processing/processor_runner.py
# def run_processor_chain(processors_list):
# 
# Path: video_processing/processors/opencv_video_decoder.py
# class OpenCVVideoDecoderProcessor(stream_processor.ProcessorBase):
#   def __init__(self, configuration):
#   def open(self, stream_set):
#   def process(self, frame_set):
#   def close(self):
# 
# Path: video_processing/processors/opencv_video_encoder.py
# class OpenCVVideoEncoderProcessor(stream_processor.ProcessorBase):
#   def __init__(self, configuration):
#   def open(self, stream_set):
#   def process(self, frame_set):
#   def close(self):


from absl import app
from absl import flags
from video_processing import processor_runner
from video_processing.processors import opencv_video_decoder
from video_processing.processors import opencv_video_encoder
# Copyright 2019 Google LLC.
"""Pipeline to decode and reencode a video using OpenCV."""


flags.DEFINE_string('input_video_file', '', 'Input file.')
flags.DEFINE_string('output_video_file', '', 'Output file.')

FLAGS = flags.FLAGS


def pipeline(input_video_file, output_video_file):
  return [
      opencv_video_decoder.OpenCVVideoDecoderProcessor(
          {'input_video_file': input_video_file}),

# Path: video_processing/processor_runner.py
# def run_processor_chain(processors_list):
# 
# Path: video_processing/processors/opencv_video_decoder.py
# class OpenCVVideoDecoderProcessor(stream_processor.ProcessorBase):
#   def __init__(self, configuration):
#   def open(self, stream_set):
#   def process(self, frame_set):
#   def close(self):
# 
# Path: video_processing/processors/opencv_video_encoder.py
# class OpenCVVideoEncoderProcessor(stream_processor.ProcessorBase):
#   def __init__(self, configuration):
#   def open(self, stream_set):
#   def process(self, frame_set):
#   def close(self):


# Path: video_processing/pipelines/simple_encode_decode.py
from absl import app
from absl import flags
from video_processing import processor_runner
from video_processing.processors import opencv_video_decoder
from video_processing.processors import opencv_video_encoder

# Copyright 2019 Google LLC.
"""Pipeline to decode and reencode a video using OpenCV."""


flags.DEFINE_string('input_video_file', '', 'Input file.')
flags.DEFINE_string('output_video_file', '', 'Output file.')

FLAGS = flags.FLAGS


def pipeline(input_video_file, output_video_file):
  return [
      opencv_video_decoder.OpenCVVideoDecoderProcessor(
          {'input_video_file': input_video_file}),

      opencv_video_encoder.OpenCVVideoEncoderProcessor(