The Beam integration currently parses the functions in ParDo to return exceptions in their respective
This integration is experimental. It may be removed in minor versions. When enabling this integration, expect to see incorrect
ip due to some distributed properties within Beam.
A Beam version of 2.12 or later is required.
BeamIntegration() to your
import sentry_sdk from sentry_sdk.integrations.beam import BeamIntegration sentry_sdk.init( dsn="https://examplePublicKey@o0.ingest.sentry.io/0", enable_tracing=True, integrations=[ BeamIntegration(), ], )
The functions get injected with an inspect function to patch getting the function signature.
The integration requires Sentry to be installed on all the worker computers using a
The main computer invoking the pipeline requires the same version of Sentry as the worker nodes.