common.runners.stdout

exec_to_stdout

@contextmanager
def exec_to_stdout(f: AnyFun) -> Iterator[Any]

[view_source]

Executes parameter-less function f and encodes the pickled return value to stdout. In case of exceptions, encodes the pickled exceptions to stderr

iter_std

def iter_std(venv: Venv, command: str, *script_args:
             Any) -> Iterator[Tuple[OutputStdStreamNo, str]]

[view_source]

Starts a process command with script_args in environment venv and returns iterator of (filno, line) tuples where fileno is 1 for stdout and 2 for stderr. line is a content of a line with stripped new line character.

Use -u in scripts_args for unbuffered python execution

iter_stdout_with_result

def iter_stdout_with_result(venv: Venv, command: str, *script_args:
                            Any) -> Generator[str, None, Any]

[view_source]

Yields stdout lines coming from remote process and returns the last result decoded with decode_obj. In case of exit code != 0 if exception is decoded it will be raised, otherwise CalledProcessError is raised