scheduler package

Submodules

scheduler.cli module

scheduler.cli.setup_logging(debug=False)[source]
scheduler.cli.validate_config(config)[source]

scheduler.config module

scheduler.config.constructor_env_variables(loader, node)[source]

Extracts the environment variable from the node’s value :param yaml.Loader loader: the yaml loader :param node: the current node in the yaml :return: the parsed string that contains the value of the environment variable

scheduler.config.load_config(input_file: TextIO) dict[source]

scheduler.daemon module

scheduler.daemon.run_daemon(config: dict, host: str, port: int)[source]

Run the scheduler daemon, scheduling signals to send to other services

scheduler.daemon.trigger_queue(name: str, client: Redis, queue: str)[source]

Module contents