Website : rimsha.abasa.com
backdoor
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
proc
/
self
/
root
/
lib
/
python3
/
dist-packages
/
compose
/
__pycache__
/
Filename :
project.cpython-310.pyc
back
Copy
o S �`w� � @ s� d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ d dl m Z d dl m Z d dl m Z d dl mZ dd lmZ dd lmZ dd lmZ dd lmZ dd lmZ ddlmZ ddlmZ ddlm Z ddlm 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%l5m6Z6 dd&l5m7Z7 dd'l5m8Z8 dd(l9m:Z: e�;e<�Z=ej>G d)d*� d*ej?��Z@G d+d,� d,�ZAd-d.� ZBd/d0� ZCd1d2� ZDd3d4� ZEd5d6� ZFd7d8� ZGd9d:� ZHd;d<� ZId=d>� ZJd?d@� ZKG dAdB� dBeL�ZMG dCdD� dDeL�ZNG dEdF� dFeL�ZOG dGdH� dHeL�ZPG dIdJ� dJeL�ZQdS )K� N)�reduce)�path)�APIError)� ImageNotFound)�NotFound)� version_lt� )�parallel)� UserError)�ConfigurationError)�V1)�$get_container_name_from_network_mode)�"get_service_name_from_network_mode)� LABEL_ONE_OFF)� LABEL_PROJECT)� LABEL_SERVICE)� Container)�build_networks)� get_networks)�ProjectNetworks)� read_status)� BuildAction)�ContainerIpcMode)�ContainerNetworkMode)�ContainerPidMode)�ConvergenceStrategy)�IpcMode)� NetworkMode)�NoSuchImageError)�parse_repository_tag)�PidMode)�Service)�ServiceIpcMode)�ServiceNetworkMode)�ServicePidMode)�filter_attached_for_up)�microseconds_from_time_nano)�truncate_string)�ProjectVolumesc @ s$ e Zd ZdZdZdZedd� �ZdS )� OneOffFilterr r � c C s` || j kr|�d�td�� d S || jkr |�d�td�� d S || jkr'd S td�t|����)N�{}={}�True�Falsez Invalid value for one_off: {})�only�append�formatr �exclude�include� ValueError�repr)�cls�value�labels� r8 �1/usr/lib/python3/dist-packages/compose/project.py� update_labels8 s zOneOffFilter.update_labelsN)�__name__� __module__� __qualname__r2 r1 r. � classmethodr: r8 r8 r8 r9 r) 2 s r) c @ s� e Zd ZdZ dQdd�Zejdfdd�Ze dRdd ��Z e d d � �Z d d � Z dd� Z dSdd�ZdTdd�Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � ZdUd!d"�Zdejfd#d$�ZdUd%d&�ZdUd'd(�ZdUd)d*�Zdejfd+d,�Z dVd-d.�Z d/d0� Z dUd1d2�Z dWd3d4�Z de j!e"j#fd5d6�Z$d7d8� Z%dUd9d:�Z&dde j!e"j#dddddddddddddddfd;d<�Z'd=d>� Z(dXd?d@�Z) dYdAdB�Z*dZdCdD�Z+dTdEdF�Z,dejfdGdH�Z-ddejfdIdJ�Z.dKdL� Z/dMdN� Z0dOdP� Z1dS )[�Projectz# A collection of services. Nc C sD || _ || _|| _|pti �| _|pti d�| _|| _|p g | _d S �NF) �name�services�clientr( �volumesr �networks�config_version�enabled_profiles)�selfrA rB rC rE rD rF rG r8 r8 r9 �__init__H s zProject.__init__Fc C s6 | j }|r t�dd|�}d�t|�g}t�||� |S )Nz[_-]� r+ )rA �re�subr0 r r) r: )rH �one_off�legacyrA r7 r8 r8 r9 r7 R s zProject.labelsc s� |pg }|j o |j tk}t|||�}t�|j||�} t�|||�� | |g || � |j |�} |jD ]�} t| �} |r=t | |�} ni } | � dd� | � | �} | � | �}| � | t| �� ��}| �| �}t| | �}|j tkrw� fdd�| �dg �D �| d< t| d | � dd�p�g |j�}| �| �| d< | �| �| d < t| �} t| �\} }|r�t�d �d � |��� | j� t | � d�f|||| | |||||| � d d�||d � | ��� q/| S )zB Construct a Project from a config.Config object. rE Nc � g | ]}� � |��qS r8 )�namespace_spec)�.0� volume_spec�rD r8 r9 � <listcomp>| s ��z'Project.from_config.<locals>.<listcomp>rD rA �secrets�scale�device_requestszIThe following deploy sub-keys are not supported and have been ignored: {}�, �platform) rC �project�use_networkingrE �links� network_mode� volumes_fromrU �pid_mode�ipc_moderY �default_platform� extra_labels) �versionr r r � from_servicesrB r( � from_config�dictr �pop� get_links� get_ipc_mode�get_network_mode�list�keys� get_pid_mode�get_volumes_from�get� get_secretsrU �get_service_scale�get_device_requests�)translate_credential_spec_to_security_opt�)translate_deploy_keys_to_container_config�log�warningr0 �joinr/ r! )r5 rA � config_datarC ra rb rG r[ rE �project_networksrZ � service_dict�service_networksr\ r` r] r_ r^ rU � ignored_keysr8 rS r9 re [ s� � � ��� �� ���zProject.from_configc C s dd� | j D �S )Nc S � g | ]}|j �qS r8 �rA �rQ �servicer8 r8 r9 rT � � z)Project.service_names.<locals>.<listcomp>)rB �rH r8 r8 r9 � service_names� s zProject.service_namesc C s& | j D ] }|j|kr| S qt|��)zo Retrieve a service by name. Raises NoSuchService if the named service does not exist. )rB rA � NoSuchService)rH rA r� r8 r8 r9 � get_service� s �zProject.get_servicec C s$ | j }|D ] }||vrt|��qdS )z� Validate that the given list of service names only contains valid services. Raises NoSuchService if one of the names is invalid. N)r� r� )rH r� � valid_namesrA r8 r8 r9 �validate_service_names� s ��z Project.validate_service_namesTc s� �j �� � |du st|�dkrd}� fdd��jD �}�fdd�|D ���fdd��jD �}|rE|D ]}|�� D ] }|� vrC� �|� q8q2|rRt� �fdd �|g �}g ��fd d�|D � �S ) aM Returns a list of this project's services filtered by the provided list of names, or all services if service_names is None or []. If include_deps is specified, returns a list including the dependencies for service_names, in order of dependency. Preserves the original order of self.services where possible, reordering as needed to resolve dependencies. Raises NoSuchService if any of the named services do not exist. Raises ConfigurationError if any service depended on is not enabled by active profiles Nr Fc s g | ] }|� � �r|j�qS r8 )�enabled_for_profilesrA r )rG r8 r9 rT � s ��z(Project.get_services.<locals>.<listcomp>c rO r8 �r� �rQ rA r� r8 r9 rT � s c � g | ]}|� v r|�qS r8 r8 �rQ �s)�unsortedr8 r9 rT � � c s �� | |� �S �N)� _inject_deps)�accr� )rG rH r8 r9 �<lambda>� s z&Project.get_services.<locals>.<lambda>c s g | ] }|� vr� � |��qS r8 )r/ r� )�uniquesr8 r9 rT � s )rG �copy�lenrB � get_profilesr/ r )rH r� � include_deps�auto_enable_profilesrB r� �profiler8 )rG rH r� r� r9 � get_services� s0 � �� �zProject.get_servicesc C s" | � ||�}|D ]}|�� q|S r� )r� �remove_duplicate_containers)rH r� r� rB r� r8 r8 r9 � get_services_without_duplicate� s z&Project.get_services_without_duplicatec C s� g }d|v rA|� dg �D ]1}d|v r|�dd�\}}n|d }}z |�| �|�|f� W q ty= td|d |f ��w |d= |S )Nr\ �:r z=Service "%s" has a link to service "%s" which does not exist.rA )ro �splitr/ r� r� r )rH rz r\ �link� service_name� link_namer8 r8 r9 rh � s" ���zProject.get_linksc C s� |� dd �}|s | jjr|rt|d �S td�S td �S t|�}|r)t| �|��S t|�}|rLz tt � | j |��W S t yK t dj|d |d���w t|�S )Nr] r �nonezRService '{name}' uses the network stack of container '{dep}' which does not exist.rA �rA �dep)rg rE r[ r r r# r� r r r �from_idrC r r r0 )rH rz rE r] r� �container_namer8 r8 r9 rj s( ���zProject.get_network_modec C � |� dd �}|s td �S t|�}|rt| �|��S t|�}|r<z tt�| j |��W S t y; t dj |d |d���w t|�S )N�pidzRService '{name}' uses the PID namespace of container '{dep}' which does not exist.rA r� ) rg r r r$ r� r r r r� rC r r r0 )rH rz r_ r� r� r8 r8 r9 rm �$ ���zProject.get_pid_modec C r� )N�ipczRService '{name}' uses the IPC namespace of container '{dep}' which does not exist.rA r� ) rg r r r" r� r r r r� rC r r r0 )rH rz r` r� r� r8 r8 r9 ri 3 r� zProject.get_ipc_modec C s� |� dd �}|� dd �}|s|d u rdS |S |� dd�dkr&|d u r$dS |S |� dd �}|d ur8|d ur8td��|d ur>|}|d u rDdS |� di �� d |�}t||�}||k r_t�d �|�� |S ) NrV �deployr �mode� replicated�replicaszUBoth service.scale and service.deploy.replicas are set. Only one of them must be set.� placement�max_replicas_per_nodez7Scale is limited to {} ('max_replicas_per_node' field).)ro r �minru rv r0 )rH rz rV � deploy_dictr� � max_replicasr8 r8 r9 rq H s2 � � �zProject.get_service_scalec C s� |� dd �}|s d S |� dd �}|r|� dd �sd S |d � d�}|s%d S |D ]*}|� dd�}t|t�sF|dkrBtd�|d �d ��d|d< d |v rQ|d g|d < q'|S ) Nr� � resources� reservations�devices�count����allz$Invalid value "{}" for devices countz(expected integer or "all")� capabilities)ro � isinstance�intr r0 )rH rz r� r� r� �devr� r8 r8 r9 rr g s, ��zProject.get_device_requestsc sL g � � �fdd�}�� |�}�fdd�}tj||t�d�d|dd� d � � S ) Nc s" | j dddi���}� �|� d S )N�quietTr8 )�start�extend)r� �service_containers)� containers�optionsr8 r9 � start_service� s z$Project.start.<locals>.start_servicec � � fdd�| � � �� D �S )Nc � h | ] \}}� � |�|f�qS r8 r� �rQ r� �configr� r8 r9 � <setcomp>� � ��z2Project.start.<locals>.get_deps.<locals>.<setcomp>��get_dependency_configs�items�r� r� r8 r9 �get_deps� � �z Project.start.<locals>.get_depsrA �Startingc S s | � � S r� )r� )�objr8 r8 r9 r� � s z Project.start.<locals>.<lambda>)� fail_check)r� r �parallel_execute�operator� attrgetter)rH r� r� r� rB r� r8 )r� r� rH r9 r� � s � z Project.startc s@ �j ||d�� � �fdd�}t�� ��d|�t�d�d|� d S )N�rM c s � �fdd��D �S )Nc s* h | ]}� j ��|j ��� v r|d f�qS r� )r� r� �get_dependency_names)rQ �other)� containerrH r8 r9 r� � s ��z1Project.stop.<locals>.get_deps.<locals>.<setcomp>r8 �r� �r� rH r� r9 r� � s z Project.stop.<locals>.get_deps�stoprA �Stopping)r� r r� �+build_container_operation_with_timeout_funcr� r� )rH r� rM r� r� r8 r� r9 r� � s �z Project.stopc K s | � |�}t�t|�|� |S r� )r� r �parallel_pause�reversed�rH r� r� r� r8 r8 r9 �pause� s z Project.pausec K s | � |�}t�||� |S r� )r� r �parallel_unpauser� r8 r8 r9 �unpause� s zProject.unpausec K s t �| �|�|� d S r� )r � parallel_killr� )rH r� r� r8 r8 r9 �kill� s z Project.killc K s t �| j|d|d�|� d S )NT)�stoppedrM )r �parallel_remover� )rH r� rM r� r8 r8 r9 �remove_stopped� s ��zProject.remove_stoppedc C sT | j tj|d� |s| �|� | j|tjd� | j�� |r#| j�� | �|� d S )N)rM �timeout)�vrM ) r� r) r2 �find_orphan_containersr� rE �removerD � remove_images)rH �remove_image_type�include_volumes�remove_orphansr� �ignore_orphansr8 r8 r9 �down� s z Project.downc C s | j D ]}|�|� qd S r� )rB � remove_image)rH r� r� r8 r8 r9 r� � s �zProject.remove_imagesc K sD dd� | � |�D �}| j|dd�}t�|| �d|�t�d�d� |S )Nc S r} r8 r~ r� r8 r8 r9 rT � r� z#Project.restart.<locals>.<listcomp>T�r� �restartrA � Restarting)r� r� r r� r� r� r� r� r8 r8 r9 r� � s �zProject.restartc s� g } | � |�D ]}|�� r| �|� q� s t�d|j � q�r.|r't�d� �r.t�d� � ��������� f dd�}|rdtj| |t � d�ddd �\}}t |�rbd � d d � |� � D ��}t|��d S | D ]}||� qfd S ) Nz%s uses an image, skippingzJFlag '--parallel' is ignored when building with COMPOSE_DOCKER_CLI_BUILD=1zJFlag '--compress' is ignored when building with COMPOSE_DOCKER_CLI_BUILD=1c s | � ����� ��� ��� d S r� )�buildr� � � build_args�cli�force_rm�gzip�memory�no_cache�progress�pull�rm�silentr8 r9 � build_service� s z$Project.build.<locals>.build_servicerA �Building� ��limit� c S �$ g | ]}t |t�r|�d �n|�qS ��utf-8�r� �bytes�decode�rQ �er8 r8 r9 rT � �z!Project.build.<locals>.<listcomp>)r� � can_be_builtr/ ru �inforA rv r r� r� r� r� rw �values� ProjectError)rH r� r r r� r r� r� �parallel_buildr r r� r rB r� r �_�errors�combined_errorsr8 r� r9 r� � s< � � �� �z Project.buildc C sT | j |dd�}|D ]}|j|d� q | �||�}|D ] }|j||j ddd� qd S )NT�r� )�do_buildF)�detachedr� )r� �ensure_image_exists�_get_convergence_plans�execute_convergence_planrA )rH r� �strategyr rB �svc�plansr� r8 r8 r9 �create s ��zProject.createc c s� � dd� }t |p | j�}| jjd| �� idd�D ](}d|vr qz t�| j|d �}W n ty3 Y qw |j|vr:q|||�V qd S )Nc S sL t j �| d �}|jt| d �d�}|d| d |j|j|j| d d�|d�S ) N�time�timeNano�� microsecondr� �status�from)rA �image�r' �type�action�idr� � attributesr� )�datetime� fromtimestamp�replacer& r1 r� rA )�eventr� r' r8 r8 r9 �build_container_event s ���z>Project._legacy_event_processor.<locals>.build_container_event�labelT��filtersr r+ r1 ) �setr� rC �eventsr7 r r� r r� )rH r� r7 r6 r� r8 r8 r9 �_legacy_event_processor s$ � � � �z Project._legacy_event_processorc sJ t �jjd�r ��|�S �fdd�� � �fdd�}||r!t|��S �j�S )Nz1.22c s� | d d }t j �| d �}|jt| d �d�}d }z t�� j| d �}W n ty. Y nw |d| d | d d |�t �d d � |� � D �|d �S ) N�Actor� Attributesr' r( r) r1 r� r+ �IDc S s i | ] \}}|� d �s||�qS )zcom.docker.compose.)� startswith)rQ �kr� r8 r8 r9 � <dictcomp>] s ��zAProject.events.<locals>.build_container_event.<locals>.<dictcomp>r. ) r3 r4 r5 r& r r� rC r ro r r� )r6 �container_attrsr' r� r� r8 r9 r7 I s* � � ��z-Project.events.<locals>.build_container_eventc 3 sn � �j jd��� idd�D ]'}|�d�dkrq z|d d t | vr$W q W n ty. Y q w � |�V q d S )Nr8 Tr9 �Typer� r> r? )rC r< r7 ro r �KeyError)r� r6 �r7 rH r8 r9 � yield_loopd s � �� � �z"Project.events.<locals>.yield_loop)r rC � api_versionr= r; r� )rH r� rH r8 rG r9 r< D s zProject.eventsc s� �� � |s ��|� �d u ri ��j||d�}|D ] }|j|||d� q�j||| |r.|ng d��t|||dd� ��� �������� � f dd�}�fdd �}t�||t� d �d |�\}}|rdt d ��d d � |D �S )Nr )r r r� )�always_recreate_depsrM c S � | j S r� r~ r� r8 r8 r9 r� � s z Project.up.<locals>.<lambda>c s2 | j �| j � � p | �v��| j������d� S )N)r� r �scale_override�rescaler� �reset_container_image�renew_anonymous_volumes�override_options)r" rA ro r� ) r rP r% rO rM rN rL �services_to_attachr� r� r8 r9 �do� s �zProject.up.<locals>.doc r� )Nc r� r8 r� r� r� r8 r9 r� � r� z/Project.up.<locals>.get_deps.<locals>.<setcomp>r� r� r� r8 r9 r� � r� z Project.up.<locals>.get_depsrA z1Encountered errors while bringing up the project.c S s" g | ] }|d ur|D ]}|�q qS r� r8 )rQ �svc_containersr� r8 r8 r9 rT � s ��z Project.up.<locals>.<listcomp>) � initializer� r� r r! r% r r� r� r� r )rH r� � start_depsr# r r� r r� r� rL rM r� rJ rN rO r r� rM �attach_dependenciesrP rB r$ rR r� �resultsr r8 ) r rP r% rO rM rN rL rH rQ r� r� r9 �upv sN � �� ���z Project.upc C s | j �� | j�� d S r� )rE rT rD r� r8 r8 r9 rT � s zProject.initializec s� i � |D ]f}� fdd�|� � D �}|o|j|v }|r_|jr_t�d|jd�|�� t|jddddgid ��}t|�� �} td d � |�� D ��} | | A } |sP|sP| rX|� t j |�} n |� ||�} n|� ||�} | � |j< q� S ) Nc s& g | ]}|� v r� | j d v r|�qS ))�recreater& )r0 r� �r% r8 r9 rT � s �z2Project._get_convergence_plans.<locals>.<listcomp>z %s has upstream changes (%s)rX Tr+ �created�exited)r� r: c s s � | ]}|� d �V qdS )zHostConfig.LinksN)ro �rQ �cr8 r8 r9 � <genexpr>� s � z1Project._get_convergence_plans.<locals>.<genexpr>) r� rA �allows_recreateru �debugrw �anyr� �get_link_names�convergence_planr �always) rH rB r# rJ rM r� �updated_dependencies� is_one_off�containers_stopped�service_has_links�container_has_links�should_recreate_for_links�planr8 rZ r9 r! � s. � �� z Project._get_convergence_plansc C s� | � ||�}|r| j||d� d S g }|D ]"}z |j||d� W q ttfy7 |�� r4|�|j� n� Y qw t|�rIt � d� d� |��� d S d S )N)r �WSome service image(s) must be built from source by running: docker-compose build {}� ) r� � parallel_pullr r r r r/ rA r� ru rv r0 rw ) rH r� �ignore_pull_failuresro r r� rB � must_buildr� r8 r8 r9 r � s$ �� ��z Project.pullc s� |sdnd �g �� ��fdd�}t j||t�d��dd�\}}t��r.t�d�d����� t|�rBd �d d � |� � D ��}t |��d S ) N�Pullingc s� | j � ddd�}|d u rd S z+tj�� }|d u r td��|D ]}d|vr%q t|�}|��| jt|�dd� � q W d S t t fyP | � � rO�� | j� Y d S � w )NT)�streamz2ParallelStreamWriter has not yet been instantiatedr+ c S s | S r� r8 �r� r8 r8 r9 r� s z=Project.parallel_pull.<locals>.pull_service.<locals>.<lambda>) r r �ParallelStreamWriter� get_instance� RuntimeErrorr �writerA r' r r r r/ )r� �strm�writerr6 r+ �rp �msgrq r8 r9 � pull_service s( ���z+Project.parallel_pull.<locals>.pull_servicerA r r rm rn r c S r r r r r8 r8 r9 rT / r z)Project.parallel_pull.<locals>.<listcomp>) r r� r� r� r� ru rv r0 rw r r )rH rB rp r r} r r r r8 r{ r9 ro s( � � ��zProject.parallel_pullc C sj t � }| j|dd�D ](}t|j�\}}}|r |�||f�n|�|df�}||vr2|�|� |�|� q d S )NFr �latest)r; r� r � image_namerw �push�add) rH r� �ignore_push_failures� unique_imagesr� �repo�tag�sep�service_image_namer8 r8 r9 r� 4 s ��z Project.pushc s� t td � fdd�� jj|d� j|d�id�D ���}|r |S t t� fdd�td � fdd�� jj|d� j|d d �id�D ����S ) Nc � g | ] }t �� j|��qS r8 �r �from_psrC �rQ r� r� r8 r9 rT @ � ��z/Project._labeled_containers.<locals>.<listcomp>r8 r� )r� r: c s | � � j�S r� )�has_legacy_proj_namerA )r^ r� r8 r9 r� I s z-Project._labeled_containers.<locals>.<lambda>c r� r8 r� r� r� r8 r9 rT I r� T)rM rN )rk �filterrC r� r7 )rH r� rM �ctnrsr8 r� r9 �_labeled_containers? s � � � �zProject._labeled_containersc s@ �r| � �� n| j�| �||�}�fdd�� � fdd�|D �S )Nc s | j �t�� v S r� )r7 ro r r� )r� r8 r9 �matches_service_namesX s z1Project.containers.<locals>.matches_service_namesc s g | ]}� |�r|�qS r8 r8 r] )r� r8 r9 rT [ r� z&Project.containers.<locals>.<listcomp>)r� r� r� )rH r� r� rM r� r8 )r� r� r9 r� P s zProject.containersc s� � fdd�}t |� �}|sd S |r7|D ]!}t�d�|j�� z|�� W n ty- Y nw |jdd� qd S t�d�d� dd � |D ���� d S ) Nc 3 sD � t � �� � jdd� �} | D ]}|j�t�}|� jvr |V qd S )NTr� )r; r� r7 ro r r� )r� �ctnrr� r� r8 r9 �_find^ s � ��z-Project.find_orphan_containers.<locals>._findz Removing orphan container "{}"T)�forcez�Found orphan containers ({}) for this project. If you removed or renamed this service in your compose file, you can run this command with the --remove-orphans flag to clean it up.rX c S s g | ]}d � |j��qS )z{})r0 rA )rQ r� r8 r8 r9 rT u r� z2Project.find_orphan_containers.<locals>.<listcomp>) rk ru r r0 rA r� r r� rv rw )rH r� r� �orphansr� r8 r� r9 r� ] s( ����z Project.find_orphan_containersc C sn |� � }t|�dkr,| jtt|��ddd�}|D ]}|�|�s*tdj|j|jd���qng }|� |� || S )Nr TF)r� r� r� z�Service "{dep_name}" was pulled in as a dependency of service "{service_name}" but is not enabled by the active profiles. You may fix this by adding a common profile to "{dep_name}" and "{service_name}".)�dep_namer� ) r� r� r� rk r; r� r r0 rA r/ )rH r� r� rG � dep_names� dep_servicesr� r8 r8 r9 r� y s& � ���� zProject._inject_depsc s � ��fdd�}|S )Nc sD �� � }|�d�d u r��| j�}|�d �|d< t| � �di |��S )Nr� r8 )r� ro r� r� � stop_timeout�getattr)r� �_optionsr� �� operationr� rH r8 r9 � container_operation_with_timeout� s z]Project.build_container_operation_with_timeout_func.<locals>.container_operation_with_timeoutr8 )rH r� r� r� r8 r� r9 r� � s z3Project.build_container_operation_with_timeout_func)NNNN)NNN)NFTr@ r� )FNF) NFFFNNFFTFFN)FN)NFTFF)FF)2r; r< r= �__doc__rI r) r1 r7 r> re �propertyr� r� r� r� r� rh rj rm ri rq rr r� r� r� r� r� r� r� r� r� r� r �changedr r� r& r= r< rX rT r! r ro r� r� r� r� r� r� r8 r8 r8 r9 r? D s� � �K 1 � �* � )3 �V � - r? c C s: g }d| v rt | d �}|�dj|d�� |r|| d< | S )N�credential_speczcredentialspec={spec})�spec� security_opt)�'convert_credential_spec_to_security_optr/ r0 )rz �resultr� r8 r8 r9 rs � s rs c C sj d| v r | d � d�|d< d| d v r t| d d �|d< d| v r3| d � d�|d< d| d v r3dgS g S )N�limitsr � mem_limit�cpusr� �mem_reservationzresources.reservations.cpus)ro �float)�resources_dictrz r8 r8 r9 �+translate_resource_keys_to_container_config� s r� c C s0 z dddd�| W S t y td�| ���w )Nre �no� on-failure)rb r� r� zInvalid restart policy "{}")rF r r0 r~ r8 r8 r9 �convert_restart_policy� s �� �r� c C s( d| v r dj | d d�S dj | d d�S )N�filez file://{file})r� zregistry://{registry}�registry)r� )r0 )r� r8 r8 r9 r� � s r� c s� d| v r| d= d| v r| d= d| vr| g fS | d � � fdd�dD �}d� v rUt � d �dd ��� d �d d �d �| d < � d �� D ]}|dkrT|d krT|�d�|�� qB|�t� �di �| �� | d= | |fS )Nr� �configsr� c r� r8 r8 )rQ rB �r� r8 r9 rT � s �z=translate_deploy_keys_to_container_config.<locals>.<listcomp>)� endpoint_moder7 � update_config�rollback_config�restart_policy� conditionrb � max_attemptsr )�Name�MaximumRetryCountr� zrestart_policy.{}r� )r� ro rl r/ r0 r� r� )rz r| rB r8 r� r9 rt � s2 � �� ��rt c s4 �� dd �}|s g S ��fdd�� � fdd�|D �S )Nr^ c s� | j dkrz | j� �| j�d�W S ty Y nw | j dkr8zt�� j| j�}| j|d�W S ty7 Y nw t d� �d | j���)Nr� )�sourcer� zWService "{}" mounts volumes from "{}", which is not the name of a service or container.rA ) r/ �_replacer� r� r� r r� rC r r r0 )r� r� )rZ rz r8 r9 �build_volume_from� s( � ���z+get_volumes_from.<locals>.build_volume_fromc s g | ]}� |��qS r8 r8 )rQ �vf)r� r8 r9 rT s z$get_volumes_from.<locals>.<listcomp>)rg )rZ rz r^ r8 )r� rZ rz r9 rn � s rn c C s� g }|D ]W}|� |j�}|stdj| |jd���|� d�r)t�dj| |jd�� q|js2|js2|jr=t�dj| |jd�� |� d�}t � t |��sSt�dj| |d�� |� ||d �� q|S ) Nz8Service "{service}" uses an undefined secret "{secret}" )r� �secret�externalz�Service "{service}" uses secret "{secret}" which is external. External secrets are not available to containers created by docker-compose.z�Service "{service}" uses secret "{secret}" with uid, gid, or mode. These fields are not supported by this implementation of the Compose filer� zwService "{service}" uses an undefined secret file "{secret_file}", the following file should be created "{secret_file}")r� � secret_file)r� r� ) ro r� r r0 ru rv �uid�gidr� r �isfile�strr/ )r� �service_secrets� secret_defsrU r� � secret_defr� r8 r8 r9 rp s> �� ��� ��rp c C s� i }t � }t � }| jD ]:}z t|�||j< W q ty. } z |�|j� W Y d }~q d }~w tyE } z |�|j� W Y d }~q d }~ww |sJ|rOt ||��|S r� ) r; rB �get_image_digestrA � NeedsPushr� r � NeedsPullr� �MissingDigests)rZ �digests� needs_push� needs_pullr� r r8 r8 r9 �get_image_digests* s ��� r� c C sr d| j vr tdj| d���t| j d �\}}}|dkr | j d S t| �}|r(|S d| j vr4t| j| j��t| j��)Nr- z�Service '{s.name}' doesn't define an image tag. An image name is required to generate a proper image digest. Specify an image repo and tag with the 'image' option.rt �@r� ) r� r r0 r � get_digestr� r rA r� )r� r � separator�digestr8 r8 r9 r� = s �� r� c C s� d }z| � � }|d r|d d }W |S W |S tyL z | �� }|d d r8dj| j|d d d�}W Y |S W Y |S tyK tdj| jd���w w ) N� RepoDigestsr � Descriptorr� z{image_name}@{digest})r r� zaDigest not found for service '{service}'. Repository does not exist or may require 'docker login'r� )r- r �get_image_registry_datar0 r r rA )r� r� r- � distributionr8 r8 r9 r� T s6 � � � � �����r� c @ � e Zd Zdd� ZdS )r� c C � || _ || _d S r� )r� r� )rH r� r� r8 r8 r9 rI o � zMissingDigests.__init__N�r; r< r= rI r8 r8 r8 r9 r� n � r� c @ r� )r� c C � || _ d S r� )r )rH r r8 r8 r9 rI u � zNeedsPush.__init__Nr� r8 r8 r8 r9 r� t r� r� c @ r� )r� c C r� r� )r r� )rH r r� r8 r8 r9 rI z r� zNeedsPull.__init__Nr� r8 r8 r8 r9 r� y r� r� c @ s e Zd Zdd� Zdd� ZdS )r� c C s* t |t�r |�d�}|| _d| j | _d S )Nr zNo such service: %s)r� r r rA r| )rH rA r8 r8 r9 rI � s zNoSuchService.__init__c C rK r� �r| r� r8 r8 r9 �__str__� s zNoSuchService.__str__N)r; r< r= rI r� r8 r8 r8 r9 r� s r� c @ r� )r c C r� r� r� )rH r| r8 r8 r9 rI � r� zProjectError.__init__Nr� r8 r8 r8 r9 r � r� r )Rr3 �enum�loggingr� rK � functoolsr �osr � docker.errorsr r r � docker.utilsr rJ r � cli.errorsr r� r � config.configr �config.sort_servicesr r �constr r r r� r �networkr r r �progress_streamr r� r r r r r r r r r r r! r" r# r$ �utilsr% r& r' �volumer( � getLoggerr; ru �unique�Enumr) r? rs r� r� r� rt rn rp r� r� r� � Exceptionr� r� r� r� r r8 r8 r8 r9 �<module> s� _ ! &