python
diff --git a/‎Lib/test/libregrtest/worker.py‎
Lines changed: 1 addition & 1 deletion b/‎Lib/test/libregrtest/worker.py‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎Lib/test/test_external_inspection.py‎
Lines changed: 6 additions & 0 deletions b/‎Lib/test/test_external_inspection.py‎
Lines changed: 6 additions & 0 deletions
@@ -66,7 +66,7 @@ def create_worker_process(runtests: WorkerRunTests, output_fd: int,
         env['TSAN_OPTIONS'] = ' '.join(parts)
 
     # Pass json_file to the worker process
-    json_file = runtests.json_file
+    json_file  runtests.json_file
     json_file.configure_subprocess(kwargs)
 
     with json_file.inherit_subprocess():
 
@@ -86,6 +86,7 @@ def foo():
             p.kill()
             p.terminate()
             p.wait(timeout=SHORT_TIMEOUT)
+            subprocess._cleanup()
 
 
         expected_stack_trace = [
@@ -173,6 +174,7 @@ def new_eager_loop():
                     p.kill()
                     p.terminate()
                     p.wait(timeout=SHORT_TIMEOUT)
+                    subprocess._cleanup()
 
                 # sets are unordered, so we want to sort "awaited_by"s
                 stack_trace[2].sort(key=lambda x: x[1])
@@ -244,6 +246,7 @@ async def main():
             p.kill()
             p.terminate()
             p.wait(timeout=SHORT_TIMEOUT)
+            subprocess._cleanup()
 
         # sets are unordered, so we want to sort "awaited_by"s
         stack_trace[2].sort(key=lambda x: x[1])
@@ -310,6 +313,7 @@ async def main():
             p.kill()
             p.terminate()
             p.wait(timeout=SHORT_TIMEOUT)
+            subprocess._cleanup()
 
         # sets are unordered, so we want to sort "awaited_by"s
         stack_trace[2].sort(key=lambda x: x[1])
@@ -379,6 +383,7 @@ async def main():
             p.kill()
             p.terminate()
             p.wait(timeout=SHORT_TIMEOUT)
+            subprocess._cleanup()
 
         # sets are unordered, so we want to sort "awaited_by"s
         stack_trace[2].sort(key=lambda x: x[1])
@@ -521,6 +526,7 @@ async def main():
             p.kill()
             p.terminate()
             p.wait(timeout=SHORT_TIMEOUT)
+            subprocess._cleanup()
 
     @skip_if_not_supported
     @unittest.skipIf(sys.platform == "linux" and not PROCESS_VM_READV_SUPPORTED,