Worker memory_monitor

The nanny isn't involved in this test though

All those calls to terminate() sends SIGTERM, not SIGKILL:

Lines 261 to 288 in c992f80

    
               def terminate(self) -> asyncio.Future[None]: 
        
                   """Terminate the child process. 
        
                   This method returns a future. 
        
                   See also 
        
                   -------- 
        
                   multiprocessing.Process.terminate 
        
                   """ 
        
                   self._check_closed() 
        
                   fut: Future[None] = Future() 
        
                   self._watch_q.put_nowait({"op": "terminate", "future": fut}) 
        
                   return fut 
        
               def kill(self) -> asyncio.Future[None]: 
        
                   """Send SIGKILL to the child process. 
        
                   On Windows, this is the same as terminate(). 
        
                   This method returns a future. 
        
                   See also 
        
                   -------- 
        
                   multiprocessing.Process.kill 
        
                   """ 
        
                   self._check_closed() 
        
                   fut: Future[None] = Future() 
        
                   self._watch_q.put_nowait({"op": "kill", "future": fut}) 
        
                   return fut

distributed/distributed/process.py

Lines 219 to 224 in c992f80

    
           elif op == "terminate": 
        
               # Send SIGTERM 
        
               _call_and_set_future(loop, msg["future"], process.terminate) 
        
           elif op == "kill": 
        
               # Send SIGKILL 
        
               _call_and_set_future(loop, msg["future"], process.kill)

	def terminate(self) -> asyncio.Future[None]:
	"""Terminate the child process.

	This method returns a future.

	See also
	--------
	multiprocessing.Process.terminate
	"""
	self._check_closed()
	fut: Future[None] = Future()
	self._watch_q.put_nowait({"op": "terminate", "future": fut})
	return fut

	def kill(self) -> asyncio.Future[None]:
	"""Send SIGKILL to the child process.
	On Windows, this is the same as terminate().

	This method returns a future.

	See also
	--------
	multiprocessing.Process.kill
	"""
	self._check_closed()
	fut: Future[None] = Future()
	self._watch_q.put_nowait({"op": "kill", "future": fut})
	return fut

	elif op == "terminate":
	# Send SIGTERM
	_call_and_set_future(loop, msg["future"], process.terminate)
	elif op == "kill":
	# Send SIGKILL
	_call_and_set_future(loop, msg["future"], process.kill)

Uh oh!

distributed/tests/test_asyncprocess.py::test_signal flaky #6393

Description

Metadata

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Issue actions

`distributed/tests/test_asyncprocess.py::test_signal` flaky #6393