apache_beam.error module

Python Dataflow error classes.

exception apache_beam.error.BeamError[source]

Bases: Exception

Base class for all Beam errors.

args
with_traceback()

Exception.with_traceback(tb) – set self.__traceback__ to tb and return self.

exception apache_beam.error.PipelineError[source]

Bases: apache_beam.error.BeamError

An error in the pipeline object (e.g. a PValue not linked to it).

args
with_traceback()

Exception.with_traceback(tb) – set self.__traceback__ to tb and return self.

exception apache_beam.error.PValueError[source]

Bases: apache_beam.error.BeamError

An error related to a PValue object (e.g. value is not computed).

args
with_traceback()

Exception.with_traceback(tb) – set self.__traceback__ to tb and return self.

exception apache_beam.error.RunnerError[source]

Bases: apache_beam.error.BeamError

An error related to a Runner object (e.g. cannot find a runner to run).

args
with_traceback()

Exception.with_traceback(tb) – set self.__traceback__ to tb and return self.

exception apache_beam.error.RuntimeValueProviderError[source]

Bases: RuntimeError

An error related to a ValueProvider object raised during runtime.

args
with_traceback()

Exception.with_traceback(tb) – set self.__traceback__ to tb and return self.

exception apache_beam.error.SideInputError[source]

Bases: apache_beam.error.BeamError

An error related to a side input to a parallel Do operation.

args
with_traceback()

Exception.with_traceback(tb) – set self.__traceback__ to tb and return self.

exception apache_beam.error.TransformError[source]

Bases: apache_beam.error.BeamError

An error related to a PTransform object.

args
with_traceback()

Exception.with_traceback(tb) – set self.__traceback__ to tb and return self.