"""Pipeline Process unittest."""

__author__ = 'yuhenglong@google.com (Yuheng Long)'

import unittest

import pipeline_process


class PipelineProcessTest(unittest.TestCase):
  """This class test the PipelineProcess.

  All the task inserted into the input queue should be taken out and hand to the
  actual pipeline handler, except for the POISON_PILL.  All these task should
  also be passed to the next pipeline stage via the output queue.
  """

  def setUp(self):
    pass

  def testRun(self):
    """"Test the run method.

    Ensure that all the tasks inserted into the queue are properly handled.
    """
    pass

if __name__ == '__main__':
  unittest.main()