The Beam integration currently parses the functions in ParDo to return exceptions in their respective setup, start_bundle, process, and finish_bundle functions.
This integration is experimental. It may be removed in minor versions. When enabling this integration, expect to see incorrect server_name and 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", integrations=[ BeamIntegration(), ], # Set traces_sample_rate to 1.0 to capture 100% # of transactions for performance monitoring. # We recommend adjusting this value in production, traces_sample_rate=1.0, )
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.
Our documentation is open source and available on GitHub. Your contributions are welcome, whether fixing a typo (drat!) to suggesting an update ("yeah, this would be better").