luigi.tools.deps

Functions

`dfs_paths`(start_task, goal_task_family[, path])
`find_deps`(task, upstream_task_family)	Finds all dependencies that start with the given task and have a path to upstream_task_family
`find_deps_cli`()	Finds all tasks on all paths from provided CLI task
`get_task_output_description`(task_output)	Returns a task's output as a string
`get_task_requires`(task)
`main`()

Classes

upstream(*args, **kwargs)

Used to provide the parameter upstream-family

luigi.tools.deps.dfs_paths(start_task, goal_task_family, path=None)[source]

class luigi.tools.deps.upstream(*args, **kwargs)[source]

Used to provide the parameter upstream-family

luigi.tools.deps.find_deps(task, upstream_task_family)[source]

Finds all dependencies that start with the given task and have a path to upstream_task_family

Returns all deps on all paths between task and upstream

luigi.tools.deps.find_deps_cli()[source]: Finds all tasks on all paths from provided CLI task

luigi.tools.deps.get_task_output_description(task_output)[source]: Returns a task’s output as a string