Skip to content

get_subprocess

faststream.cli.supervisors.utils.get_subprocess #

get_subprocess(
    target: DecoratedCallableNone, args: Any
) -> SpawnProcess

Spawn a subprocess.

PARAMETER DESCRIPTION
target

The target function to be executed in the subprocess.

TYPE: DecoratedCallableNone

args

The arguments to be passed to the target function.

TYPE: Any

RETURNS DESCRIPTION
SpawnProcess

The spawned subprocess.
RAISES DESCRIPTION
OSError

If there is an error getting the file descriptor of sys.stdin.
Source code in faststream/cli/supervisors/utils.py 
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
def get_subprocess(target: DecoratedCallableNone, args: Any) -> SpawnProcess:
    """Spawn a subprocess.

    Args:
        target: The target function to be executed in the subprocess.
        args: The arguments to be passed to the target function.

    Returns:
        The spawned subprocess.

    Raises:
        OSError: If there is an error getting the file descriptor of sys.stdin.

    """
    stdin_fileno: Optional[int]
    try:
        stdin_fileno = sys.stdin.fileno()
    except OSError:
        stdin_fileno = None

    return spawn.Process(
        target=subprocess_started,
        args=args,
        kwargs={"t": target, "stdin_fileno": stdin_fileno},
    )