Revision fbde16f0 lib/watcher/__init__.py
b/lib/watcher/__init__.py | ||
---|---|---|
614 | 614 |
|
615 | 615 |
try: |
616 | 616 |
client = GetLuxiClient(True) |
617 |
query_client = GetLuxiClient(True, query=True) |
|
617 | 618 |
except NotMasterError: |
618 | 619 |
# Don't proceed on non-master nodes |
619 | 620 |
return constants.EXIT_SUCCESS |
... | ... | |
637 | 638 |
_ArchiveJobs(client, opts.job_age) |
638 | 639 |
|
639 | 640 |
# Spawn child processes for all node groups |
640 |
_StartGroupChildren(client, opts.wait_children) |
|
641 |
_StartGroupChildren(query_client, opts.wait_children)
|
|
641 | 642 |
|
642 | 643 |
return constants.EXIT_SUCCESS |
643 | 644 |
|
Also available in: Unified diff