@@ -251,7 +251,6 @@ def _stderr_loop(self) -> None:
251
251
def create_transport (config : TransportConfig , cwd : Optional [str ],
252
252
callback_object : TransportCallbacks ) -> Transport [Dict [str , Any ]]:
253
253
stderr = subprocess .PIPE
254
- pass_fds = () # type: Union[Tuple[()], Tuple[int]]
255
254
if config .tcp_port is not None :
256
255
assert config .tcp_port is not None
257
256
if config .tcp_port < 0 :
@@ -263,7 +262,6 @@ def create_transport(config: TransportConfig, cwd: Optional[str],
263
262
stdout = subprocess .PIPE
264
263
stdin = subprocess .DEVNULL
265
264
stderr = subprocess .STDOUT
266
- pass_fds = (config .node_ipc .child_connection .fileno (),)
267
265
else :
268
266
stdout = subprocess .PIPE
269
267
stdin = subprocess .PIPE
@@ -273,7 +271,7 @@ def create_transport(config: TransportConfig, cwd: Optional[str],
273
271
process = None # type: Optional[subprocess.Popen]
274
272
275
273
def start_subprocess () -> subprocess .Popen :
276
- return _start_subprocess (config .command , stdin , stdout , stderr , startupinfo , config .env , cwd , pass_fds )
274
+ return _start_subprocess (config .command , stdin , stdout , stderr , startupinfo , config .env , cwd )
277
275
278
276
if config .listener_socket :
279
277
assert isinstance (config .tcp_port , int ) and config .tcp_port > 0
@@ -355,8 +353,7 @@ def _start_subprocess(
355
353
stderr : int ,
356
354
startupinfo : Any ,
357
355
env : Dict [str , str ],
358
- cwd : Optional [str ],
359
- pass_fds : Union [Tuple [()], Tuple [int ]]
356
+ cwd : Optional [str ]
360
357
) -> subprocess .Popen :
361
358
debug ("starting {} in {}" .format (args , cwd if cwd else os .getcwd ()))
362
359
process = subprocess .Popen (
@@ -367,7 +364,7 @@ def _start_subprocess(
367
364
startupinfo = startupinfo ,
368
365
env = env ,
369
366
cwd = cwd ,
370
- pass_fds = pass_fds )
367
+ close_fds = False )
371
368
_subprocesses .add (process )
372
369
return process
373
370
0 commit comments