o 2.a@s*ddlmZddlmZGdddZdS))errors)utilsc@sPeZdZed   dddZdd Zdd d Zed   dd dZdS) ExecApiMixin containerTFNc  Cs| durt|jdrtdt|trt|}t| tr%tj | } ||||||||| d } | durEt|jdrAtd| | d<| rL| | d<n d|j vrX|j d| d<| d |} |j | | d }| |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. Nz1.25z;Setting environment for exec is not supported in API < 1.25) ContainerZUserZ PrivilegedTtyZ AttachStdinZ AttachStdoutZ AttachStderrZCmdZEnvz1.35z/workdir is not supported for API version < 1.35Z WorkingDirZ detachKeysz/containers/{0}/exec)dataT)rZ version_ltZ_versionrZInvalidVersion isinstancestrZ split_commanddictZformat_environmentZ_general_configs_url _post_json_result)selfrcmdstdoutstderrstdinttyZ privilegeduserZ environmentZworkdirZ detach_keysr urlresr5/usr/lib/python3/dist-packages/docker/api/exec_api.py exec_creates>#         zExecApiMixin.exec_createcCs2t|tr |d}||d|}||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)r r getZ_getr r)rexec_idrrrr exec_inspectPs   zExecApiMixin.exec_inspectcCsFt|tr |d}||d}|d|}|j||d}||dS)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 r)hwz/exec/{0}/resize)paramsN)r r rr Z_postZ_raise_for_status)rrZheightwidthr"rrrrr exec_resizecs   zExecApiMixin.exec_resizerc Csd||d}|r inddd}|j|d|||dd} |r"|| S|r)|| S|j| |||dS) 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): Stream response data. Default: False socket (bool): Return the connection socket to allow custom read/write operations. 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. )rZDetachUpgradeZtcp)Z Connectionr%z/exec/{0}/startT)headersr stream)rdemux)rr rZ_get_raw_response_socketZ_read_from_socket) rrdetachrr'Zsocketr(r r&rrrr exec_startus$   zExecApiMixin.exec_start) TTFFFrNNN)NN)FFFFF) __name__ __module__ __qualname__rZcheck_resourcerrr$r*rrrrrs I rN)rrrrrrrrs