Yuheng Long | f20cffa | 2013-06-03 18:46:00 -0700 | [diff] [blame^] | 1 | """Pipeline Process unittest.""" |
| 2 | |
| 3 | __author__ = 'yuhenglong@google.com (Yuheng Long)' |
| 4 | |
| 5 | import unittest |
| 6 | |
| 7 | import pipeline_process |
| 8 | |
| 9 | |
| 10 | class 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 | |
| 28 | if __name__ == '__main__': |
| 29 | unittest.main() |