biB4ddlmZmZddlmZGddZy))errorsutils)CancellableStreamceZdZejd ddZdZd dZejd d dZy) ExecApiMixin containerNc f| 5tj|jdrtjdt |t rtj|}t | trtjj| } ||||||||| d } | :tj|jdrtjd| | d<| r| | d<n d|jvr|jd| d<|jd|} |j| | }|j|d S) aC Sets up an exec instance in a running container. Args: container (str): Target container where exec instance will be created cmd (str or list): Command to be executed stdout (bool): Attach to stdout. Default: ``True`` stderr (bool): Attach to stderr. Default: ``True`` stdin (bool): Attach to stdin. Default: ``False`` tty (bool): Allocate a pseudo-TTY. Default: False privileged (bool): Run as privileged. user (str): User to execute command as. Default: root environment (dict or list): A dictionary or a list of strings in the following format ``["PASSWORD=xxx"]`` or ``{"PASSWORD": "xxx"}``. workdir (str): Path to working directory for this exec session detach_keys (str): Override the key sequence for detaching a container. Format is a single character `[a-Z]` or `ctrl-` where `` is one of: `a-z`, `@`, `^`, `[`, `,` or `_`. ~/.docker/config.json is used by default. Returns: (dict): A dictionary with an exec ``Id`` key. Raises: :py:class:`docker.errors.APIError` If the server returns an error. z1.25z;Setting environment for exec is not supported in API < 1.25) ContainerUser PrivilegedTty AttachStdin AttachStdout AttachStderrCmdEnvz1.35z/workdir is not supported for API version < 1.35 WorkingDir detachKeysz/containers/{0}/exec)dataT)r version_lt_versionrInvalidVersion isinstancestr split_commanddictformat_environment_general_configs_url _post_json_result)selfrcmdstdoutstderrstdintty privilegeduser environmentworkdir detach_keysrurlress N/home/cdr/jupyterlab/.venv/lib/python3.12/site-packages/docker/api/exec_api.py exec_createzExecApiMixin.exec_creates4F  "u'7'7 v'N''M  c3 %%c*C k4 (++88EK#$ ""     v6++E")D  !,D  T22 2!%!6!6|!DD ii. :ooco-||C&&ct|tr|jd}|j|j d|}|j |dS)aL Return low-level information about an exec command. Args: exec_id (str): ID of the exec instance Returns: (dict): Dictionary of values returned by the endpoint. Raises: :py:class:`docker.errors.APIError` If the server returns an error. Idz/exec/{0}/jsonT)rrget_getrr!)r"exec_idr.s r/ exec_inspectzExecApiMixin.exec_inspectPsG gt $kk$'Gii "2G<=||C&&r1ct|tr|jd}||d}|jd|}|j ||}|j |y)z Resize the tty session used by the specified exec command. Args: exec_id (str): ID of the exec instance height (int): Height of tty session width (int): Width of tty session r3)hwz/exec/{0}/resize)paramsN)rrr4r_post_raise_for_status)r"r6heightwidthr;r-r.s r/ exec_resizezExecApiMixin.exec_resizecsW gt $kk$'GE*ii*G4jjVj, s#r1r6cJ||d}|rinddd}|j|jd|||d} |r" |j| | jS|r|j | S|j | |||} |r t | | S| S#| jwxYw) a? Start a previously set up exec instance. Args: exec_id (str): ID of the exec instance detach (bool): If true, detach from the exec command. Default: False tty (bool): Allocate a pseudo-TTY. Default: False stream (bool): Return response data progressively as an iterator of strings, rather than a single string. socket (bool): Return the connection socket to allow custom read/write operations. Must be closed by the caller when done. demux (bool): Return stdout and stderr separately Returns: (generator or str or tuple): If ``stream=True``, a generator yielding response chunks. If ``socket=True``, a socket object for the connection. A string containing response data otherwise. If ``demux=True``, a tuple with two elements of type byte: stdout and stderr. Raises: :py:class:`docker.errors.APIError` If the server returns an error. )r DetachUpgradetcp) ConnectionrCz/exec/{0}/startT)headersrstream)r'demux)r rr!close_get_raw_response_socket_read_from_socketr) r"r6detachr'rGsocketrHrrFr.outputs r/ exec_startzExecApiMixin.exec_startus@  "#%  oo II' 1    ||C( 005 5''VE'J $VS1 1M s BB") TTFFFNNN)NN)FFFFF) __name__ __module__ __qualname__rcheck_resourcer0r7r@rOr1r/rrs^U+&>BCE@DG''G'R'&$$U)$BG',:%:r1rN)rPrrtypesrrrUr1r/rWs%kkr1