X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/09794d996eca79b85d3ac0c21a4a43c65a51d0d7..e2bf56f0a0fa1f6b4fb7b4efc4db5178b074b8ce:/services/nodemanager/arvnodeman/launcher.py diff --git a/services/nodemanager/arvnodeman/launcher.py b/services/nodemanager/arvnodeman/launcher.py index cb80bbf293..d85ef552c0 100644 --- a/services/nodemanager/arvnodeman/launcher.py +++ b/services/nodemanager/arvnodeman/launcher.py @@ -1,4 +1,7 @@ #!/usr/bin/env python +# Copyright (C) The Arvados Authors. All rights reserved. +# +# SPDX-License-Identifier: AGPL-3.0 from __future__ import absolute_import, print_function @@ -87,7 +90,10 @@ def launch_pollers(config, server_calculator): config.new_arvados_client(), timer, poll_time, max_poll_time).tell_proxy() job_queue_poller = JobQueueMonitorActor.start( config.new_arvados_client(), timer, server_calculator, - poll_time, max_poll_time).tell_proxy() + config.getboolean('Arvados', 'jobs_queue'), + config.getboolean('Arvados', 'slurm_queue'), + poll_time, max_poll_time + ).tell_proxy() return timer, cloud_node_poller, arvados_node_poller, job_queue_poller _caught_signals = {} @@ -125,7 +131,7 @@ def main(args=None): server_calculator = build_server_calculator(config) timer, cloud_node_poller, arvados_node_poller, job_queue_poller = \ launch_pollers(config, server_calculator) - cloud_node_updater = node_update.start(config.new_cloud_client).tell_proxy() + cloud_node_updater = node_update.start(config.new_cloud_client, timer).tell_proxy() node_daemon = NodeManagerDaemonActor.start( job_queue_poller, arvados_node_poller, cloud_node_poller, cloud_node_updater, timer,