biKDddlmZmZmZddlmZdZdZGddZy))autherrorsutils) ServiceModecrd}|tj|drd|vr |ddd|vr |ddtj|dr|jdd k(r |d dtj|d r d |vr |d d |Btj|dr |ddtj|d r d |vr |dd |8tj|dr"d|vrtd|dDr |dd|d|vrtj|dr |dd|jdrftj|dr|djdr |ddtj|dr|djdr |dd|jdr|jd}tj|dr|jdr |dd|jd  |d!d|jd" |d#d|jd$ |d%d|jd& |d'd|jd( |d)dtj|dr4|jd* |d'd|jd+ |d,dtj|dr4|jd- |d.d|jd/ |d0dtj|d1r|jd2 |d3d1tj|d4r|jd5 |d6d4|jd7r6tj|dr|d7jd8r |d9dyyyyy):Nc6tj|d|)Nz# is not supported in API version < )rInvalidVersion)param min_versions M/home/cdr/jupyterlab/.venv/lib/python3.12/site-packages/docker/api/service.pyraise_version_errorz0_check_api_features..raise_version_errors$##g8 F  1.25MaxFailureRatiozUpdateConfig.max_failure_ratioMonitorzUpdateConfig.monitorz1.28 FailureActionrollbackz$UpdateConfig.failure_action rollback1.29OrderzUpdateConfig.orderrollback_configzRollbackConfig.orderz1.32Portsc3>K|]}|jdyw) PublishModeN)get).0ps r z&_check_api_features..(sHA155'HszEndpointSpec.Ports[].mode ForceUpdate force_update Placementz1.30 PlatformszPlacement.platformsz1.27 PreferenceszPlacement.preferences ContainerSpecTTYzContainerSpec.ttyHostnamezContainerSpec.hostnameHostszContainerSpec.hostsGroupszContainerSpec.groups DNSConfigzContainerSpec.dns_config HealthcheckzContainerSpec.healthcheckReadOnly StopSignalzContainerSpec.stop_signalConfigszContainerSpec.configs PrivilegeszContainerSpec.privilegesz1.35 IsolationzContainerSpec.isolationz1.38InitzContainerSpec.init ResourcesGenericResourceszResources.generic_resources)r version_ltrany)version task_template update_config endpoint_specrr container_specs r _check_api_featuresr9s    GV , M1#$DfMM)#$:FC   GV ,  1Z?#:F   GV ,-'#$8&A"   GV ,  16 :   GV ,-'#$:FC   GV ,M1IHw1GHH#$?H M )e.>.>/!  7   [ )0 -11+>'(=vF0 -11-@'(?H   _ -*..?N0!%%e,'(;VD!%%j1='(@&I!%%g.:'(=vF!%%h/;'(>G!%%k2>'(BFK!%%m4@'(CVL0!%%j1='(BFK!%%l3?'(CVL0!%%i0<'(?H!%%l3?'(BFK0!%%k2>'(A6J0!%%f-9'(|||<D|S)Nr#)copyitems)currentoverridemergedts_keyts_valuecs_keycs_values r _merge_task_templaterDcs \\^F ( 0 * FH("&0.0F?+(0(A(G(G(IC$FH+:B/7C%!)v * MrceZdZejd ddZejdej dddZejdej ddZejdej ddZ ejddd Z ejd ej d dd Z ejddd Z ejdej d dd Z y)ServiceApiMixinz1.24Nc xt|j|||| |jd} i} |jdijdd} | t j d|rt |ts t|}tj| \} }tj|| }|r|| d<tj|jdr|xs|jdd}||||tj||d }|||d <| | |d <|j!|j#| || d S)a Create a service. Args: task_template (TaskTemplate): Specification of the task to start as part of the new service. name (string): User-defined name for the service. Optional. labels (dict): A map of labels to associate with the service. Optional. mode (ServiceMode): Scheduling mode for the service (replicated or global). Defaults to replicated. update_config (UpdateConfig): Specification for the update strategy of the service. Default: ``None`` rollback_config (RollbackConfig): Specification for the rollback strategy of the service. Default: ``None`` networks (:py:class:`list`): List of network names or IDs or :py:class:`~docker.types.NetworkAttachmentConfig` to attach the service to. Default: ``None``. endpoint_spec (EndpointSpec): Properties that can be configured to access and load balance a service. Default: ``None``. Returns: A dictionary containing an ``ID`` key for the newly created service. Raises: :py:class:`docker.errors.APIError` If the server returns an error. z/services/creater#ImageNz,Missing mandatory Image key in ContainerSpecX-Registry-AuthrNetworks)NameLabels TaskTemplateModerJ EndpointSpec UpdateConfigRollbackConfig)dataheadersT)r9_version_urlrrDockerException isinstancedictrrresolve_repository_nameget_config_headerrr2popconvert_service_networks_result _post_json)selfr5namelabelsmoder6networksendpoint_configr7rurlrSimageregistry repo_name auth_headerrRs r create_servicezServiceApiMixin.create_servicessQH  MM=-  ii*+!!/26::7DI =((>   4.t$D"::5A),,T8< )4G% &   DMM6 2F=#4#4Z#FH)66x@)    $#0D  &%4D! "|| OOCdGO ))$&&577:s5%7H ##D#v66rcd|rtj|ndi}|jd}|j|j ||dS)a Retrieve a list of tasks. Args: filters (dict): A map of filters to process on the tasks list. Valid filters: ``id``, ``name``, ``service``, ``node``, ``label`` and ``desired-state``. Returns: (:py:class:`list`): List of task dictionaries. Raises: :py:class:`docker.errors.APIError` If the server returns an error. r}Nz/tasksroT)rrrUr]rq)r_r}rpres r taskszServiceApiMixin.tasksWsM& u,,W5d ii!||DIIc&I94@@rc @t|j||| | | r;d} tj|jdrd} |j || d}ni}|j d|}i}i}||j dn||d<||j dn||d<|!t|ts t|}||d <n|j d |d <t|j d i||d <|d j d i}|j d d}|5tj|\}}tj||}|r||d <|||d<n|j d|d<| | |d<n|j d|d<|Dtj|}tj|jdr||d<n||d d<ntj|jdr|j d|d<nT|d j d@|j d i}|j d}||j d}|||d d<| | |d<n|j d|d<|j||d|i|}|j!|dS)a Update a service. Args: service (string): A service identifier (either its name or service ID). version (int): The version number of the service object being updated. This is required to avoid conflicting writes. task_template (TaskTemplate): Specification of the updated task to start as part of the service. name (string): New name for the service. Optional. labels (dict): A map of labels to associate with the service. Optional. mode (ServiceMode): Scheduling mode for the service (replicated or global). Defaults to replicated. update_config (UpdateConfig): Specification for the update strategy of the service. Default: ``None``. rollback_config (RollbackConfig): Specification for the rollback strategy of the service. Default: ``None`` networks (:py:class:`list`): List of network names or IDs or :py:class:`~docker.types.NetworkAttachmentConfig` to attach the service to. Default: ``None``. endpoint_spec (EndpointSpec): Properties that can be configured to access and load balance a service. Default: ``None``. fetch_current_spec (boolean): Use the undefined settings from the current specification of the service. Default: ``False`` Returns: A dictionary containing a ``Warnings`` key. Raises: :py:class:`docker.errors.APIError` If the server returns an error. TrN)rrrz/services/{0}/updaterKrLrNrMr#rHrIrPrQrrJrOr4)rRrprS)json)r9rTrr2rsrUrrWrXrrDrrYrZr\r^r])r_rkr4r5r`rarbr6rcrdr7fetch_current_specrinspect_defaultsr=rerRrSr8rfrgrhriconverted_networkscurrent_task_templatecurrent_networksrzs r update_servicezServiceApiMixin.update_serviceosT  MM=-  #  v6#' **)9+G Gii.8.2lw{{6*V 28.X.fX  dD)"4(DL";;v.DL3 KK +] ^n-11/2F""7D1  "&">">u"E Hi00x@K-8)*  $#0D #*;;~#>D  &%4D! "%,[[1A%BD! "  !&!?!?!I  v6#5Z 3E^$Z0   dmmV 4&{{:6D  . ! % %j 1 9$+KK$C !488D '#*;;z#: +3C^$Z0  $#0D #*;;~#>D  dIw#7 ||Dt|,,r)NNNNNNNN)N)NN)FFFFFallN) NNNNNNNNFN)__name__ __module__ __qualname__rminimum_versionrjcheck_resourcersrvr{rrrrrr rFrFrsU6">B?C04I #I VU6"U)$A%#A8U6"U&!2"#2"U6"U)$%#(U6"A#A<U6"U)$HMCH .7%#.7`U6"A#A.U6"U)$HL=A6:>C'+ u-%#u-rrFN) rrrtypesrr9rDrFrrr rs'""[O| t-t-r