pub async fn exec_timeout(
parts: Vec<String>,
ctx: &WatchContext,
logger: &Logger,
timeout: u64,
env: Option<HashMap<String, String>>,
output_strategy: &OutpuStrategy,
pipe_registry: Arc<Mutex<PipeRegistry>>,
) -> Result<CommandOutput, Error>