X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/3265a76b23fc57ae22ddce95a589c019abce503c..b3d286cda65b90e4dd0aaef88f085f45ea855ed5:/services/nodemanager/arvnodeman/launcher.py diff --git a/services/nodemanager/arvnodeman/launcher.py b/services/nodemanager/arvnodeman/launcher.py index ec5c7840fc..93f6cbdbe3 100644 --- a/services/nodemanager/arvnodeman/launcher.py +++ b/services/nodemanager/arvnodeman/launcher.py @@ -10,6 +10,7 @@ import time import daemon import pykka +import libcloud from . import config as nmconfig from .baseactor import WatchdogActor @@ -70,7 +71,8 @@ def build_server_calculator(config): abort("No valid node sizes configured") return ServerCalculator(cloud_size_list, config.getint('Daemon', 'max_nodes'), - config.getfloat('Daemon', 'max_total_price')) + config.getfloat('Daemon', 'max_total_price'), + config.getfloat('Daemon', 'node_mem_scaling')) def launch_pollers(config, server_calculator): poll_time = config.getint('Daemon', 'poll_time') @@ -78,7 +80,7 @@ def launch_pollers(config, server_calculator): timer = TimedCallBackActor.start(poll_time / 10.0).tell_proxy() cloud_node_poller = CloudNodeListMonitorActor.start( - config.new_cloud_client(), timer, poll_time, max_poll_time).tell_proxy() + config.new_cloud_client(), timer, server_calculator, poll_time, max_poll_time).tell_proxy() arvados_node_poller = ArvadosNodeListMonitorActor.start( config.new_arvados_client(), timer, poll_time, max_poll_time).tell_proxy() job_queue_poller = JobQueueMonitorActor.start( @@ -112,7 +114,7 @@ def main(args=None): try: root_logger = setup_logging(config.get('Logging', 'file'), **config.log_levels()) - root_logger.info("%s %s" % (sys.argv[0], __version__)) + root_logger.info("%s %s, libcloud %s", sys.argv[0], __version__, libcloud.__version__) node_setup, node_shutdown, node_update, node_monitor = \ config.dispatch_classes() server_calculator = build_server_calculator(config)