Skip to content

Commit 52559be

Browse files
committed
Add: added add_event_processor method
1 parent 4c673d6 commit 52559be

File tree

1 file changed

+12
-11
lines changed

1 file changed

+12
-11
lines changed

sentry_sdk/integrations/spark/spark_driver.py

Lines changed: 12 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -36,28 +36,21 @@ def _set_app_properties():
3636
)
3737

3838

39-
def _start_sentry_listener():
39+
def _start_sentry_listener(sc):
4040
# type: (Any) -> None
4141
"""
4242
Start java gateway server to add custom `SparkListener`
4343
"""
44-
from pyspark import SparkContext
4544
from pyspark.java_gateway import ensure_callback_server_started
4645

47-
sc = SparkContext._active_spark_context
4846
gw = sc._gateway
4947
ensure_callback_server_started(gw)
5048
listener = SentryListener()
5149
sc._jsc.sc().addSparkListener(listener)
5250

5351

54-
def _activate_integration(sc):
55-
# type: (SparkContext) -> None
56-
from pyspark import SparkContext
57-
58-
_start_sentry_listener()
59-
_set_app_properties()
60-
52+
def _add_event_processor(sc):
53+
# type: (Any) -> None
6154
scope = sentry_sdk.get_isolation_scope()
6255

6356
@scope.add_event_processor
@@ -92,6 +85,15 @@ def process_event(event, hint):
9285
return event
9386

9487

88+
def _activate_integration(sc):
89+
# type: (SparkContext) -> None
90+
from pyspark import SparkContext
91+
92+
_start_sentry_listener(sc)
93+
_set_app_properties()
94+
_add_event_processor(sc)
95+
96+
9597
def _patch_spark_context_init():
9698
# type: () -> None
9799
from pyspark import SparkContext
@@ -114,7 +116,6 @@ def _setup_sentry_tracing():
114116

115117
if SparkContext._active_spark_context is not None:
116118
_activate_integration(SparkContext._active_spark_context)
117-
return
118119
_patch_spark_context_init()
119120

120121

0 commit comments

Comments
 (0)