luigi.tools.deps module¶
- class luigi.tools.deps.upstream(*args, **kwargs)[source]¶
Bases:
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