}id6ddlZddlmZmZddlmZmZmZmZddl m Z m Z Gdde Z Gdd e Z gd Zgd Zgd Zgd ZdZy)N)InvalidArgumentcreate_unexpected_kwargs_error) ContainerSpec Placement ServiceMode TaskTemplate) CollectionModelcZeZdZdZdZedZedZdZd dZ dZ d Z d Z d Z y) Servicez A service.IDc&|jddS)zThe service's name.SpecName)attrsselfs ]/home/factor_ks/STREAMA2026/tests/venv/lib/python3.12/site-packages/docker/models/services.pynamez Service.name szz&!&))cV|jjdjdS)z The version number of the service. If this is not the same as the server, the :py:meth:`update` function will not work and you will need to call :py:meth:`reload` before calling it again. VersionIndex)rgetrs rversionzService.versions"zz~~i(,,W55rc`|jjj|jS)z Stop and remove the service. Raises: :py:class:`docker.errors.APIError` If the server returns an error. )clientapiremove_serviceidrs rremovezService.removes!{{--dgg66rNct|i}|j|d<|jjj|S)a List the tasks in this service. Args: filters (dict): A map of filters to process on the tasks list. Valid filters: ``id``, ``name``, ``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. service)filters)r!rrtasks)rr%s rr&z Service.tasks%s8 ?G!WW {{$$W$55rc dd|vr|jddd}|d|d<|jddur5|jdd}t|jdd }|d z|d<td |}|jj j |j|jfi|S) a) Update a service's configuration. Similar to the ``docker service update`` command. Takes the same parameters as :py:meth:`~ServiceCollection.create`. Raises: :py:class:`docker.errors.APIError` If the server returns an error. imagerrrImage force_updateT ForceUpdaterr update) rrint_get_create_service_kwargsrrupdate_servicer!r)rkwargsspec task_template current_value create_kwargss rr,zService.update:s & ::f%n5oFD"7mF7O ::n % - JJv.~>M 1 1- CDM%2Q%6F> "28VD -t{{-- GG LL   rc |jdddjdd}|jjj|j fd|i|S)a Get log stream for the service. Note: This method works only for services with the ``json-file`` or ``journald`` logging drivers. Args: details (bool): Show extra details provided to logs. Default: ``False`` follow (bool): Keep connection open to read logs as they are sent by the Engine. Default: ``False`` stdout (bool): Return logs from ``stdout``. Default: ``False`` stderr (bool): Return logs from ``stderr``. Default: ``False`` since (int): UNIX timestamp for the logs staring point. Default: 0 timestamps (bool): Add timestamps to every log line. tail (string or int): Number of log lines to be returned, counting from the current end of the logs. Specify an integer or ``'all'`` to output all log lines. Default: ``all`` Returns: generator: Logs for the service. rrrTTYFis_tty)rrrr service_logsr!)rr0r7s rlogsz Service.logsWsW0F#N3ODHH 5 ,t{{++DGGMFMfMMrcd|jddjvr tdtd|}|jj j |j|j|dS)z Scale service container. Args: replicas (int): The number of containers that should be running. Returns: bool: ``True`` if successful. GlobalrModezCannot scale a global container replicatedT)modefetch_current_spec) rkeysrrrrr/r!r)rreplicas service_modes rscalez Service.scaletso tzz&)&1668 8!"CD D"<: {{--dggt||3?AE.G Grc(|jddS)z Force update the service even if no changes require it. Returns: bool: ``True`` if successful. T)r*r?)r,rs rr*zService.force_updates{{{FFrN)__name__ __module__ __qualname____doc__ id_attributepropertyrrr"r&r,r9rCr*rrr r sQL **6676* :N:G&Grr c*eZdZdZeZddZddZdZy)ServiceCollectionzServices on the Docker server.Nc ||d<||d<td|}|jjjdi|}|j |S)a Create a service. Similar to the ``docker service create`` command. Args: image (str): The image name to use for the containers. command (list of str or str): Command to run. args (list of str): Arguments to the command. constraints (list of str): :py:class:`~docker.types.Placement` constraints. preferences (list of tuple): :py:class:`~docker.types.Placement` preferences. maxreplicas (int): :py:class:`~docker.types.Placement` maxreplicas or (int) representing maximum number of replicas per node. platforms (list of tuple): A list of platform constraints expressed as ``(arch, os)`` tuples. container_labels (dict): Labels to apply to the container. endpoint_spec (EndpointSpec): Properties that can be configured to access and load balance a service. Default: ``None``. env (list of str): Environment variables, in the form ``KEY=val``. hostname (string): Hostname to set on the container. init (boolean): Run an init inside the container that forwards signals and reaps processes isolation (string): Isolation technology used by the service's containers. Only used for Windows containers. labels (dict): Labels to apply to the service. log_driver (str): Log driver to use for containers. log_driver_options (dict): Log driver options. mode (ServiceMode): Scheduling mode for the service. Default:``None`` mounts (list of str): Mounts for the containers, in the form ``source:target:options``, where options is either ``ro`` or ``rw``. name (str): Name to give to the service. networks (:py:class:`list`): List of network names or IDs or :py:class:`~docker.types.NetworkAttachmentConfig` to attach the service to. Default: ``None``. resources (Resources): Resource limits and reservations. restart_policy (RestartPolicy): Restart policy for containers. secrets (list of :py:class:`~docker.types.SecretReference`): List of secrets accessible to containers for this service. stop_grace_period (int): Amount of time to wait for containers to terminate before forcefully killing them. 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`` user (str): User to run commands as. workdir (str): Working directory for commands to run. tty (boolean): Whether a pseudo-TTY should be allocated. groups (:py:class:`list`): A list of additional groups that the container process will run as. open_stdin (boolean): Open ``stdin`` read_only (boolean): Mount the container's root filesystem as read only. stop_signal (string): Set signal to stop the service's containers healthcheck (Healthcheck): Healthcheck configuration for this service. hosts (:py:class:`dict`): A set of host to IP mappings to add to the container's `hosts` file. dns_config (DNSConfig): Specification for DNS related configurations in resolver configuration file. configs (:py:class:`list`): List of :py:class:`~docker.types.ConfigReference` that will be exposed to the service. privileges (Privileges): Security options for the service's containers. cap_add (:py:class:`list`): A list of kernel capabilities to add to the default set for the container. cap_drop (:py:class:`list`): A list of kernel capabilities to drop from the default set for the container. sysctls (:py:class:`dict`): A dict of sysctl values to add to the container Returns: :py:class:`Service`: The created service. Raises: :py:class:`docker.errors.APIError` If the server returns an error. r(commandcreaterL)r.rrcreate_servicer)rr(rPr0r4 service_ids rrQzServiceCollection.createsPd w#y28VD 3T[[__33DmD xx ##rcl|j|jjj||S)a} Get a service. Args: service_id (str): The ID of the service. insert_defaults (boolean): If true, default values will be merged into the output. Returns: :py:class:`Service`: The service. Raises: :py:class:`docker.errors.NotFound` If the service does not exist. :py:class:`docker.errors.APIError` If the server returns an error. :py:class:`docker.errors.InvalidVersion` If one of the arguments is not supported with the current API version. ) prepare_modelrrinspect_service)rrSinsert_defaultss rrzServiceCollection.gets/*!! KKOO + +J H  rc |jjjdi|Dcgc]}|j|c}Scc}w)a List services. Args: filters (dict): Filters to process on the nodes list. Valid filters: ``id``, ``name`` , ``label`` and ``mode``. Default: ``None``. status (bool): Include the service task count of running and desired tasks. Default: ``None``. Returns: list of :py:class:`Service`: The services. Raises: :py:class:`docker.errors.APIError` If the server returns an error. rL)rrservicesrU)rr0ss rlistzServiceCollection.listsG(.T[[__--77    q !   sArE) rFrGrHrIr modelrQrr[rLrrrNrNs( EV$p 2 rrN)argscap_addcap_droprPconfigs dns_configenvgroups healthcheckhostnamehostsr(init isolationlabelsmounts open_stdin privileges read_onlysecretsstop_grace_period stop_signalttyuserworkdirsysctls)networks resourcesrestart_policy)rrir> update_configrollback_config endpoint_spec) constraints preferences platforms maxreplicasc4i}tj|D]}|tvs |j|||<!i}tj|D]}|tvs |j|||<!i}tj|D]}|tvs |j|||<!d|vr|jd|d<i}tj|D]}|t vs |j|||<!t d i|}||d<d|vr'|jd|jdid|d<|dk(r/d|vr|jd|d<|jd d }||d <|r t||td i|}||d <td i||d <|S)Ncontainer_labelsri placement log_driverlog_driver_options)rOptionsr,r*r?Tcontainer_specr2rL) copyCREATE_SERVICE_KWARGSpopCONTAINER_SPEC_KWARGSTASK_TEMPLATE_KWARGSPLACEMENT_KWARGSrrrr) func_namer0r4keycontainer_spec_kwargstask_template_kwargsrr?rs rr.r.VsMyy 1 ' '!'CM# 1yy 9 ' ')/C !# &9yy 8 & &(. 3  %8V#*0**5G*Hh'Iyy - " "#ZZ_IcN-&I&I(1%vJJ|,zz"6;. \* H V #39::n3M  0$ZZ(rsY ILL'FGeFGRJ J \<0r