@@ -93,33 +93,33 @@ def run_subprocess(
93
93
stderr = process_stderr ,
94
94
env = env ,
95
95
) as process :
96
- try :
97
- if pipe_output :
98
- logger_map = {
99
- process .stdout .fileno (): _LineLogger (LOGGER .debug ),
100
- process .stderr .fileno (): _LineLogger (LOGGER .warning ),
101
- }
96
+ logger_map = {
97
+ process .stdout .fileno (): _LineLogger (LOGGER .debug ),
98
+ process .stderr .fileno (): _LineLogger (LOGGER .warning ),
99
+ }
102
100
103
- line_map = {
104
- process .stdout .fileno (): stdout_list ,
105
- process .stderr .fileno (): stderr_list ,
106
- }
101
+ line_map = {
102
+ process .stdout .fileno (): stdout_list ,
103
+ process .stderr .fileno (): stderr_list ,
104
+ }
107
105
108
- fds = list (line_map .keys ())
106
+ file_descriptors = list (line_map .keys ())
109
107
110
- while fds :
111
- ret = select .select (fds , [], [])
108
+ try :
109
+ if pipe_output :
110
+ while file_descriptors :
111
+ ret = select .select (file_descriptors , [], [])
112
112
113
- for fd in ret [0 ]:
114
- logger = logger_map [fd ]
115
- lines = line_map [fd ]
116
- buff = os .read (fd , 8192 )
113
+ for file_descriptor in ret [0 ]:
114
+ logger = logger_map [file_descriptor ]
115
+ lines = line_map [file_descriptor ]
116
+ buff = os .read (file_descriptor , 8192 )
117
117
if buff :
118
118
lines .append (buff )
119
119
if log_output_live :
120
120
logger .log (buff )
121
121
else :
122
- fds .remove (fd )
122
+ file_descriptors .remove (file_descriptor )
123
123
logger .flush ()
124
124
125
125
# stderr/stdout are not readable anymore which usually means
0 commit comments