Revision daba67c7 test/ganeti.workerpool_unittest.py
b/test/ganeti.workerpool_unittest.py | ||
---|---|---|
76 | 76 |
|
77 | 77 |
class ChecksumBaseWorker(workerpool.BaseWorker): |
78 | 78 |
def RunTask(self, ctx, number): |
79 |
name = "number%s" % number |
|
80 |
self.SetTaskName(name) |
|
81 |
|
|
82 |
# This assertion needs to be checked before updating the checksum. A |
|
83 |
# failing assertion will then cause the result to be wrong. |
|
84 |
assert self.getName() == ("%s/%s" % (self._worker_id, name)) |
|
85 |
|
|
79 | 86 |
ctx.lock.acquire() |
80 | 87 |
try: |
81 | 88 |
ctx.checksum = ctx.UpdateChecksum(ctx.checksum, number) |
Also available in: Unified diff