Revision 59303563
| b/lib/jqueue.py | ||
|---|---|---|
| 522 | 522 |
|
| 523 | 523 |
# Get initial list of nodes |
| 524 | 524 |
self._nodes = dict((n.name, n.primary_ip) |
| 525 |
for n in self.context.cfg.GetAllNodesInfo().values()) |
|
| 525 |
for n in self.context.cfg.GetAllNodesInfo().values() |
|
| 526 |
if n.master_candidate) |
|
| 526 | 527 |
|
| 527 | 528 |
# Remove master node |
| 528 | 529 |
try: |
| ... | ... | |
| 596 | 597 |
# Clean queue directory on added node |
| 597 | 598 |
rpc.RpcRunner.call_jobqueue_purge(node_name) |
| 598 | 599 |
|
| 600 |
if not node.master_candidate: |
|
| 601 |
# remove if existing, ignoring errors |
|
| 602 |
self._nodes.pop(node_name, None) |
|
| 603 |
# and skip the replication of the job ids |
|
| 604 |
return |
|
| 605 |
|
|
| 599 | 606 |
# Upload the whole queue excluding archived jobs |
| 600 | 607 |
files = [self._GetJobPath(job_id) for job_id in self._GetJobIDsUnlocked()] |
| 601 | 608 |
|
Also available in: Unified diff