File: //proc/722141/root/lib/python3.6/site-packages/botocore/__pycache__/client.cpython-36.pyc
3
�T_*� � @ s| d dl Z d dlZd dlmZmZ d dlmZ d dlmZ d dl m
Z
d dl m Z d dl m
Z
d dlmZmZmZmZmZ d d lmZ d d
lmZ d d lmZ d d lmZm Z m Z m Z m Z m Z m!Z!m"Z" d dlmZ d d
lm#Z# d dl$m%Z% d dl&m'Z' d dl(m)Z)m*Z*m+Z+ d dl,m-Z- d dl,m.Z. e j/e0�Z1e'� Z2G dd� de3�Z4G dd� de3�Z5G dd� de3�Z6G dd� de3�Z7dd � Z8dS ) � N)�waiter�
xform_name)�ClientArgsCreator)�AUTH_TYPE_MAPS)�prepare_request_dict)�ClientMethodDocstring)�PaginatorDocstring)� ClientError�DataNotFoundError�OperationNotPageableError� UnknownSignatureVersionError�*InvalidEndpointDiscoveryConfigurationError)�first_non_none_response)� ServiceModel)� Paginator)�CachedProperty�get_service_module_name�S3RegionRedirector�S3ArnParamHandler�S3EndpointSetter�ensure_boolean�S3ControlArnParamHandler�S3ControlEndpointSetter)�UNSIGNED)�Config)�get_global_history_recorder)�EndpointDiscoveryHandler�EndpointDiscoveryManager�,block_endpoint_discovery_required_operations)�standard)�adaptivec @ s� e Zd ZdZd0dd�Zd1dd�Zd2dd �Zd
d � Zd3d d
�Zdd� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� ZdS )4�
ClientCreatorz%Creates client objects for a service.Nc
C s: || _ || _|| _|| _|| _|| _|| _|| _| | _d S )N) �_loader�_endpoint_resolver� _user_agent�_event_emitter�_retry_handler_factory�_retry_config_translator�_response_parser_factory�_exceptions_factory�
_config_store)
�self�loader�endpoint_resolver�
user_agent�
event_emitterZretry_handler_factoryZretry_config_translatorZresponse_parser_factory�exceptions_factory� config_store� r2 � /usr/lib/python3.6/client.py�__init__6 s zClientCreator.__init__Tc
C s� | j jd|d�}
t|
|d�}| j||�} | j|| �} t| j|| | jjd�d�}
| j | ||||||| |
� }| f |�}| j
|� | j ||
|| |� | j ||
|| |� | j
||| � |S )Nzchoose-service-name)� service_name)�defaultZ signingName)�service_signing_name)r% �emitr �_load_service_model�_create_client_class�ClientEndpointBridger# �metadata�get�_get_client_args�_register_retries�_register_s3_events�_register_s3_control_events� _register_endpoint_discovery)r+ r5 � region_name� is_secure� endpoint_url�verify� credentials�
scoped_config� api_version�
client_config� responses�
service_model�cls�endpoint_bridgeZ client_argsZservice_clientr2 r2 r3 �
create_clientH s,
zClientCreator.create_clientc C s | j ||�}| j||�S )N)r9 r: )r+ r5 rI rL r2 r2 r3 �create_client_classe s z!ClientCreator.create_client_classc C sb | j |�}| j|�}||d< tg}|jj� }| jjd| ||d� t|�}tt |�t
|�|�}|S )N�_PY_TO_OP_NAMEzcreating-client-class.%s)�class_attributesZ base_classes) �_create_methods�_create_name_mapping�
BaseClient�
service_id� hyphenizer% r8 r �type�str�tuple) r+ r5 rL rR Zpy_name_to_operation_name�basesrV �
class_namerM r2 r2 r3 r: i s
z"ClientCreator._create_client_classc C s" | j j|d|d�}t||d�}|S )Nz service-2)rI )r5 )r" �load_service_modelr )r+ r5 rI Z
json_modelrL r2 r2 r3 r9 w s
z!ClientCreator._load_service_modelc C sV |j jjd }|dkr"| j|� n0|dkr@| j|� | j|� n|dkrR| j|� d S )N�moder r �legacy)�meta�config�retries� _register_v2_standard_retries� _register_v2_adaptive_retries�_register_legacy_retries)r+ �client�
retry_moder2 r2 r3 r? } s
z ClientCreator._register_retriesc C s8 |j jjjd�}d|i}|d k r(||d< tjf |� d S )N�total_max_attemptsrf � max_attempts)r` ra rb r= r �register_retry_handler)r+ rf ri �kwargsr2 r2 r3 rc � s
z+ClientCreator._register_v2_standard_retriesc C s t j|� d S )N)r rj )r+ rf r2 r2 r3 rd � s z+ClientCreator._register_v2_adaptive_retriesc
C s� |j jj}|j jj}|j� }| jjd�}|s0d S | j|j jj �}| j
j ||j di �|j di �|�}t
jd|j jj� | jj||�}d| } |j jjd| || d� d S )NZ_retryZretryZ definitionsz*Registering retry handlers for service: %szretry-config-%szneeds-retry.%s)� unique_id)r` rL �endpoint_prefixrV rW r" Z load_data�_transform_legacy_retriesra rb r' Zbuild_retry_configr= �logger�debugr5 r& Zcreate_retry_handler�events�register)
r+ rf rm rV Zservice_event_nameZoriginal_configrb Z retry_config�handlerrl r2 r2 r3 re � s&
z&ClientCreator._register_legacy_retriesc C s: |d kr d S |j � }d|kr6|j � }|jd�d |d< |S )Nrh � ri )�copy�pop)r+ rb Z copied_argsr2 r2 r3 rn � s z'ClientCreator._transform_legacy_retriesc C s6 |j jj}|d k r(|jd�d k r(|d S |jd�p4dS )Nr^ rg r_ )r` ra rb r= �get_config_variable)r+ rf r1 Zclient_retriesr2 r2 r3 �_get_retry_mode� s
z ClientCreator._get_retry_modec
C s� |d k r d S |j jjd kr d S |j j}|j jjj� }d}|rN|jd k rN|j}n| jr`| jjd�}| j |�}|r�| j
||�r�|dk}t ||d�}t |�} | j
||� n |j
dt� d S )NF�endpoint_discovery_enabledT)Zalways_discoverzbefore-parameter-build)r` rL Z endpoint_discovery_operationrq rV rW ry r* rw �$_normalize_endpoint_discovery_config� _requires_endpoint_discoveryr r rr r )
r+ rf rE ra rq rV �enabledZdiscoverZmanagerrs r2 r2 r3 rB � s(
z*ClientCreator._register_endpoint_discoveryc C sP t |t�r4|j� j� }|dkr"|S |dkrBt|�S nt |t�rB|S t|d��dS )z?Config must either be a boolean-string or string-literal 'auto'�auto�true�false)Z config_valueN)r~ r )�
isinstancerY �lower�stripr �boolr
)r+ r| r2 r2 r3 rz � s
z2ClientCreator._normalize_endpoint_discovery_configc C s |dkr|j jjS |S )Nr} )r` rL Zendpoint_discovery_required)r+ rf r| r2 r2 r3 r{ � s
z*ClientCreator._requires_endpoint_discoveryc C sp |j jjdkrd S t||�j� t� j|j j� t| j|j j |j j
j ||j j d�j|j j� | j
|j ||� d S )N�s3)r- �region� s3_configrE � partition)r` rL r5 r rr r rq r r# rC ra r� r� �!_set_s3_presign_signature_version)r+ rf rN rE rJ rH r2 r2 r3 r@ � s
z!ClientCreator._register_s3_eventsc C sR |j jjdkrd S t� j|j j� t| j|j j|j j j
||j j d�j|j j� d S )NZ s3control)r- r� r� rE r� ) r` rL r5 r rr rq r r# rC ra r� r� )r+ rf rN rE rJ rH r2 r2 r3 rA � s z)ClientCreator._register_s3_control_eventsc C sx t d||�}|d k rd S | jjd|j�}|jdkr@|j|kr@d S | jjd|j�}|d }d|krdd S |jjd| j� d S )Nr� z
aws-global�signatureVersionszchoose-signer.s3) �!_get_configured_signature_versionr# Zget_available_endpointsr� rC �construct_endpointrq rr � _default_s3_presign_to_sigv2)r+ Z client_metarJ rH Zprovided_signature_versionZregions�endpointZsignature_versionsr2 r2 r3 r� s
z/ClientCreator._set_s3_presign_signature_versionc K s$ x dD ]}|j |�rd| S qW dS )a�
Returns the 's3' (sigv2) signer if presigning an s3 request. This is
intended to be used to set the default signature version for the signer
to sigv2.
:type signature_version: str
:param signature_version: The current client signature version.
:type signing_name: str
:param signing_name: The signing name of the service.
:return: 's3' if the request is an s3 presign request, None otherwise
�-query�
-presign-postr� N)r� r� )�endswith)r+ �signature_versionrk �suffixr2 r2 r3 r� - s
z*ClientCreator._default_s3_presign_to_sigv2c
C s: t | j| j| j| j| j| jd�}
|
j||||||||| � S )N)r1 )r r% r$ r( r" r) r* Zget_client_args) r+ rL rC rD rE rF rG rH rJ rN Z args_creatorr2 r2 r3 r> ? s z ClientCreator._get_client_argsc C s2 i }x(|j D ] }t|�}| j|||�||< q W |S )N)�operation_namesr �_create_api_method)r+ rL Zop_dict�operation_name�py_operation_namer2 r2 r3 rS J s z ClientCreator._create_methodsc C s( i }x |j D ]}t|�}|||< q W |S )N)r� r )r+ rL �mappingr� r� r2 r2 r3 rT R s
z"ClientCreator._create_name_mappingc sH � �fdd�}t ��|_|j� �}t|� | j|jd� dd�}||_|S )Nc s |rt d� ��| j� |�S )Nz$%s() only accepts keyword arguments.)� TypeError�_make_api_call)r+ �argsrk )r� r� r2 r3 � _api_call] s
z3ClientCreator._create_api_method.<locals>._api_callzresponse = client.%sF)�operation_modelZ method_namer/ Zmethod_descriptionZexample_prefix�include_signature)rY �__name__r� r r% Z
documentation�__doc__)r+ r� r� rL r� r� Z docstringr2 )r� r� r3 r� [ s
z ClientCreator._create_api_method)NNN)TNNNNNN)N)N)r� �
__module__� __qualname__r� r4 rO rP r: r9 r? rc rd re rn rx rB rz r{ r@ rA r� r� r> rS rT r� r2 r2 r2 r3 r! 4 s8
$ r! c @ s� e Zd ZdZdZddgZd dd�Zd d d
�Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd d � ZdS )!r; a� Bridges endpoint data and client creation
This class handles taking out the relevant arguments from the endpoint
resolver and determining which values to use, taking into account any
client configuration options and scope configuration options.
This class also handles determining what, if any, region to use if no
explicit region setting is provided. For example, Amazon S3 client will
utilize "us-east-1" by default if no region can be resolved.z {service}.{region}.amazonaws.comr� z
s3-controlNc C s( || _ || _|| _|| _|p | j| _d S )N)r7 r- rH rJ �DEFAULT_ENDPOINT�default_endpoint)r+ r- rH rJ r� r7 r2 r2 r3 r4 � s
z ClientEndpointBridge.__init__Tc C sZ | j ||�}| jj||�}|s0| jj||dd�}|rF| j|||||�S | j||||�S d S )NZaws)Zpartition_name)�_check_default_regionr- r� �_create_endpoint�_assume_endpoint)r+ r5 rC rE rD �resolvedr2 r2 r3 �resolve� s z ClientEndpointBridge.resolvec C s* |d k r |S | j r&| j jd k r&| j jS d S )N)rJ rC )r+ r5 rC r2 r2 r3 r� � s z*ClientEndpointBridge._check_default_regionc C s� |d k }| j |||�\}}|d krl| j|�rD| j|||d ||�}n(|jd|jd��}| j|||jdg ��}| j||�} | j||�}
| j||||
||| d�S )NZ dnsSuffixZ
sslCommonName�hostnameZ protocols)r5 rC �signing_region� signing_namerE r< r� )�_pick_region_values�_is_s3_dualstack_mode�_create_dualstack_endpointr= � _make_url�_resolve_signature_version�_resolve_signing_name�_create_result) r+ r� r5 rC rE rD �explicit_regionr� r� r� r� r2 r2 r3 r� � s&
z%ClientEndpointBridge._create_endpointc C sn || j krdS | j}|d k r:|jd k r:d|jkr:|jd S | jd krHdS | jjdi �jdd�}|dkrjdS dS )NFZuse_dualstack_endpointr� T�Truer~ )Tr� r~ )�_DUALSTACK_ENABLED_SERVICESrJ r� rH r= )r+ r5 rJ r| r2 r2 r3 r� � s
z*ClientEndpointBridge._is_s3_dualstack_modec C s4 | r|dkrd}dj |||d�}| j||ddg�S )Nz
aws-globalz us-east-1z){service}.dualstack.{region}.{dns_suffix})�servicer� �
dns_suffix�http�https)�formatr� )r+ r5 rC r� rD r� r� r2 r2 r3 r� � s z/ClientEndpointBridge._create_dualstack_endpointc C sr |d kr*| j j||d�}| j||ddg�}tjd|||� | j|ddgi�}| j|i d�}| j||||||i d�S ) N)r� r� r� r� z#Assuming an endpoint for %s, %s: %sr� �v4)r� )r5 rC r� r� r� rE r< )r� r� r� ro rp r� r� r� )r+ r5 rC rE rD r� r� r� r2 r2 r3 r� � s
z%ClientEndpointBridge._assume_endpointc C s |||||||d�S )N)r5 rC r� r� rE r� r< r2 )r+ r5 rC r� r� rE r� r< r2 r2 r3 r� � s z#ClientEndpointBridge._create_resultc C s" |rd|krd}nd}d||f S )Nr� r� z%s://%sr2 )r+ r� rD Zsupported_protocols�schemer2 r2 r3 r� s z ClientEndpointBridge._make_urlc C s0 d|kr d|d kr |d d S | j r,| j S |S )N�credentialScoper� )r7 )r+ r5 r� r2 r2 r3 r� s z*ClientEndpointBridge._resolve_signing_namec C s@ |}|d kr8|d }|}d|kr8d|d kr8|d d }||fS )NZ endpointNamer� r� r2 )r+ r� rC rE r� r2 r2 r3 r� s z(ClientEndpointBridge._pick_region_valuesc C sr t || j| j�}|d k r |S d|kr^|d }|dkr8dS d|krDdS x|D ]}|tkrJ|S qJW t|jd�d��d S )Nr� r� Zs3v4r� )r� )r� rJ rH r r r= )r+ r5 r� Zconfigured_versionZpotential_versionsZknownr2 r2 r3 r� + s
z/ClientEndpointBridge._resolve_signature_version)NNNN)NNT)r� r� r� r� r� r� r4 r� r� r� r� r� r� r� r� r� r� r� r2 r2 r2 r3 r; w s$
r; c @ s� e Zd Zi Zdd� Zdd� Zdd� Zedd� �Zd d
� Z d d � Z
d dd�Z dd� Z dd� Z
dd� Zdd� Zdd� Zedd� �Zed d � �Zd d � Zd
S )!rU c C s\ || _ || _|| _|| _i | _|| _|| _t|| j|j|| j | �| _
|
| _ d | _ | j
� d S )N)� _serializer� _endpointZ_response_parser�_request_signer�_cacher" �_client_config�
ClientMeta�hostrQ r` r) � _exceptions�_register_handlers) r+ Z
serializerr� Zresponse_parserr/ �request_signerrL r, rJ r� r0 r2 r2 r3 r4 K s zBaseClient.__init__c C sN d| j jj� |f }| jjj|| d�\}}|d k r6|S td| jj|f ��d S )Nz
getattr.%s.%s)rf z!'%s' object has no attribute '%s') �_service_modelrV rW r` rq �emit_until_response�AttributeError� __class__r� )r+ �item�
event_namers �event_responser2 r2 r3 � __getattr__\ s zBaseClient.__getattr__c C s* | j jjj� }| j jjd| | jj� d S )Nzrequest-created.%s)r` rL rV rW rq rr r� rs )r+ rV r2 r2 r3 r� k s z BaseClient._register_handlersc C s | j jS )N)r` rL )r+ r2 r2 r3 r� s s zBaseClient._service_modelc C s | j j|�}| j j}tjd|||d�� |jr<tjd||� | jj | jj
|j |j d�}| j
|||d�}| j jj� }| jjjdj||d�||| j|d�\}} | d k r�| \}
} n| j|||�\}
} | jjjd j||d�|
| ||d
� |
jd k�r| jd i �jd
�} | jj| �}
|
| |��n| S d S )NZAPI_CALL)r� Z operation�paramsz Warning: %s.%s() is deprecated)Z
client_regionrJ �has_streaming_input� auth_type)�contextz)before-call.{service_id}.{operation_name})rV r� )�modelr� r� r� z(after-call.{service_id}.{operation_name})Z
http_responseZparsedr� r� i, �ErrorZCode)r� r� r5 �history_recorder�recordZ
deprecatedro rp r` rC ra r� r� �_convert_to_request_dictrV rW rq r� r� r� �
_make_requestr8 Z status_coder= �
exceptionsZ from_code)r+ r� �
api_paramsr� r5 �request_context� request_dictrV rs r� r� Zparsed_responseZ
error_codeZ error_classr2 r2 r3 r� w sJ
zBaseClient._make_api_callc C s` y| j j||�S tk
rZ } z0| jjjdj| jjj � |j
d�||d� � W Y d d }~X nX d S )Nz.after-call-error.{service_id}.{operation_name})rV r� )Z exceptionr� ) r� Z make_request� Exceptionr` rq r8 r� r� rV rW �name)r+ r� r� r� �er2 r2 r3 r� � s
zBaseClient._make_requestNc C sL | j |||�}| jj||�}| jjs0|jdd � t|| jj| jj |d� |S )NZ host_prefix)rE r. r� )
�_emit_api_paramsr� Zserialize_to_requestr� Zinject_host_prefixrv r r� r� r. )r+ r� r� r� r� r2 r2 r3 r� � s
z#BaseClient._convert_to_request_dictc C sf |j }| jjj� }| jjjdj||d�|||d�}t||d�}d}| jjj|j||d�|||d� |S )Nz3provide-client-params.{service_id}.{operation_name})rV r� )r� r� r� )r6 z4before-parameter-build.{service_id}.{operation_name}) r� r� rV rW r` rq r8 r� r )r+ r� r� r� r� rV rK r� r2 r2 r3 r� � s zBaseClient._emit_api_paramsc C s� | j |�st|d��n�| j| }dd� }| jd | }t|| jj| jj|dd�|_t dt
| jj�|f �}t |t fd|i�}| j
j|�}|t| |�||�}|S d S )
a Create a paginator for an operation.
:type operation_name: string
:param operation_name: The operation name. This is the same name
as the method name on the client. For example, if the
method name is ``create_foo``, and you'd normally invoke the
operation as ``client.create_foo(**kwargs)``, if the
``create_foo`` operation can be paginated, you can use the
call ``client.get_paginator("create_foo")``.
:raise OperationNotPageableError: Raised if the operation is not
pageable. You can use the ``client.can_paginate`` method to
check if an operation is pageable.
:rtype: L{botocore.paginate.Paginator}
:return: A paginator object.
)r� c [ s t j| f|�S )N)r �paginate)r+ rk r2 r2 r3 r� � s z*BaseClient.get_paginator.<locals>.paginate� page_configF)Zpaginator_namer/ rL �paginator_configr� z%s.Paginator.%sr� N)� can_paginater rQ r� r r` rq rL r� rY r rX r r� r� �getattr) r+ r� �actual_operation_namer� r� Zpaginator_class_nameZdocumented_paginator_clsr� Z paginatorr2 r2 r3 �
get_paginator� s.
zBaseClient.get_paginatorc C sl d| j krTy*| jj| jjd| jj�d }|| j d< W n tk
rR i | j d< Y nX | j| }|| j d kS )aM Check if an operation can be paginated.
:type operation_name: string
:param operation_name: The operation name. This is the same name
as the method name on the client. For example, if the
method name is ``create_foo``, and you'd normally invoke the
operation as ``client.create_foo(**kwargs)``, if the
``create_foo`` operation can be paginated, you can use the
call ``client.get_paginator("create_foo")``.
:return: ``True`` if the operation can be paginated,
``False`` otherwise.
r� z paginators-1Z
pagination)r� r" r] r� r5 rI r
rQ )r+ r� r� r� r2 r2 r3 r� s
zBaseClient.can_paginatec C sZ d| j krPy&| jj| jjd| jj�}|| j d< W n tk
rN i | j d< Y nX | j d S )N�
waiter_configz waiters-2)r� r" r] r� r5 rI r
)r+ r� r2 r2 r3 �_get_waiter_config. s
z BaseClient._get_waiter_configc C sh | j � }|std| ��tj|�}i }x|jD ]}||t|�< q.W ||krVtd| ��tj|| || �S )aG Returns an object that can wait for some condition.
:type waiter_name: str
:param waiter_name: The name of the waiter to get. See the waiters
section of the service docs for a list of available waiters.
:returns: The specified waiter object.
:rtype: botocore.waiter.Waiter
zWaiter does not exist: %s)r� �
ValueErrorr � WaiterModel� waiter_namesr Zcreate_waiter_with_client)r+ Z waiter_namera r� r� r� r2 r2 r3 �
get_waiter: s
zBaseClient.get_waiterc C s* | j � }|sg S tj|�}dd� |jD �S )z(Returns a list of all available waiters.c S s g | ] }t |��qS r2 )r )�.0r� r2 r2 r3 �
<listcomp>Z s z+BaseClient.waiter_names.<locals>.<listcomp>)r� r r� r� )r+ ra r� r2 r2 r3 r� Q s
zBaseClient.waiter_namesc C s | j d kr| j� | _ | j S )N)r� �_load_exceptions)r+ r2 r2 r3 r� \ s
zBaseClient.exceptionsc C s | j j| j�S )N)r) Zcreate_client_exceptionsr� )r+ r2 r2 r3 r� b s zBaseClient._load_exceptions)N)r� r� r� rQ r4 r� r� �propertyr� r� r� r� r� r� r� r� r� r r� r� r� r2 r2 r2 r3 rU A s 1
9 rU c @ s` e Zd ZdZdd� Zedd� �Zedd� �Zedd � �Zed
d � �Z ed d
� �Z
edd� �Z dS )r� a~ Holds additional client methods.
This class holds additional information for clients. It exists for
two reasons:
* To give advanced functionality to clients
* To namespace additional client attributes from the operation
names which are mapped to methods at runtime. This avoids
ever running into collisions with operation names.
c C s( || _ || _|| _|| _|| _|| _d S )N)rq r� �
_endpoint_urlr� �_method_to_api_mapping�
_partition)r+ rq rJ rE rL �method_to_api_mappingr� r2 r2 r3 r4 t s zClientMeta.__init__c C s | j S )N)r� )r+ r2 r2 r3 rL } s zClientMeta.service_modelc C s | j jS )N)r� rC )r+ r2 r2 r3 rC � s zClientMeta.region_namec C s | j S )N)r� )r+ r2 r2 r3 rE � s zClientMeta.endpoint_urlc C s | j S )N)r� )r+ r2 r2 r3 ra � s zClientMeta.configc C s | j S )N)r� )r+ r2 r2 r3 r� � s z ClientMeta.method_to_api_mappingc C s | j S )N)r� )r+ r2 r2 r3 r� � s zClientMeta.partitionN) r� r� r� r� r4 r� rL rC rE ra r� r� r2 r2 r2 r3 r� g s r� c C s\ |r|j dk r|j S |dk rX|j| �}|dk rXt|t�rX|jd�}|rXtjd| |� |S dS )z�
Gets the manually configured signature version.
:returns: the customer configured signature version, or None if no
signature version was configured.
Nr� zWSwitching signature version for service %s to version %s based on config file override.)r� r= r� �dictro rp )r5 rJ rH Zservice_config�versionr2 r2 r3 r� � s
r� )9Zlogging� functoolsZbotocorer r Z
botocore.argsr Z
botocore.authr Zbotocore.awsrequestr Zbotocore.docs.docstringr r Zbotocore.exceptionsr r
r r r
Zbotocore.hooksr Zbotocore.modelr Zbotocore.paginater Zbotocore.utilsr r r r r r r r r Zbotocore.configr Zbotocore.historyr Zbotocore.discoveryr r r Zbotocore.retriesr r Z getLoggerr� ro r� �objectr! r; rU r� r� r2 r2 r2 r3 �<module>
s> (
E K (/