pipeline_process_test.py revision f20cffac082e3d920818f230ffc80ae6976267c0 
1"""Pipeline Process unittest."""
2
3__author__ = 'yuhenglong@google.com (Yuheng Long)'
4
5import unittest
6
7import pipeline_process
8
9
10class PipelineProcessTest(unittest.TestCase):
11  """This class test the PipelineProcess.
12
13  All the task inserted into the input queue should be taken out and hand to the
14  actual pipeline handler, except for the POISON_PILL.  All these task should
15  also be passed to the next pipeline stage via the output queue.
16  """
17
18  def setUp(self):
19    pass
20
21  def testRun(self):
22    """"Test the run method.
23
24    Ensure that all the tasks inserted into the queue are properly handled.
25    """
26    pass
27
28if __name__ == '__main__':
29  unittest.main()
30