Skip to content

Commit c217f31

Browse files
committed
.
1 parent a2fc2ec commit c217f31

File tree

1 file changed

+1
-6
lines changed

1 file changed

+1
-6
lines changed

sentry_sdk/integrations/spark/spark_driver.py

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -296,7 +296,7 @@ def onStageCompleted(self, stageCompleted): # noqa: N802,N803
296296

297297
def _get_attempt_id(stage_info):
298298
# type: (Any) -> Optional[int]
299-
from py4j.protocol import Py4JJavaError # type: ignore
299+
from py4j.protocol import Py4JJavaError
300300

301301
try:
302302
return stage_info.attemptId()
@@ -308,9 +308,4 @@ def _get_attempt_id(stage_info):
308308
except Py4JJavaError:
309309
pass
310310

311-
try:
312-
return stage_info.currentAttemptId()
313-
except Py4JJavaError:
314-
pass
315-
316311
return None

0 commit comments

Comments
 (0)