blob: 8df2327848e3a950e394b7160c60234348823c9d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
"""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()
|
