Revision b2e8a4d9 test/ganeti.workerpool_unittest.py
b/test/ganeti.workerpool_unittest.py | ||
---|---|---|
93 | 93 |
self._CheckWorkerCount(wp, 3) |
94 | 94 |
|
95 | 95 |
for i in range(10): |
96 |
wp.AddTask(ctx, "Hello world %s" % i)
|
|
96 |
wp.AddTask((ctx, "Hello world %s" % i))
|
|
97 | 97 |
|
98 | 98 |
wp.Quiesce() |
99 | 99 |
finally: |
... | ... | |
133 | 133 |
checksum = ChecksumContext.CHECKSUM_START |
134 | 134 |
for i in range(1, 100): |
135 | 135 |
checksum = ChecksumContext.UpdateChecksum(checksum, i) |
136 |
wp.AddTask(ctx, i)
|
|
136 |
wp.AddTask((ctx, i))
|
|
137 | 137 |
|
138 | 138 |
wp.Quiesce() |
139 | 139 |
|
... | ... | |
156 | 156 |
self._CheckWorkerCount(wp, 3) |
157 | 157 |
|
158 | 158 |
wp.AddManyTasks([(ctx, "Hello world %s" % i, ) for i in range(10)]) |
159 |
wp.AddTask(ctx, "A separate hello")
|
|
160 |
wp.AddTask(ctx, "Once more, hi!")
|
|
159 |
wp.AddTask((ctx, "A separate hello"))
|
|
160 |
wp.AddTask((ctx, "Once more, hi!"))
|
|
161 | 161 |
wp.AddManyTasks([(ctx, "Hello world %s" % i, ) for i in range(10)]) |
162 | 162 |
|
163 | 163 |
wp.Quiesce() |
... | ... | |
180 | 180 |
[i for i in range(10)]) |
181 | 181 |
|
182 | 182 |
wp.AddManyTasks([(ctx, "Hello world %s" % i, ) for i in range(10)]) |
183 |
wp.AddTask(ctx, "A separate hello")
|
|
183 |
wp.AddTask((ctx, "A separate hello"))
|
|
184 | 184 |
|
185 | 185 |
wp.Quiesce() |
186 | 186 |
|
Also available in: Unified diff