File tree 1 file changed +3
-4
lines changed
1 file changed +3
-4
lines changed Original file line number Diff line number Diff line change @@ -134,7 +134,7 @@ def join_all(self) -> None:
134
134
process .join ()
135
135
136
136
def restart_all (self ) -> None :
137
- for idx , process in enumerate (tuple ( self .processes ) ):
137
+ for idx , process in enumerate (self .processes ):
138
138
process .terminate ()
139
139
process .join ()
140
140
new_process = Process (self .config , self .target , self .sockets )
@@ -163,7 +163,7 @@ def keep_subprocess_alive(self) -> None:
163
163
if self .should_exit .is_set ():
164
164
return # parent process is exiting, no need to keep subprocess alive
165
165
166
- for idx , process in enumerate (tuple ( self .processes ) ):
166
+ for idx , process in enumerate (self .processes ):
167
167
if process .is_alive ():
168
168
continue
169
169
@@ -174,10 +174,9 @@ def keep_subprocess_alive(self) -> None:
174
174
return
175
175
176
176
logger .info (f"Child process [{ process .pid } ] died" )
177
- del self .processes [idx ]
178
177
process = Process (self .config , self .target , self .sockets )
179
178
process .start ()
180
- self .processes . append ( process )
179
+ self .processes [ idx ] = process
181
180
182
181
def handle_signals (self ) -> None :
183
182
for sig in tuple (self .signal_queue ):
You can’t perform that action at this time.
0 commit comments