o
    i3                     @   sP   d dl mZ d dlmZ d dlmZ d dlmZ ddlm	Z	 G dd deZ
d	S )
    )TraceProcessor)_BASE_SERVICE_KEY)in_aws_lambda)config   )schematize_service_namec                   @   s$   e Zd Zdd Zdd Zdd ZdS )BaseServiceProcessorc                 C   s    t tjpd | _t | _d S )N )r   r   servicelower_global_servicer   _in_aws_lambdaself r   U/home/ubuntu/.local/lib/python3.10/site-packages/ddtrace/internal/schema/processor.py__init__
   s   zBaseServiceProcessor.__init__c                    s:   |r j r|S t fdd|}tt fdd| |S )Nc                    s   | j o
| j   jkS N)r
   r   r   xr   r   r   <lambda>   s    z4BaseServiceProcessor.process_trace.<locals>.<lambda>c                    s
     | S r   )_update_dd_base_servicer   r   r   r   r      s   
 )r   filteranymap)r   tracetraces_to_processr   r   r   process_trace   s   

z"BaseServiceProcessor.process_tracec                 C   s   |j t| jd d S )N)keyvalue)_set_tag_strr   r   )r   spanr   r   r   r      s   z,BaseServiceProcessor._update_dd_base_serviceN)__name__
__module____qualname__r   r   r   r   r   r   r   r   	   s    r   N)ddtrace._trace.processorr   ddtrace.constantsr   ddtrace.internal.serverlessr   !ddtrace.internal.settings._configr   r	   r   r   r   r   r   r   <module>   s    