cubed.runtime.executors.beam.BeamExecutor

cubed.runtime.executors.beam.BeamExecutor#

class cubed.runtime.executors.beam.BeamExecutor#

An execution engine that uses Apache Beam.

Methods

`__init__`()
`execute_dag`(dag[, callbacks, resume, spec, ...])

Attributes

name