Apache Beam

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.

Add BeamIntegration() to your integrations list:

import sentry_sdk
from sentry_sdk.integrations.beam import BeamIntegration


    # Set traces_sample_rate to 1.0 to capture 100%
    # of transactions for performance monitoring.
    # We recommend adjusting this value in production,


  • 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 --requirements_file.

  • The main computer invoking the pipeline requires the same version of Sentry as the worker nodes.

Help improve this content
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").
Suggest an edit to this page   |  Contribute to Docs   |  

Report a Problem

🎉 Thank you for your feedback! 🙌
Report a problem