@@ -3392,6 +3392,7 @@ class _TestMyManager(BaseTestCase):
33923392 ALLOWED_TYPES = ('manager' ,)
33933393
33943394 @warnings_helper .ignore_fork_in_thread_deprecation_warnings ()
3395+ @support .skip_if_sanitizer ('TSan: leaks threads' , thread = True )
33953396 def test_mymanager (self ):
33963397 manager = MyManager (shutdown_timeout = SHUTDOWN_TIMEOUT )
33973398 manager .start ()
@@ -3404,6 +3405,7 @@ def test_mymanager(self):
34043405 self .assertIn (manager ._process .exitcode , (0 , - signal .SIGTERM ))
34053406
34063407 @warnings_helper .ignore_fork_in_thread_deprecation_warnings ()
3408+ @support .skip_if_sanitizer ('TSan: leaks threads' , thread = True )
34073409 def test_mymanager_context (self ):
34083410 manager = MyManager (shutdown_timeout = SHUTDOWN_TIMEOUT )
34093411 with manager :
@@ -3414,6 +3416,7 @@ def test_mymanager_context(self):
34143416 self .assertIn (manager ._process .exitcode , (0 , - signal .SIGTERM ))
34153417
34163418 @warnings_helper .ignore_fork_in_thread_deprecation_warnings ()
3419+ @support .skip_if_sanitizer ('TSan: leaks threads' , thread = True )
34173420 def test_mymanager_context_prestarted (self ):
34183421 manager = MyManager (shutdown_timeout = SHUTDOWN_TIMEOUT )
34193422 manager .start ()
@@ -3485,6 +3488,7 @@ def _putter(cls, address, authkey):
34853488 queue .put (tuple (cls .values ))
34863489
34873490 @warnings_helper .ignore_fork_in_thread_deprecation_warnings ()
3491+ @support .skip_if_sanitizer ('TSan: leaks threads' , thread = True )
34883492 def test_remote (self ):
34893493 authkey = os .urandom (32 )
34903494
@@ -3527,6 +3531,7 @@ def _putter(cls, address, authkey):
35273531 queue .put ('hello world' )
35283532
35293533 @warnings_helper .ignore_fork_in_thread_deprecation_warnings ()
3534+ @support .skip_if_sanitizer ("TSan: leaks threads" , thread = True )
35303535 def test_rapid_restart (self ):
35313536 authkey = os .urandom (32 )
35323537 manager = QueueManager (
0 commit comments