Ë
    S>{iž  ã                   ó¼   — d dl mZ d dlZd dlmZ d dlmZ d dlmZ d dl	m
Z
mZmZmZmZ d dlmZ erd dlmZ d d	lmZ d d
lmZmZmZ  G d„ de«      Zd„ Zd„ Zd„ Zy)é    )Úabsolute_importN)Úconfigure_scope)ÚHub)ÚIntegration)Úcapture_internal_exceptionsÚexc_info_from_errorÚ!single_exception_from_error_tupleÚwalk_exception_chainÚevent_hint_with_exc_info)ÚTYPE_CHECKING)ÚAny)ÚOptional)ÚExcInfoÚEventÚHintc                   ó    — e Zd ZdZed„ «       Zy)ÚSparkWorkerIntegrationÚspark_workerc                  ó&   — dd l m}  t        | _        y ©Nr   )Úpyspark.daemonÚdaemonÚ_sentry_worker_mainÚworker_main)Úoriginal_daemons    úh/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/sentry_sdk/integrations/spark/spark_worker.pyÚ
setup_oncez!SparkWorkerIntegration.setup_once   s   € õ 	1ä&9ˆÕ#ó    N)Ú__name__Ú
__module__Ú__qualname__Ú
identifierÚstaticmethodr   © r   r   r   r      s   „ Ø€Jàñ:ó ñ:r   r   c           
      ót  — |j                   }|j                  }dddœ}t        | «      } | \  }}}g }t        | «      D ]8  \  }}}|t        t
        t        fvsŒ|j                  t        |||||«      «       Œ: |r@|j                  «        t        | «      }	dd|idœ}
t        «        |j                  |
|	¬«       y y )NÚsparkF)ÚtypeÚhandledÚerrorÚvalues)ÚlevelÚ	exception)Úhint)ÚclientÚoptionsr   r
   Ú
SystemExitÚEOFErrorÚConnectionResetErrorÚappendr	   Úreverser   Ú_tag_task_contextÚcapture_event)Úexc_infoÚhubr.   Úclient_optionsÚ	mechanismÚexc_typeÚ	exc_valueÚtbÚrvr-   Úevents              r   Ú_capture_exceptionr@   $   sÉ   € à�Z‰Z€Fà—^‘^€Nà ¨UÑ3€Iä" 8Ó,€Hà&Ñ€Hˆi˜Ø	€Bô $8¸Ó#Aò Ñˆ�)˜RØœJ¬Ô2FÐGÒGØ�I‰IÜ1Ø˜i¨¨^¸Yóõðñ 
Ø
�
‰
ŒÜ'¨Ó1ˆØ!°¸2°Ñ?ˆäÔà×Ñ˜% dÐÕ+ð 
r   c                  óx   ‡— ddl mŠ t        «       5 } | j                  ˆfd„«       }d d d «       y # 1 sw Y   y xY w)Nr   )ÚTaskContextc                 ó|  •— t        «       5  t        j                  j                  t        «      }‰j                  «       }|�|€| cd d d «       S | j                  di «      j                  dt        |j                  «       «      «       | d   j                  dt        |j                  «       «      «       | d   j                  dt        |j                  «       «      «       | d   j                  dt        |j                  «       «      «       |j                  r�d|j                  v rD| d   j                  d|j                  d   «       | d   j                  d|j                  d	   «       d
|j                  v r/| j                  di «      j                  d|j                  d
   «       d d d «       | S # 1 sw Y   | S xY w)NÚtagsÚstageIdÚpartitionIdÚattemptNumberÚtaskAttemptIdÚsentry_app_nameÚapp_nameÚapplication_idÚsentry_application_idzcallSite.shortÚextraÚcallSite)r   r   ÚcurrentÚget_integrationr   ÚgetÚ
setdefaultÚstrrE   rF   rG   rH   Ú_localProperties)r?   r-   ÚintegrationÚtask_contextrB   s       €r   Úprocess_eventz(_tag_task_context.<locals>.process_eventJ   s£  ø€ ô -Ó.ñ Ü!Ÿk™k×9Ñ9Ô:PÓQ�Ø*Ÿ™Ó0�àÐ&¨,Ð*>Ø ÷ñ ð × Ñ  ¨Ó,×7Ñ7Øœs <×#7Ñ#7Ó#9Ó:ôð �f‘×(Ñ(¨¼¸L×<TÑ<TÓ<VÓ8WÔXØ�f‘×(Ñ(Ø#¤S¨×)CÑ)CÓ)EÓ%Fôð �f‘×(Ñ(Ø#¤S¨×)CÑ)CÓ)EÓ%Fôð  ×0Ò0Ø(¨L×,IÑ,IÑIØ˜f™×0Ñ0Ø&¨×(EÑ(EÐFWÑ(Xôð ˜f™×0Ñ0Ø,Ø(×9Ñ9Ð:QÑRôð
 (¨<×+HÑ+HÑHØ×(Ñ(¨°"Ó5×@Ñ@Ø&¨×(EÑ(EÐFVÑ(Wô÷;ðB ˆL÷CðB ˆLús   Œ9F1ÁEF1Æ1F;)Úpyspark.taskcontextrB   r   Úadd_event_processor)ÚscoperW   rB   s     @r   r5   r5   D   s;   ø€ å/ä	Ó	ð &˜eà	×	"Ñ	"ó#	ó 
#ð#	÷&÷ &ñ &ús   ’0°9c                  ó>  — dd l m} 	  |j                  | i |¤Ž y # t        $ rx t        j
                  j                  t        «      �Rt        j
                  }t        j                  «       }t        «       5  t        ||«       d d d «       Y y # 1 sw Y   Y y xY wY y w xY wr   )Úpyspark.workerÚworkerÚmainr0   r   rO   rP   r   Úsysr7   r   r@   )ÚargsÚkwargsÚoriginal_workerr8   r7   s        r   r   r   q   sƒ   € å,ð2Øˆ×Ñ˜dÐ- fÓ-øÜò 2Ü�;‰;×&Ñ&Ô'=Ó>ÐJÜ—+‘+ˆCÜ—|‘|“~ˆHÜ,Ó.ñ 2Ü" 8¨SÔ1÷2÷ 2ó 2úñ Kð2ús.   ˆ ›ABÁ5BÂBÂB	ÂBÂBÂB)Ú
__future__r   r_   Ú
sentry_sdkr   Úsentry_sdk.hubr   Úsentry_sdk.integrationsr   Úsentry_sdk.utilsr   r   r	   r
   r   Úsentry_sdk._typesr   Útypingr   r   r   r   r   r   r@   r5   r   r$   r   r   ú<module>rj      sO   ðÝ &ã 
å &Ý Ý /÷õ õ ,áÝÝç6Ñ6ô:˜[ô :ò,ò@*óZ2r   