Skip to content
Snippets Groups Projects
Commit 37ea6cc8 authored by André Anjos's avatar André Anjos :speech_balloon:
Browse files

[scripts] Improved worker detection and error reporting

parent cb55d77b
No related branches found
No related tags found
1 merge request!194Scheduler
Pipeline #
...@@ -115,6 +115,17 @@ def main(user_input=None): ...@@ -115,6 +115,17 @@ def main(user_input=None):
from ..backend import utils from ..backend import utils
from ..backend.models import Worker from ..backend.models import Worker
try:
worker = Worker.objects.get(name=arguments['--name'])
except Worker.DoesNotExist:
logger.error("Cannot find worker `%s' in database, aborting",
arguments['--name'])
sys.exit(1)
else:
logger.info("Found worker `%s' in database, proceeding...",
arguments['--name'])
# figure out paths to programs I need to use
from beat.core.async import resolve_cpulimit_path from beat.core.async import resolve_cpulimit_path
cpulimit = resolve_cpulimit_path(arguments['--cpulimit']) cpulimit = resolve_cpulimit_path(arguments['--cpulimit'])
logger.debug("(path) cpulimit: `%s'", cpulimit) logger.debug("(path) cpulimit: `%s'", cpulimit)
...@@ -128,8 +139,6 @@ def main(user_input=None): ...@@ -128,8 +139,6 @@ def main(user_input=None):
environments = utils.find_environments(paths) environments = utils.find_environments(paths)
logger.debug("Environments: %s", ", ".join(environments)) logger.debug("Environments: %s", ", ".join(environments))
worker = Worker.objects.get(name=arguments['--name'])
# check environments # check environments
missing, unused = worker.check_environments(environments) missing, unused = worker.check_environments(environments)
if unused: if unused:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment