File: //lib/python3/dist-packages/compose/__pycache__/service.cpython-310.pyc
o
S �`� � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z d dlm
Z
d dl m Z d dl
mZ d dl
mZ d dl
mZ d dlmZ d d lmZ d d
lmZ d d lmZ d d lmZ d d
lmZ d dlmZ ddl m Z ddl m Z ddl m Z ddl m!Z! ddl m"Z" ddl m#Z# ddl m$Z$ ddl%m&Z& ddl'm(Z( ddl'm)Z) ddl'm*Z* ddl m+Z+ dd l m,Z, dd l m-Z- dd l m.Z. dd l m/Z/ dd l m0Z0 dd!l m1Z1 dd"l m2Z2 dd#l m3Z3 dd$l m4Z4 dd%l m5Z5 dd&l6m7Z7 dd'l8m9Z9 dd(l8m:Z: dd)l8m;Z; dd*l8m<Z< dd+l=m>Z> dd,l m?Z? dd-l m@Z@ dd.lAmBZB dd/lAmCZC dd0lAmDZD dd1lAmEZE dd2lAmFZF dd3lAmGZG d d4lHmIZI e�JeK�ZLg d5�ZMd6ZNd7ZOd8ZPG d9d:� d:eQ�ZRG d;d<� d<eQ�ZSG d=d>� d>eQ�ZTe d?d@�ZUe dAdB�ZVe jWG dCdD� dDe jX��ZYe jWG dEdF� dFe jX��ZZe jWG dGdH� dHe jX��Z[G dIdJ� dJ�Z\dKdL� Z]G dMdN� dN�Z^G dOdP� dPe^�Z_G dQdR� dRe^�Z`G dSdT� dT�ZaG dUdV� dVea�ZbG dWdX� dXea�ZcG dYdZ� dZ�ZdG d[d\� d\�ZeG d]d^� d^�Zfd�d_d`�Zgdadb� Zhdcdd� Zidedf� Zjdgdh� Zkdidj� Zldkdl� Zmdmdn� Zndodp� Zodqdr� Zpdsdt� Zqdudv� Zrdwdx� Zsdydz� Ztd{d|� Zud}d~� ZvG dd�� d��ZwG d�d�� d��ZxG d�d�� d��ZydS )�� N)�
namedtuple)� OrderedDict)�
attrgetter)�APIError)�
ImageNotFound)�NotFound)� LogConfig)�Mount)� version_gte)�
version_lt)�build_port_bindings)�
split_port)�convert_tmpfs_mounts� )� __version__)�const)�progress_stream)�DOCKER_CONFIG_KEYS)�is_url)�merge_environment)� merge_labels)�DependencyError)� MountSpec)� ServicePort)�
VolumeSpec)�DEFAULT_TIMEOUT)�IS_WINDOWS_PLATFORM)�LABEL_CONFIG_HASH)�LABEL_CONTAINER_NUMBER)�
LABEL_ONE_OFF)�
LABEL_PROJECT)�
LABEL_SERVICE)�
LABEL_SLUG)�
LABEL_VERSION)�NANOCPUS_SCALE)�WINDOWS_LONGPATH_PREFIX)� Container)�CompletedUnsuccessfully)�HealthCheckFailed)�NoHealthCheckConfigured)�OperationFailedError��parallel_execute)�
stream_output)�StreamOutputError)�generate_random_id)� json_hash)� parse_bytes)�parse_seconds_float)� truncate_id)�unique_everseen)�binarystr_to_unicode)-�cap_add�cap_drop�
cgroup_parent� cpu_count� cpu_percent�
cpu_period� cpu_quota�
cpu_rt_period�cpu_rt_runtime�
cpu_shares�cpus�cpuset�device_cgroup_rules�devices�device_requests�dns�
dns_search�dns_opt�env_file� extra_hosts� group_add�init�ipc� isolation� read_only�
log_driver�log_opt� mem_limit�mem_reservation�
memswap_limit�mem_swappiness�oom_kill_disable�
oom_score_adj�pid�
pids_limit�
privileged�restart�runtime� security_opt�shm_size� storage_opt�sysctls� userns_mode� volumes_from�
volume_driver�service_started�service_healthy� service_completed_successfullyc @ � e Zd Zdd� ZdS )�
BuildErrorc C s || _ || _d S �N)�service�reason)�selfri rj � rl �1/usr/lib/python3/dist-packages/compose/service.py�__init__w s
zBuildError.__init__N��__name__�
__module__� __qualname__rn rl rl rl rm rg v � rg c @ rf )�NeedsBuildErrorc C �
|| _ d S rh �ri �rk ri rl rl rm rn } �
zNeedsBuildError.__init__Nro rl rl rl rm rt | rs rt c @ s e Zd ZdS )�NoSuchImageErrorN)rp rq rr rl rl rl rm ry � s ry � ServiceNamezproject service number�ConvergencePlanzaction containersc @ s( e Zd ZdZdZdZdZedd� �ZdS )�ConvergenceStrategyzrEnumeration for all possible convergence strategies. Values refer to
when containers should be recreated.
r � � c C s | t | �juS rh )�type�never�rk rl rl rm �allows_recreate� s z#ConvergenceStrategy.allows_recreateN) rp rq rr �__doc__�changed�alwaysr� �propertyr� rl rl rl rm r| � s r| c @ � e Zd ZdZdZdZdZdS )� ImageTypez5Enumeration for the types of images known to compose.r r r} N)rp rq rr r� �none�local�allrl rl rl rm r� � �
r� c @ r� )� BuildActionz+Enumeration for the possible build actions.r r r} N)rp rq rr r� r� �force�skiprl rl rl rm r� � r� r� c @ s| e Zd Z d�dd�Zdd� Zd�d d
�Zd�d d �Zd
d� Zdd� Zd�dd�Z d�dd�Z
e j ddfdd�Z
dd� Zdd� Zedd � �Zed d � �Zejdfd d �Zd!d"� Zd�d#d$�Zd%d&� Zd'd(� Zd�d)d*�Z d�d,d-�Z + d�d.d/�Z d0d1� Z d�d2d3�Z d�d4d5�Z ed6d7� �Z d�d8d9�Z!d�d:d;�Z"d<d=� Z#ed>d?� �Z$d@dA� Z%dBdC� Z&dDdE� Z'dFdG� Z(dHdI� Z)dJdK� Z*d�dLdM�Z+dNdO� Z,d�dPdQ�Z-dRdS� Z.dTdU� Z/dVdW� Z0 d�dXdY�Z1dZd[� Z2d�d\d]�Z3d^d_� Z4 d�d`da�Z5dbdc� Z6ddde� Z7d�dfdg�Z8edhdi� �Z9d�djdk�Z:dldm� Z;dndo� Z<dpdq� Z=d�drds�Z>d�dtdu�Z?dvdw� Z@dxdy� ZAdzd{� ZBd|d}� ZCd~d� ZDdS )��ServiceN�defaultFr c K s� || _ || _|| _|| _|pg | _|pg | _| ptd �| _|p"td �| _ | p)t
d �| _ |p.i | _ | p3g | _
|
| _|
| _|| _|pAg | _d S rh )�name�client�project�use_networking�linksra �IpcMode�ipc_mode� NetworkMode� network_mode�PidMode�pid_mode�networks�secrets� scale_num�default_platform�options� extra_labels)rk r� r� r� r� r� ra r� r� r� �scaler� r� r� r� r� rl rl rm rn � s
zService.__init__c C s d� | j�S )Nz
<Service: {}>)�formatr� r� rl rl rm �__repr__� s zService.__repr__c
s� |d u ri }|� d� j|d�|pg i� ttd � fdd�� jj||d�D ���}|r-|S |� d� j|dd�|p9g i� tt� fdd �td � fd
d�� jj||d�D ����S ) N�label��one_offc � g | ] }t �� j|��qS rl �r& �from_psr� ��.0� containerr� rl rm �
<listcomp>� � ��z&Service.containers.<locals>.<listcomp>�r� �filtersT�r� �legacyc s | � � j�S rh )�has_legacy_proj_namer� ��cr� rl rm �<lambda>� � z$Service.containers.<locals>.<lambda>c r� rl r� r� r� rl rm r� � r� )�update�labels�list�filterr� �
containers)rk �stoppedr� r� r� �resultrl r� rm r� � s, �
� ����zService.containersc C s4 | j d�t|�gd�D ]}| S td�| j|���)z�Return a :class:`compose.container.Container` for this service. The
container must be active, and match `number`.
�{}={})r� z No container found for {}_{})r� r� r �
ValueErrorr� )rk �numberr� rl rl rm �
get_container� s zService.get_containerc K s, | j dd�}|D ] }| j|fi |�� q|S )NT�r� )r� �start_container_if_stopped)rk r� r� r� rl rl rm �start� s z
Service.startc C sP | j r|dkrt�d| j| j f � | �� r$|dkr&t�d| j � d S d S d S )Nr z�The "%s" service is using the custom container name "%s". Docker requires each container to have a unique name. Remove the custom name to scale the service.z�The "%s" service specifies a port on the host. If multiple containers for this service are created on a single host, the port will clash.)�custom_container_name�log�warningr� �specifies_host_port)rk � desired_numrl rl rm �show_scale_warnings� s
�
��zService.show_scale_warningsc s2 � � |� � jdd�}t|�}|D ]}|�� j�sqt�d|j � � j||dd� q||kr6t�d� dS ||krz� jdd�}|t|�kridd � |D �}� fd
d �|D �}|D ]}|� � qXt
t |�t |� �}t |t
d �d �} � �| ||dd� ||k r�|| }
t |t
d �d �} � �| |
d� |� dS dS )
ar
Adjusts the number of containers to the specified number and ensures
they are running.
- creates containers until there are at least `desired_num`
- stops containers until there are at most `desired_num` running
- starts containers until there are at least `desired_num` running
- removes all stopped containers
Fr� z(Recreating container with legacy name %s)�start_new_containerz)Desired container number already achievedNTc S � g | ]}|j s|�qS rl ��
is_running�r� r� rl rl rm r� ! s
��z!Service.scale.<locals>.<listcomp>c s g | ]
}� � |g�r|�qS rl )�_containers_have_divergedr� r� rl rm r� & s
��r� ��key)r� r� �lenr� r� r� �infor� �recreate_container�remover� �set�sortedr �_execute_convergence_start�
_downscale) rk r� �timeout�running_containers� num_runningr� �all_containers�stopped_containers�divergent_containers�sorted_containers� num_to_stop�sorted_running_containersrl r� rm r� sF
�
�
���z
Service.scalec
K s� | � � | j||p| j|d�||d�}d|v r"|s"t�d|d � z tj| jfi |��W S tyE } z t d| j
t |j �f ��d}~ww )zn
Create a container for this service. If the image doesn't exist, attempt to pull
it.
r� )r� �previous_containerr� z Creating %sz*Cannot create container for service %s: %sN)
�ensure_image_exists� _get_container_create_options�_next_container_numberr� r� r& �creater� r r* r� r5 � explanation)rk r� r� r� �quiet�override_options�container_options�exrl rl rm �create_container< s" � ���zService.create_containerc C s� | � � r|tjkr| j|d� d S z| �� W d S ty! Y nw | � � s.| j|d� d S |tjkr7t| ��| j|d� t �
d� | j �� d S )N)�cli)�silentz�Image for service {} was built because it did not already exist. To rebuild this image you must use `docker-compose build` or `docker-compose up --build`.)
� can_be_builtr� r� �build�imagery �pullr� rt r� r� r� r� )rk �do_buildr� r� rl rl rm r� Z s& �
�zService.ensure_image_existsc C �0 z| j �| j�W S ty td�| j���w �NzImage '{}' not found)r� �inspect_distribution�
image_namer ry r� r� rl rl rm �get_image_registry_datar �
�z Service.get_image_registry_datac C r� r� )r� �
inspect_imager� r ry r� r� rl rl rm r� x r� z
Service.imagec C s | j �ddj| | j�d�d��S )Nr� z{project}_{s.name}z_-)�sr� )r� �getr� r� �lstripr� rl rl rm r� ~ s �zService.image_namec C s( | j �d�}|st| jjd�r| j}|S )N�platform�1.35)r� r r
r� � api_versionr� )rk r rl rl rm r � s zService.platformc C s� | j dd�}|r
tdg �S |stdg �S |tju r td|�S |tju s(| �|�r-td|�S dd� |D �}|r;td|�S td |�S )
NTr� r� r� r� �recreatec S r� rl r� r� rl rl rm r� � � z,Service.convergence_plan.<locals>.<listcomp>�noop)r� r{ r| r� r� r� )rk �strategyr� r� r� rl rl rm �convergence_plan� s
�
zService.convergence_planc
C s� d }z| j }W n ty$ } zt�d| jt|�� W Y d }~dS d }~ww d}|D ])}|�| j�r<t�d|j � d}q)|j� t
d �}||krRt�d|j||� d}q)|S )NzService %s has diverged: %sTFz$%s has diverged: Legacy project namez%s has diverged: %s != %s) � config_hashry r� �debugr� �strr� r� r� r r )rk r� r �e� has_divergedr� �container_config_hashrl rl rm r� � s4
��� ��z!Service._containers_have_divergedc sv �� � }�����fdd�� ��fdd�}t�fdd�t||| �D �� �fdd�|d �\}} | �� D ]}
t|
��|S )
Nc sL �r| j dddd����}n| j |dd�}� s|�� �r$�s$��|� |S )NT)r� r� )r� r� rl )r� �attach_log_stream�start_container)ri �nr� )�detachedr� r� rk r� rl rm �create_and_start� s
z=Service._execute_convergence_create.<locals>.create_and_startc s( � r d� | j| jdg�S ��| j| j�S )N�_�run)�joinr� ri �get_container_namer� �� service_name)r� rk rl rm �get_name� s �z5Service._execute_convergence_create.<locals>.get_namec s g | ]
}t � j� j|��qS rl )rz r� r� )r� �indexr� rl rm r� � s ��z7Service._execute_convergence_create.<locals>.<listcomp>c s � �| j �S rh �r� r )r rk rl rm r� � r� z5Service._execute_convergence_create.<locals>.<lambda>�Creating)r� r, �range�valuesr* ) rk r� r r� r� r� �ir r� �errors�errorrl )r r r� r� rk r� rm �_execute_convergence_create� s
� � z#Service._execute_convergence_createc
s� |d urt |�|kr��||d � �� |d |� }� ����fdd�}t||dd� d�\}}|�� D ]} t| ��|d urQt |�|k rQ|���|t |� � ��� |S )Nc s �j | �� ��d�S )N)r� � attach_logsr� �renew_anonymous_volumes)r� �r� �r r' rk r� r� rl rm r � s �z7Service._execute_convergence_recreate.<locals>.recreatec S � | j S rh �r� r� rl rl rm r� � � z7Service._execute_convergence_recreate.<locals>.<lambda>�
Recreating�r� r� r, r! r* �extendr% )
rk r� r� r� r r� r' r r# r$ rl r) rm � _execute_convergence_recreate� s" � �z%Service._execute_convergence_recreatec
s� |d urt |�|kr��||d � |� |d |� }|r=dd� |D �}t|� �fdd�dd� d�\}}|�� D ]} t| ��|d urUt |�|k rU|���|t |� � |�� |S )Nc S r� rl r� r� rl rl rm r� r z6Service._execute_convergence_start.<locals>.<listcomp>c s �j | � dd�S )NT)r& r� )r� r� �r rk rl rm r�
� z4Service._execute_convergence_start.<locals>.<lambda>c S r* rh r+ r� rl rl rm r� r, �Startingr. )
rk r� r� r� r r� r� r r# r$ rl r1 rm r� s$ � �z"Service._execute_convergence_startc s$ � �fdd�}t ||dd� d� d S )Nc s | j � ���d� | �� d S )N�r� )�stop� stop_timeoutr� r( �rk r� rl rm �stop_and_remove s z+Service._downscale.<locals>.stop_and_removec S r* rh r+ r� rl rl rm r� r, z$Service._downscale.<locals>.<lambda>zStopping and removingr+ )rk r� r� r8 rl r7 rm r� s �zService._downscaleTc
C s |\}
} |d ur
|n| j } t| td�d�} | �| � |
dv r*| j| |||
dk| d�S |s.d } |
dkrN|rD| �� d }
| D ]}|�|
� q<| �| | ||||�S |
dkr[| �| | |||�S |
d kr}| t | �krn| �| | |||�S | D ]
}t
� d
|j � qp| S t
d �|
���) Nr� r� )r� r� r� )r� r� r �Idr� r z%s is up-to-datezInvalid action: {})r� r� r r� r% r� � reset_imager0 r� r� r� r� r� � Exceptionr� )rk �planr� r r� �scale_override�rescale�reset_container_imager' r� �actionr� r� �img_idr� rl rl rm �execute_convergence_plan$ sH
�
�
�
�z Service.execute_convergence_planc C sZ |j | �|�d� |�� | j|s|nd|jdd�}|r |�� |r'| �|� |�� |S )z�Recreate a container.
The original container is renamed to a temporary name so that data
volumes can be copied to the new container, before the original
container is removed.
r4 NT)r� r� r� )r5 r6 �rename_to_tmp_namer� r� r r r� )rk r� r� r& r� r' �
new_containerrl rl rm r� Y s
�
zService.recreate_containerc C s, |d ur|S t | j�d��}|d ur|S tS )N�stop_grace_period)r2 r� r r r7 rl rl rm r6 p s zService.stop_timeoutc C s4 |j s|s
t�d|j � |r|�� | �|�S d S )Nz Starting %s)r� r� r� r� r r )rk r� r& r� rl rl rm r� x s
�z"Service.start_container_if_stoppedc
C sb | � ||� z|�� W |S ty0 } zt|j�}d|v r#t�d� td�| j |���d }~ww )Nz/driver failed programming external connectivityz+Host is already in use by another containerzCannot start service {}: {})
� connect_container_to_networksr� r r5 r� r� �warnr* r� r� )rk r� �use_network_aliasesr� �explrl rl rm r � s
�
��zService.start_containerc C s t t| j�� dd� dd��S )Nc S s | d � d�pdS )Nr �priorityr �r )�trl rl rm r� � r2 z.Service.prioritized_networks.<locals>.<lambda>T)r� �reverse)r r� r� �itemsr� rl rl rm �prioritized_networks� s ��z Service.prioritized_networksc C s� |� d�}| j�� D ]=\}}||v r t||�rq
| j�|j|� |r(| �||�ng }| jj|j|||� dd �|� dd �| � d�|� dd �d� q
d S )NzNetworkSettings.Networks� ipv4_address� ipv6_addressF�link_local_ips)�aliasesrP rQ r� rR )
r rO rN �short_id_alias_existsr� �!disconnect_container_from_network�id� _get_aliases� connect_container_to_network�
_get_links)rk r� rH �connected_networks�network�netdefsrS rl rl rm rF � s
��z%Service.connect_container_to_networksc C s< | � � D ]}t�d|j � |j| �|�d� |�� qd S )Nz Removing %sr4 )�duplicate_containersr� r� r� r5 r6 r� )rk r� r� rl rl rm �remove_duplicate_containers� s
�z#Service.remove_duplicate_containersc c sL � t | jdd�dd� d�}t� }|D ]}|j|v r |V q|�|j� qd S )NTr� c S s
| � d�S )N�CreatedrK r� rl rl rm r� � s
z.Service.duplicate_containers.<locals>.<lambda>r� )r� r� r� r� �add)rk r� �numbersr� rl rl rm r] � s �
�
�z Service.duplicate_containersc C s t | �� �S rh )r0 � config_dictr� rl rl rm r � � zService.config_hashc sB � fdd�}� j |� � �� � jj� jj� j� jdd� � jD �d�S )Nc s$ z� � � d W S ty Y d S w �Nr9 )r� ry rl r� rl rm �image_id� s
�z%Service.config_dict.<locals>.image_idc S s& g | ]}t |jt�r|jj|jf�qS rl )�
isinstance�sourcer� r� �mode�r� �vrl rl rm r� � s
� �z'Service.config_dict.<locals>.<listcomp>)r� re r� �netr� r� r� ra ) r� �get_link_namesr� rV r� rh r� r� ra )rk re rl r� rm rb � s ��zService.config_dictc C sh | j j}| jj}| jj}| �� | �� |r|gng |r |gng |r&|gng t| j�di �� � � S )N�
depends_on)
r� r r� r� �get_linked_service_names�get_volumes_from_namesr� r� r �keys)rk �net_name�
pid_namespace�
ipc_namespacerl rl rm �get_dependency_names� s � � � ���z Service.get_dependency_namesc C s | j j}| jj}| jj}dd� | �� D �}|�dd� | �� D �� |�|r)|d ini � |�|r4|d ini � |�|r?|d ini � |�| j�di �� | j�di �� � D ]3\}}|d t
krfdd� ||< qU|d t krsd d� ||< qU|d t kr�d
d� ||< qUt
d �|d ���|S ) Nc S s i | ]}|d �qS rh rl �r� r� rl rl rm �
<dictcomp>� � �z2Service.get_dependency_configs.<locals>.<dictcomp>c s s � | ]}|d fV qd S rh rl ru rl rl rm � <genexpr>� � �
�z1Service.get_dependency_configs.<locals>.<genexpr>rm � conditionc S s dS )NTrl �r rl rl rm r� � s z0Service.get_dependency_configs.<locals>.<lambda>c S � | � � S rh )�
is_healthyr{ rl rl rm r� � � c S r| rh )�is_completed_successfullyr{ rl rl rm r� � r~ z%depends_on condition "{}" is invalid.)r� r r� r� rn r� ro r� r rN �CONDITION_STARTED�CONDITION_HEALTHY� CONDITION_COMPLETED_SUCCESSFULLYr� r� )rk rq rr rs �configs�svc�configrl rl rm �get_dependency_configs� s4 �
� ��z Service.get_dependency_configsc C � dd� | j D �S )Nc S s g | ]\}}|j �qS rl r+ )r� ri r rl rl rm r� r z4Service.get_linked_service_names.<locals>.<listcomp>�r� r� rl rl rm rn � z Service.get_linked_service_namesc C r� )Nc S s g | ] \}}|j |f�qS rl r+ )r� ri �aliasrl rl rm r� � z*Service.get_link_names.<locals>.<listcomp>r� r� rl rl rm rl r� zService.get_link_namesc C r� )Nc S s g | ] }t |jt�r|jj�qS rl )rf rg r� r� )r� r rl rl rm r�
s z2Service.get_volumes_from_names.<locals>.<listcomp>�ra r� rl rl rm ro r� z Service.get_volumes_from_namesc
C sd |rd S t �| jdd| jdd�id�| jdd| jddd�id��}dd� |D �}|s,d S t|�d S )
NTr� Fr� r� r� c S s g | ]
}|j d ur|j �qS rh r r� rl rl rm r� � z2Service._next_container_number.<locals>.<listcomp>r )� itertools�chain�_fetch_containersr� �max)rk r� r� ra rl rl rm r� s ��� z Service._next_container_numberc s2 � fdd��t d �fdd�� jjdi |��D ��S )Nc s* z
t �� j| d �W S ty Y d S w rd )r& �from_idr� r r( r� rl rm � soft_inspect s
�z/Service._fetch_containers.<locals>.soft_inspectc � g | ]}� |��qS rl rl r� )r� rl rm r� $ s ��z-Service._fetch_containers.<locals>.<listcomp>rl )r� r� r� )rk �
fetch_optionsrl )rk r� rm r� s �zService._fetch_containersc C s. t | jh|r
|jhnt� B t|�dd��B �S )NrS rl )r� r� �short_idr� r )rk r[ r� rl rl rm rW ) s ���zService._get_aliasesc C sp | j si S | j | jj }| �|�i d�}|�d�r"|�d�|d d< |�d�r0|�d�|d d< d| jj|iiS )N)�Aliases�
IPAMConfigrP r� � IPv4AddressrQ � IPv6Address�EndpointsConfig)r� r� rV rW r )rk r[ �endpointrl rl rm � build_default_networking_config0 s �
z'Service.build_default_networking_configc C s� i }| j D ] \}}|�� D ]}|j||p|j< |j||j< |j||j< q
q|r@| �� D ]}|j|| j< |j||j< |j||j< q+| j�d�pGg D ]}d|vrQ|}n|�d�\}}|||< qHdd� |�� D �S )N�external_links�:c S s g | ]\}}||f�qS rl rl )r� �container_namer� rl rl rm r� W s ��z&Service._get_links.<locals>.<listcomp>)r� r� r� �name_without_projectr� r �splitrN )rk � link_to_selfr� ri � link_namer� �
external_linkrl rl rm rY A s( �
�zService._get_linksc C r� )Nc S � g | ]}t |��qS rl )�build_volume_from)r� �specrl rl rm r� ] � z-Service._get_volumes_from.<locals>.<listcomp>r� r� rl rl rm �_get_volumes_from\ r� zService._get_volumes_fromc s | o| }|r t � nd }� fdd�tD �}|�dg �}|�|� |�d�s0� �� j||�|d< |�dd� t� j j
d�r^d|v r^d |vr^d
|d v r^|d � d
�} | d |d< | d |d < t � j j
d
�rqd� j
v rq� �d �|d< d|v szd� j
v r�tt|�dg ��� j
�|d< d|v s�|r�tt|�dg �| ��|d< t� �� t� j
�d�|�d���|d< t� j
�d�|�d��|d< � �|||�\}}� j|d< t|�di �� j|d�� j ||r߈ jnd |�|d< t D ]}
|�|
d � q� j ||d�|d< � � � } | �r| |d< t |d �|d< |S )Nc s" i | ]
}|� j v r|� j | �qS rl �r� )r� �kr� rl rm rv h s
�z9Service._get_container_create_options.<locals>.<dictcomp>�volumesr� �detachTz1.23�hostname�
domainname�.r r} z1.25rE r6 �ports�expose� environmentr� r� r� � host_config�networking_config) r/ r �popr� r r r� �
setdefaultr r� r � partitionr
r� r6 �build_container_ports�formatted_portsr� r� r �_parse_proxy_configr � _build_container_volume_optionsr� �build_container_labelsr� r� r �HOST_CONFIG_KEYS�_get_container_host_configr� �format_environment) rk r� r� r� r� �add_config_hash�slugr� �override_volumes�partsr� r� rl r� rm r� _ s�
�
�
�
��
��
�
��z%Service._get_container_create_optionsc
C s| g }g }d|v r dd� |� d�D �}dd� |� d�D �}t|| j� d�p%g ||�\}}|d �|� dd� |p8i D �|d< t| jjd �rPd
d� |D �pLd |d < n)| j� d�pWg |d< |D ] }|jrj|d �|j � q\|�|�
� � i |d |j < q\| � � } | r�t | jjd �r�|�
d d
� | D �� |d �dd
� | D �� n|� d �p�g |d < |d �
dd� | D �� tt|��|d< ||fS )Nr� c S � g | ] }t |t�r|�qS rl )rf r ri rl rl rm r� � s
��z;Service._build_container_volume_options.<locals>.<listcomp>c S r� rl )rf r ri rl rl rm r� � r� �tmpfsr� c S s i | ]}|j i �qS rl )�internalri rl rl rm rv � r� z;Service._build_container_volume_options.<locals>.<dictcomp>z1.30c S r� rl �� build_mountri rl rl rm r� � r� �mountsc s s � | ]}|� � V qd S rh )� legacy_reprri rl rl rm rx � � � z:Service._build_container_volume_options.<locals>.<genexpr>c s s � | ]}|j i fV qd S rh ��targetri rl rl rm rx � s �
�c S r� rl r� ri rl rl rm r� � r� �binds)r �merge_volume_bindingsr� r� r
r� r �is_tmpfs�appendr� r� �get_secret_volumesr r/ r� r4 )
rk r� r� r� �container_volumes�container_mountsr� �affinity�m�secret_volumesrl rl rm r� � s@ ��
�z'Service._build_container_volume_optionsc
C sJ t | jfi |��}|�dd �}t|�dd ��}t|�}d }t|�d�t�r.|�d�}d|d< |�d�r=dd� |�d�D �nd }d } d|v rNt|�d�t �} | j j
dGi d | j |d
��d t t
|�d g ����d
|�d
��d| �� �d|�dd��d| jj�d|�d��d|�d��d|�d��d|�d��d|�d��d|�d��d|�d��d|�d��d|�d��d |�d ��d |�d ��d |�d ��d t|�d ���d |�d!|�d!��d"|�d"��d#| jj�d|�d$| jj�d%|�d%��d&|�d&��d'|�d'��d(|�d(��d)|�d)��d*|�d*��d+|�d+��d,|�d,��d-|�d-��d.|�d.��d/|�d/��d|�dd ��d0|�d1|�d1��d2|�d2��d3|�d3��d4| �d5|�d5��d6|�d7��d8|�d8��d9|�d9��d:|�d;��d<|�d=��d>|�d>��d?|�d?��d@|�d@��dA|�dA��dB|�dB��dC|�dC��dD|�dD��dE|�dE��dF|�dF���S )HN�logging� blkio_configrK Tr\ c S � g | ]}|j �qS rl )�value)r� �orl rl rm r� � rw z6Service._get_container_host_config.<locals>.<listcomp>r@ r� )r� �
port_bindingsr� r� ra rY Fr� rC rD rE rG rF �restart_policyrZ r[ r6 r7 rQ rR rS �ulimits�
log_configrI rN r� r� r8 r< r] r_ rX r� rU rV rT rJ r` � init_pathrM r9 r: � nano_cpusrb � cpuset_cpusrA r? r^ � blkio_weight�weight�blkio_weight_device�
weight_device�device_read_bps�device_read_iops�device_write_bps�device_write_iopsr� rB r; r= r> rl )�dictr� r �convert_blkio_config�get_log_configrf r
�intr$ r� �create_host_configrY r r� r� r� rh �
build_ulimitsr� r� )
rk r� r� r� � logging_dictr� r� r� r\ r� rl rl rm r� � s
��� ���
�� ��
�
�
�
�
�
�
�
�
�
�
�
���
�
����
�
�
�
�
�
!�
"�
#�
$�
%�
&� '�(�
)�
*�
+�,�
-�
.�
/�
0�
1�
2�
3�
4�
5�
6�
7�
8�
9�
:�
;�z"Service._get_container_host_configc s dd� � � fdd�| j D �S )Nc S sV | d j }|d u rd�tj| d j�}n
tj�|�s!d�tj|�}td| d |dd�S )N�secretz{}/{}�bind�fileT)rN ) r� r� r � SECRETS_PATHrg �os�path�isabsr )r� r� rl rl rm �
build_spec5 s
z.Service.get_secret_volumes.<locals>.build_specc r� rl rl )r� r� �r� rl rm r� > r� z.Service.get_secret_volumes.<locals>.<listcomp>)r� r� rl r� rm r� 4 s zService.get_secret_volumesc C s� t tjd�} |stj} t�d| j � | j� di �} | � di ��
� }
|r)|
� |� | � � �
� D ]
\}}|
�||� q/t| � d��}| jrOt| jjd�rOtd��| sVt| j�nt|
�}|jd i d| �d |�d
| j�d |�d |�d
|�d|�d| � dd ��d| �| ��d| � dd ��d|
�d| � dd ��d| � dd ��d| � d�r�t| � d��nd �d| � dd ��dd|r�t|�nd i�d|�d | � d | j� d d ���d | j�d | ��S ) N�wz Building %sr� �args�contextr zEImpossible to perform platform-targeted builds for API version < 1.35ri r� �tag�rm�forcermr� �nocache�
dockerfile�
cache_fromr� � buildargsr� r[ r� �shmsizer] rI �container_limits�memory�gziprM r �
output_streamrl )�openr� �devnull�sys�stdoutr� r� r� r� r �copyr� r� rN r� �rewrite_build_pathr r r� r r* �_ClientBuilder� _CLIBuilderr� r� �get_cache_fromr1 )rk �no_cacher� �force_rmr
�build_args_overrider r r� r� �progressr �
build_opts�
build_argsr� rj r� �builderrl rl rm r� @ sv
�
������� �
�
� � �
��� �������z
Service.buildc C s& |� dd �}|d urdd� |D �}|S )Nr c S s g | ]}|r|�qS rl rl )r� r rl rl rm r� r r� z*Service.get_cache_from.<locals>.<listcomp>rK )rk r r rl rl rm r o s zService.get_cache_fromc C s
d| j v S )Nr� r� r� rl rl rm r� u rx zService.can_be_builtc C sJ |s| j nt�dd| j �}d�t|�d�t| j�d�t|r!d�gS d�gS )Nz[_-]� r� �True�False)r� �re�subr� r r! r� r )rk r� r� � proj_namerl rl rm r� x s
��zService.labelsc C s | j �d�S )Nr� �r� r r� rl rl rm r� � rc z Service.custom_container_namec C sZ | j r
|d u r
| j S t| j|||�}dd� | j�dg �D �}||v r+td�| j|���|S )Nc S s g | ] }|� d �d �qS )r� r �r� )r� �linkrl rl rm r� � r� z.Service.get_container_name.<locals>.<listcomp>r� z3Service {} has a self-referential external link: {})r� �build_container_namer� r� r r r� r� )rk r r� r� r� �ext_links_originsrl rl rm r � s
���zService.get_container_namec
C s� |r|t jkr dS |t jkr| j�d�rdS t�d| j� z
| j� | j� W dS t
y8 t� d| j� Y dS t yR } zt�
d| j|� W Y d }~dS d }~ww )NFr� zRemoving image %sTzImage %s not found.z)Failed to remove image for service %s: %s)r� r� r� r� r r� r� r� r� � remove_imager r� r r$ r� )rk �
image_typer rl rl rm r( � s ��zService.remove_imagec s( dd� � t � fdd�| j�dg �D ��S )Nc S s\ t | t�r | �d�}nt| �\}}|d u rdS |d }t |t�s"dS |\}}|d ur,dS dS )N� publishedFr T)rf r� r r
�tuple)�binding�external_bindingsr �external_binding� host_portrl rl rm �
has_host_port� s
z2Service.specifies_host_port.<locals>.has_host_portc 3 s � | ]}� |�V qd S rh rl )r� r, �r0 rl rm rx � r� z.Service.specifies_host_port.<locals>.<genexpr>r� )�anyr� r r� rl r1 rm r� � s zService.specifies_host_portc
c s� � z;| j j|fi |��}|r1ttjd��}t||�E d H W d � W d S 1 s)w Y W d S t|tj�E d H W d S tt fy[ } z|sI� t
� t |�� W Y d }~d S d }~ww )Nr� )
r� r� r
r� r r- r r r. r r� r$ r
)rk �repo� pull_kwargsr� �ignore_pull_failures�outputr r rl rl rm �_do_pull� s �&� ��zService._do_pullc C s� d| j vrd S t| j d �\}}}|pdd| jd�}|s(t�d�| j|||�� |d r7t| jj d�r7t
d��| � ||||�}|rC|S t �
|�S ) Nr� �latestT)r �streamr zPulling {} ({}{}{})...r r zDImpossible to perform platform-targeted pulls for API version < 1.35)r� �parse_repository_tagr r� r� r� r� r r� r r* r7 r �get_digest_from_pull) rk r5 r� r9 r3 r � separator�kwargs� event_streamrl rl rm r� � s"
��
z Service.pullc
C s� d| j vs
d| j vr d S t| j d �\}}}|pd}t�d�| j|||�� | jj||dd�}z
t� t
|t j ��W S t
yV } z|sD� t�t|�� W Y d }~d S d }~ww )Nr� r� r8 zPushing {} ({}{}{})...T)r r9 )r� r: r� r� r� r� r� �pushr �get_digest_from_pushr- r r r. r$ r
)rk �ignore_push_failuresr3 r r< r6 r rl rl rm r? � s
� ��z Service.pushc C sZ d}| � � D ]$}|�� |�d�}|du rt| j��|dkr!d}q|dkr*t|j��q|S )z� Check that all containers for this service report healthy.
Returns false if at least one healthcheck is pending.
If an unhealthy container is detected, raise a HealthCheckFailed
exception.
TzState.Health.StatusN�startingF� unhealthy)r� �inspectr r) r� r( r� )rk r� �ctnr�statusrl rl rm r} � s
�zService.is_healthyc C sN d}| j dd�D ] }|�� |�d�dkrd}q|jdkr$t|j|j��q|S )a Check that all containers for this service has completed successfully
Returns false if at least one container does not exited and
raises CompletedUnsuccessfully exception if at least one container
exited with non-zero exit code.
Tr� z State.Status�exitedFr )r� rD r � exit_coder' r� )rk r� rE rl rl rm r s
�z!Service.is_completed_successfullyc C s� | j }d|jvr
i S t|d|j�}|jd �||jd �d��p!i }ddddd�}i }|�� D ]\}}||vr8q/| ||| < ||| �� < q/|S ) N�proxies�_original_base_urlr� � FTP_PROXY�
HTTP_PROXY� HTTPS_PROXY�NO_PROXY)�ftpProxy� httpProxy�
httpsProxy�noProxy)r� �_general_configs�getattr�base_urlr rN �lower)rk r� � docker_host� proxy_config� permittedr� r� rj rl rl rm r� s(
��� zService._parse_proxy_configc C s d| j vrg S | j �d�S )N�profilesr# r� rl rl rm � get_profiles1 s
zService.get_profilesc C s6 d| j vrdS | j �d�}|D ] }||v r dS qdS )NrZ TFr# )rk �enabled_profiles�service_profiles�profilerl rl rm �enabled_for_profiles7 s
�z Service.enabled_for_profiles)
Nr� FNNNNNr NNNN)FFNN)r rh )FNNF)FN)NFTNTFFN)NFTF)FF)T)F)
FFFNNFTFFN)FFF)Erp rq rr rn r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r| r� r
r� r% r0 r� r� rB r� r6 r� r rO rF r^ r] r rb rt r� rn rl ro r� r� rW r� rY r� r� r� r� r� r� r r� r� r� r r( r� r7 r� r? r} r r� r[ r_ rl rl rl rm r� � s�
�"
;
�
&
�5
�
!
�X
,Q
�/
r� c C s | � dj|d��p
d}| j|v S )Nz&NetworkSettings.Networks.{net}.Aliases)rk rl )r r� r� )r� r[ rS rl rl rm rT D s
��
rT c @ �, e Zd Zdd� Zedd� �Zedd� �ZdS )r� c C ru rh ��_mode�rk rh rl rl rm rn K rx zIpcMode.__init__c C r* rh ra r� rl rl rm rh N � z IpcMode.modec C � d S rh rl r� rl rl rm r R � zIpcMode.service_nameN�rp rq rr rn r� rh r rl rl rl rm r� J �
r� c @ r` )�ServiceIpcModec C ru rh rv rw rl rl rm rn X rx zServiceIpcMode.__init__c C � | j jS rh �ri r� r� rl rl rm r [ � zServiceIpcMode.service_namec C �0 | j �� }|rd|d j S t�d| j � d S )N�
container:r z[Service %s is trying to use reuse the IPC namespace of another service that is not running.�ri r� rV r� r� r �rk r� rl rl rm rh _ �
��zServiceIpcMode.modeN�rp rq rr rn r� r rh rl rl rl rm ri W rh ri c @ rf )�ContainerIpcModec C � || _ d�|j�| _d S �Nz container:{}�r� r� rV rb �rk r� rl rl rm rn m � zContainerIpcMode.__init__Nro rl rl rl rm rs l rs rs c @ r` )r� c C ru rh ra rc rl rl rm rn s rx zPidMode.__init__c C r* rh ra r� rl rl rm rh v rd z PidMode.modec C re rh rl r� rl rl rm r z rf zPidMode.service_nameNrg rl rl rl rm r� r rh r� c @ r` )�ServicePidModec C ru rh rv rw rl rl rm rn � rx zServicePidMode.__init__c C rj rh rk r� rl rl rm r � rl zServicePidMode.service_namec C rm )Nrn r z[Service %s is trying to use reuse the PID namespace of another service that is not running.ro rp rl rl rm rh � rq zServicePidMode.modeNrr rl rl rl rm ry rh ry c @ rf )�ContainerPidModec C rt ru rv rw rl rl rm rn � rx zContainerPidMode.__init__Nro rl rl rl rm rz � rs rz c @ s, e Zd ZdZdZdd� Zedd� �ZeZdS )r� z,A `standard` network mode (ex: host, bridge)Nc C ru rh �r� )rk r� rl rl rm rn � rx zNetworkMode.__init__c C r* rh r{ r� rl rl rm rV � rd zNetworkMode.id� rp rq rr r� r rn r� rV rh rl rl rl rm r� � s
r� c @ s4 e Zd ZdZdZdd� Zedd� �Zedd� �ZdS ) �ContainerNetworkModez5A network mode that uses a container's network stack.Nc C ru rh r( rw rl rl rm rn � rx z ContainerNetworkMode.__init__c C rj rh �r� rV r� rl rl rm rV � rl zContainerNetworkMode.idc C s d| j j S )Nrn r~ r� rl rl rm rh � rc zContainerNetworkMode.moder| rl rl rl rm r} � s
r} c @ s4 e Zd ZdZdd� Zedd� �ZeZedd� �ZdS ) �ServiceNetworkModez3A network mode that uses a service's network stack.c C ru rh rv rw rl rl rm rn � rx zServiceNetworkMode.__init__c C rj rh rk r� rl rl rm rV � rl zServiceNetworkMode.idc C s0 | j �� }|rd|d j S t�d| j � d S )Nrn r z[Service %s is trying to use reuse the network stack of another service that is not running.)ri r� rV r� r� rp rl rl rm rh � s
�zServiceNetworkMode.modeN) rp rq rr r� rn r� rV r rh rl rl rl rm r � s
r c C s> | � d�|g}|r|�dt|�g� n|�t|�� d�|�S )Nz-_r r )r r/ r3 r� r
r )r� ri r� r� �bitsrl rl rm r& � s
r& c C sh d}d}|| v r| � |d�\}}|||fS | d}}|| v r/| � |d�\}}d|v r/| d}}|||fS )a Splits image identification into base image path, tag/digest
and it's separator.
Example:
>>> parse_repository_tag('user/repo@sha256:digest')
('user/repo', 'sha256:digest', '@')
>>> parse_repository_tag('user/repo:v1')
('user/repo', 'v1', ':')
r� �@r r �/)�rsplit)� repo_path�
tag_separator�digest_separatorr3 r rl rl rm r: � s
r: c C st i }t dd� | D ��}|r2t|| ||�\}}t| ||j� |�dd� |D �� |s+|r2dd|j i}t|�� �|fS )z�
Return a list of volume bindings for a container. Container data volumes
are replaced by those from the previous container.
Anonymous mounts are updated in place.
c s s � | ]
}|j rt|�V qd S rh )�external�build_volume_binding�r� �volumerl rl rm rx s � �
�z(merge_volume_bindings.<locals>.<genexpr>c s s � | ]}t |�V qd S rh )r� r� rl rl rm rx ry zaffinity:container�=)r �get_container_data_volumes�warn_on_masked_volumeri r� rV r� r! )r� r� r� r� r� �volume_bindings� old_volumes�
old_mountsrl rl rm r� � s ��
�r� c C s
g }|pg }dd� | � d�pi D �}dd� | jd � d�p i D �}t|| �D ]7}|jr-q'|jt|��� v r7q'|� |j�}|s@q'|� d�sFq'|jd d� |D �v rQq'|j|d d
�}|�|� q'd } |D ] }|j d krkqc|� |j
�}
|
rx|
� d�syqc|
d |_ d
} qc|| fS )z�
Find the container data volumes that are in `volumes_option`, and return
a mapping of volume bindings for those volumes.
Anonymous volume mounts are updated in place instead.
c S s i | ]}|d |�qS )� Destinationrl )r� �mountrl rl rm rv # � ��z.get_container_data_volumes.<locals>.<dictcomp>�Mountsc S s g | ]}t �|��qS rl )r �parser� rl rl rm r� ( r� z.get_container_data_volumes.<locals>.<listcomp>�ContainerConfig�Volumes�Namec S r� rl r� )r� r� rl rl rm r� C r2 )r� Fr� T) r � image_configr� r� r� r rp �_replacer� r r� rg ) r� �volumes_option� tmpfs_option�
mounts_optionr� r� �
image_volumesr� r� �updated_mounts�
ctnr_mountrl rl rm r� s@ ��
r� c C sX dd� |D �}| D ] }|j r)|j|v r)|�|j�|j kr)t�dj||j|j d�� q d S )Nc S s i | ]}|j |j�qS rl )r� r� r� rl rl rm rv Z r� z)warn_on_masked_volume.<locals>.<dictcomp>z�Service "{service}" is using volume "{volume}" from the previous container. Host mapping "{host_path}" has no effect. Remove the existing containers (with `docker-compose rm {service}`) to use the host volume mapping.)ri r� � host_path)r� r� r r� r� r� )r� r� ri r� rl rl rm r� Y s" ��
���r� c C s | j | �� fS rh )r� �repr)� volume_specrl rl rm r� o � r� c C sn t | jt�r&| jjdd�}|sd�| j�� j| j�S |d }d�|j| j�S t | jt�r5d�| jj| j�S dS )z�
volume_from can be either a service or a container. We want to return the
container.id and format it into a string complete with the mode.
Tr� �{}:{}r N) rf rg r� r� r� r� rV rh r& )�volume_from_specr� r� rl rl rm r� s s
� �r� c C s` i }| j r | j| j �� D ]\}}|| j v r | j | ||< q
td| j| j| j| j| jd�|��S )N)r r� rg rN � consistencyrl ) r� � options_mapr rN r r� rg rN r� )�
mount_specr= �option�sdk_namerl rl rm r� � s
� ��r� c C sj t | pi �}|�dd� |D �� |d urt|�|t< |d ur"||t< t|t< |r3t�d| � ||t < |S )Nc s s � | ] }|� d d�V qdS )r� r Nr$ )r� r� rl rl rm rx � s � z)build_container_labels.<locals>.<genexpr>zAdded config hash: %s)
r� r� r
r r" r r# r� r r )�
label_options�service_labelsr� r r� r� rl rl rm r� � s r� c C sf | sd S g }| � � D ]&\}}t|t�r |�|||d�� q
t|t�r0d|i}|�|� |�|� q
|S )N)r� �soft�hardr� )rN rf r� r� r� r� )�
ulimit_configr� �
limit_name�soft_hard_values� ulimit_dictrl rl rm r� � s
�r� c C s4 | r| � dd�nd}| r| � dd �nd }t||d�S )N�driverr r� )r r� )r r )r� rO � log_optionsrl rl rm r� � s �r� c s dd� � � fdd�| � � D �S )Nc S s. |d u r| S t |t�r|�d�}dj| |d�S )Nzutf-8z
{key}={value}�r� r� )rf �bytes�decoder� r� rl rl rm �
format_env� s
z&format_environment.<locals>.format_envc s g | ]}� |� �qS rl rl )r� �item�r� rl rm r� � r� z&format_environment.<locals>.<listcomp>)rN )r� rl r� rm r� � s r� c C s6 g }| D ]}t |t�r|�|�� � q|�|� q|S rh )rf r r� r� )r� r� �portrl rl rm r� � s
r� c C s` g }| |� dg � }|D ]!}t|�\}}|D ]}t|�}d|v r't|�d��}|�|� qq |S )Nr� r� )r r
r
r+ r� r� )�container_portsr� r� � all_ports�
port_range�internal_ranger r� rl rl rm r� � s �r� c C sh i }| d u r|S | � d�|d< dD ] }|| vrqg }| | D ]}|�dd� |�� D �� q |||< q|S )Nr� )r� r� r� r� r� c S s i | ] \}}|� � |�qS rl )�
capitalize)r� r� rj rl rl rm rv � r� z(convert_blkio_config.<locals>.<dictcomp>)r r� rN )r� r� �field�arrr� rl rl rm r� � s
r� c C s* t rt| �s| �t�sttj�| � } | S rh )r r �
startswithr% r� r� �normpath)r� rl rl rm r � s r c @ �T e Zd Zdd� Zdddddddddddddddddddddddddejfdd�ZdS )r c C ru rh )r� )rk r� rl rl rm rn � rx z_ClientBuilder.__init__NFTc #
C s | j jdi d|�d|�d|�d|�d| �d| �d|
�d|�d |�d
|�d |�d |�d
|�d|�d|�d|�d|�d|��} z tt| | ��} W n tyY } zt|t| ���d } ~ ww | j �� d } | D ]}!d|!v rzt� d|!�
dd��}"|"rz|"� d�} qc| d u r�t|| r�|!��d��| S )Nr� r r r r� r r r� r r r� r� r rI r r rM r r9 z Successfully built ([0-9a-f]+)r r �Unknownrl ) r� r� r� r- r. rg r
�closer �searchr �group)#rk ri r� r r� �fileobjr r r� �custom_context�encodingr� r r r r� r r r r� r r� r� �squashrI r rM �use_config_proxyr � build_output�
all_eventsr re �event�matchrl rl rm r� sl �������� �
� � �
��������
�z_ClientBuilder.build�rp rq rr rn r r r� rl rl rl rm r � � �r c @ r� )r c C ru rh )� _progress)rk r rl rl rm rn 7 rx z_CLIBuilder.__init__NFTc % C s� |
rt j�|�rt j�||
�}
t�� } t� } | �d|� | �d|� | � d|
� | �
d| � | �d|� | � d|� d�� | � d|� | �
d |� | � d
| j � | �
d | � | � d |� | � d
|� | � d| � | � d|� | � d|� |r�t
|t�r�dd� |�� D �}|D ] } | � dd�| �� q�| �|g�} tj| | tjdd��}!|!�� |!jdkr�t|d��W d � n1 s�w Y t| ��}"|"�� }#|#�d�d � � }$W d � n1 s�w Y t � | � |$S ) ah
Args:
service (str): Service to be built
path (str): Path to the directory containing the Dockerfile
buildargs (dict): A dictionary of build arguments
cache_from (:py:class:`list`): A list of images used for build
cache resolution
container_limits (dict): A dictionary of limits applied to each
container created by the build process. Valid keys:
- memory (int): set memory limit for build
- memswap (int): Total memory (memory + swap), -1 to disable
swap
- cpushares (int): CPU shares (relative weight)
- cpusetcpus (str): CPUs in which to allow execution, e.g.,
``"0-3"``, ``"0,1"``
custom_context (bool): Optional if using ``fileobj``
decode (bool): If set to ``True``, the returned stream will be
decoded into dicts on the fly. Default ``False``
dockerfile (str): path within the build context to the Dockerfile
encoding (str): The encoding for a stream. Set to ``gzip`` for
compressing
extra_hosts (dict): Extra hosts to add to /etc/hosts in building
containers, as a mapping of hostname to IP address.
fileobj: A file object to use as the Dockerfile. (Or a file-like
object)
forcerm (bool): Always remove intermediate containers, even after
unsuccessful builds
isolation (str): Isolation technology used during build.
Default: `None`.
labels (dict): A dictionary of labels to set on the image
network_mode (str): networking mode for the run commands during
build
nocache (bool): Don't use the cache when set to ``True``
platform (str): Platform in the format ``os[/arch[/variant]]``
pull (bool): Downloads any updates to the FROM image in Dockerfiles
quiet (bool): Whether to return the status
rm (bool): Remove intermediate containers. The ``docker build``
command now defaults to ``--rm=true``, but we have kept the old
default of `False` to preserve backward compatibility
shmsize (int): Size of `/dev/shm` in bytes. The size must be
greater than 0. If omitted the system uses 64MB
squash (bool): Squash the resulting images layers into a
single layer.
tag (str): A tag to add to the final image
target (str): Name of the build-stage to build in a multi-stage
Dockerfile
timeout (int): HTTP timeout
use_config_proxy (bool): If ``True``, and if the docker client
configuration file (``~/.docker/config.json`` by default)
contains a proxy configuration, the corresponding environment
variables will be set in the container being built.
output_stream (writer): stream to use for build logs
Returns:
A generator for the build output.
z --build-argz --cache-fromz--filez
--force-rmz--labelz--memoryr
z --networkz
--no-cachez
--progressz--pullz--tagz--targetz --iidfilez
--platformz --isolationc S s g | ]
\}}d � ||��qS )r� )r� )r� �host�iprl rl rm r� � r� z%_CLIBuilder.build.<locals>.<listcomp>z
--add-hostz{}T)r �stderr�universal_newlinesr z Build failedNr� r ) r� r� �isdirr �tempfile�mktemp�_CommandBuilder�
add_params�add_list�add_arg�add_flagr r� rf r� rN r� r� �
subprocess�Popenr r� � communicate�
returncoderg r
�readliner� �stripr� )%rk ri r� r r� r� r r r� r� r� r� r r r r� r r r r� r r� r� r� rI r rM r� r �iidfile�command_builderr� r� �p�f�linere rl rl rm r� : sP ?
�
� �
�
z_CLIBuilder.buildr� rl rl rl rm r 6 r� r c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
S )r� c C s ddg| _ d S )N�dockerr� ��_argsr� rl rl rm rn � r� z_CommandBuilder.__init__c C s |r| j �|t|�g� d S d S rh )r� r/ r
)rk r� r� rl rl rm r� � s �z_CommandBuilder.add_argc C s |r | j �|g� d S d S rh �r� r/ )rk r� �flagrl rl rm r� � s �z_CommandBuilder.add_flagc C s6 |r|� � D ]\}}| j�|d�||�g� qd S d S )Nr� )rN r� r/ r� )rk r� �paramsr� �valrl rl rm r� � s
�z_CommandBuilder.add_paramsc C s& |r|D ] }| j �||g� qd S d S rh r� )rk r� r! r� rl rl rm r� � s
�z_CommandBuilder.add_listc C s
| j | S rh r� )rk r� rl rl rm r� � rx z_CommandBuilder.buildN) rp rq rr rn r� r� r� r� r� rl rl rl rm r� � s r� rh )z�enumr� r� r� r r� r r� � collectionsr r �operatorr �
docker.errorsr r r � docker.typesr r � docker.utilsr
r �docker.utils.portsr r
�docker.utils.utilsr r r r r r� r r r r �
config.errorsr � config.typesr r r r r r r r r r! r" r# r$ r% r� r& r# r' r( r) r* �parallelr, r- r. �utilsr/ r0 r1 r2 r3 r4 �compose.cli.utilsr5 � getLoggerrp r� r� r� r� r� r; rg rt ry rz r{ �unique�Enumr| r� r� r� rT r� ri rs r� ry rz r� r} r r& r: r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r� rl rl rl rm �<module> s�
0
%
?
8n