Pipes de subprocess en Python: vacía ambos flujos antes de esperar indefinidamente

Qué es

La documentación de subprocess de Python advierte de que Popen.wait puede provocar un interbloqueo (deadlock) cuando stdout o stderr es un pipe y el proceso hijo llena el búfer de pipe del sistema operativo. communicate coordina la entrada y la salida, pero almacena en memoria los datos capturados. Por eso la documentación distingue entre una vía cómoda para salidas de tamaño acotado y las cargas de trabajo que requieren streaming deliberado y límites de almacenamiento. Python subprocess

Por qué importa

Un agente puede aumentar un timeout mientras el proceso padre y el hijo se esperan mutuamente. Lo primero es averiguar quién tiene que avanzar: el padre, que debe vaciar la salida; el hijo, que debe leer su entrada; o el hijo, que debe terminar. Esperar más tiempo no soluciona la ausencia de un consumidor.

Cómo aplicarlo

• Anota cómo están conectados stdin, stdout y stderr. Comprueba si el padre lee un flujo por completo antes de tocar el otro, o si espera a que el hijo termine antes de leer cualquiera de los dos.
• Si la salida es de tamaño acotado y conocido, usa la invocación de alto nivel documentada o la vía de communicate. Define un timeout adecuado a la tarea y gestiona explícitamente el fallo resultante.
• Si la salida puede ser grande, diseña un vaciado concurrente hacia un almacenamiento acotado o hacia un pipeline de procesamiento acotado. Especifica qué ocurre cuando la salida supera su límite, en lugar de acumularla indefinidamente.
• Distingue el comportamiento del timeout de subprocess.run del manejo del timeout en Popen.communicate invocado directamente. Este último exige decidir explícitamente cómo limpiar; sigue la secuencia documentada de terminate o kill y vaciado de la salida que corresponda a la política deseada.
• Propón un fixture de proceso hijo que escriba una cantidad considerable de datos en ambos flujos, además de fixtures para la terminación anticipada y para el timeout. Comprueba tanto la limpieza de procesos como el contenido capturado.

Trampas

La capacidad de un pipe es un detalle de implementación, así que evita que producción dependa de un tamaño de búfer medido. Un timeout no es una política universal para terminar un árbol de procesos. Considera aparte los procesos nietos cuando la herramienta pueda crearlos. Los fixtures propuestos son pruebas de diagnóstico acotadas; no afirman que se haya probado ningún comando concreto ni que capture_output sea seguro para salidas ilimitadas.