⚠️ BACKUP DATA ANDA SECARA TERATUR! File manager ini untuk keperluan teknis.
Zy Filemanager
berang berang bawa gelek berangkat lek !!!
🌙 Dark Mode
🏠 Home Shell
🔄 Refresh
Current Path:
Home Shell
/
opt
/
hc_python
/
lib
/
python3.12
/
site-packages
/
sentry_sdk
/
integrations
/
spark
/
__pycache__
⬆️ Parent Directory
📁 File Browser
Name
Size
Permissions
Modified Date
Actions
📄
__init__.cpython-312.pyc
(396 bytes)
396 B
0644
📅
✏️
✍️
⬇️
🗑️
📄
spark_driver.cpython-312.pyc
(13,503 bytes)
13.19 KB
0644
📅
✏️
✍️
⬇️
🗑️
📄
spark_worker.cpython-312.pyc
(4,920 bytes)
4.8 KB
0644
📅
✏️
✍️
⬇️
🗑️
📤 Upload Files
Single File
Multiple Files
ZIP Extract
ZIP file will be deleted after extraction
➕ Create New
New Folder
New File
✍️ Editing: spark_driver.cpython-312.pyc
File: /opt/hc_python/lib/python3.12/site-packages/sentry_sdk/integrations/spark/__pycache__/spark_driver.cpython-312.pyc
Size: 13.19 KB | Last Modified: 2025-12-03 14:34:44
💾 Backup File
🔢 Toggle Line Numbers
� �/i% � �� � d dl Z d dlmZ d dlmZmZ d dlmZ erd dlmZ d dlm Z d dl mZmZ d dl mZ G d � d e� Zd� Zd� Zd � Zd� Zd� Zd� Z G d� d� Z G d� de� Zd� Zy)� N)�Integration)�capture_internal_exceptions�ensure_integration_enabled)� TYPE_CHECKING)�Any)�Optional)�Event�Hint��SparkContextc � � e Zd ZdZed� � Zy)�SparkIntegration�sparkc � � t � y �N)�_setup_sentry_tracing� � �Y/opt/hc_python/lib/python3.12/site-packages/sentry_sdk/integrations/spark/spark_driver.py� setup_oncezSparkIntegration.setup_once s � � �r N)�__name__� __module__�__qualname__� identifier�staticmethodr r r r r r s � ��J�� � � r r c � � ddl m} | j }|r9|j d|j � |j d|j � yy)z� Set properties in driver that propagate to worker processes, allowing for workers to have access to those properties. This allows worker integration to have access to app_name and application_id. r r �sentry_app_name�sentry_application_idN)�pysparkr �_active_spark_context�setLocalProperty�appName� applicationId)r � spark_contexts r �_set_app_propertiesr% sP � � %� �6�6�M���&�&���!�!� � �&�&�#��'�'� � r c � � ddl m} | j } ||� t � }| j j � j |� y)zA Start java gateway server to add custom `SparkListener` r )�ensure_callback_server_startedN)�pyspark.java_gatewayr'