run — The run subcommand

Module for the run subcommand.

class valjean.cambronne.commands.run.RunCommand[source]

Command class for the run subcommand.

register(parser)[source]

Register options for this command in the parser.

execute(args, config)[source]

Execute the run command.

classmethod task_diagnostics(*, tasks, env, config)[source]

Emit diagnostic messages about the status of the tasks. Count how many have succeeded, how many have failed, etc. If any tasks have failed, this method writes their names in a file called ‘failed_tasks’ in the log directory.

Parameters:

  • tasks (list(Task)) – the tasks that have been scheduled.

  • env (Env) – the environment.

  • config (Config) – the configuration object.

classmethod write_failed_tasks(*, failed, config)[source]

Write the names of the failed tasks in the failed_tasks file.

Parameters:

  • failed (list(str)) – the names of the failed tasks.

  • config (Config) – the configuration object.

valjean.cambronne.commands.run.schedule(*, hard_graph, soft_graph, env, config=None, workers=1)[source]

Schedule a graph for execution.