tasks.cli

CLI for validation workflows.

Attributes

WORKFLOW_TASKS
LOGGING_LEVELS
LUIGI_PARAMETERS
_PARAM_NO_VALUE

Classes

ArgParser

Class to build parser and parse arguments.

Functions

_process_param(param)
format_description(param[, default_str, optional_str, ...])	Format the description of a parameter.
_build_parser()	Build the parser.
export_dependency_graph(task, output_file[, dpi])	Export the dependency graph of the given task.
main([arguments])	Main function.

Module Contents

WORKFLOW_TASKS

LOGGING_LEVELS = ['DEBUG', 'INFO', 'WARNING', 'ERROR', 'CRITICAL']

LUIGI_PARAMETERS = ['workers', 'log_level']

_PARAM_NO_VALUE

_process_param(param)

format_description(param, default_str='{doc} Default value: {default}.', optional_str='(optional) {doc}', type_str='({type}) {doc}', choices_str='{doc} Choices: {choices}.', interval_str='{doc} Permitted values: {interval}.', param_no_value=None)

Format the description of a parameter.

class ArgParser

Class to build parser and parse arguments.

parsers

property parser

Return the root parser.

_get_parsers()

Return the main argument parser.

static _get_workflow_parsers(parser=None)

Return the workflow argument parser.

If parser is None, a new parser is created with the workflows as subparsers, otherwise if it is supplied, the parsers are added as subparsers.

For each task listed in WORKFLOW_TASKS, a subparser is created as if it was created by luigi.

parse_args(argv)

Parse the arguments, and return a argparse.Namespace object.

_build_parser()

Build the parser.

export_dependency_graph(task, output_file, dpi=None)

Export the dependency graph of the given task.

main(arguments=None)

Main function.