luigi.tools.deps module¶
-
class
luigi.tools.deps.
upstream
(*args, **kwargs)[source]¶ Bases:
luigi.task.Config
Used to provide the parameter upstream-family
-
family
= OptionalParameter (defaults to None)¶
-
-
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