pollination_dsl.dag.base module

class pollination_dsl.dag.base.DAG

Bases: _BaseClass

Baseclass for DSL DAG classes.

Every Queenbee DAG must subclass from this class.

queenbee
_dependencies
_inputs
_outputs
_package
_python_package
property queenbee: DAG

Convert this class to a Queenbee DAG.

class pollination_dsl.dag.base.GroupedDAG

Bases: DAG

A grouped DAG is a special DAG that will be executed on the same Pod.

Grouped DAG is useful to group similar small tasks together to run them faster. Unlike the default DAG, the tasks in group DAG cannot have a for loop.

property queenbee: DAG

Convert this class to a Queenbee DAG.