tests/test_process_executor_loky.py::TestsProcessPoolLokyShutdown::test_shutdown_with_sys_exit_at_pickle <- tests\_test_process_executor.py
+++++++++++++++++++++++++++++++++++ Timeout ++++++++++++++++++++++++++++++++++++
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ Captured stderr ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
[DEBUG:MainProcess:MainThread] shutting down executor <loky.process_executor.ProcessPoolExecutor object at 0x043D0690>
[DEBUG/LokyProcess-33] Using default backend pickle for pickling.
[DEBUG/LokyProcess-33] recreated blocker with handle 20
[DEBUG/LokyProcess-33] recreated blocker with handle 24
[DEBUG/LokyProcess-33] Queue._after_fork()
[DEBUG/LokyProcess-33] recreated blocker with handle 28
[DEBUG/LokyProcess-33] recreated blocker with handle 32
[INFO/LokyProcess-33] child process calling self.run()
[DEBUG/LokyProcess-33] worker started with timeout=None
[DEBUG:MainProcess:QueueManager] queue management thread shutting down
[DEBUG:MainProcess:QueueManager] closing call_queue
[DEBUG:MainProcess:QueueManager] telling queue thread to quit
[DEBUG:MainProcess:QueueManager] joining processes
[DEBUG:MainProcess:QueueFeederThread] feeder thread got sentinel -- exiting
[INFO/LokyProcess-32] shutting down worker on sentinel
[INFO/LokyProcess-32] process shutting down
[DEBUG/LokyProcess-32] running all "atexit" finalizers with priority >= 0
[DEBUG/LokyProcess-32] running the remaining "atexit" finalizers
[INFO/LokyProcess-32] process exiting with exitcode 0
[INFO/LokyProcess-35] shutting down worker on sentinel
[INFO/LokyProcess-35] process shutting down
[DEBUG/LokyProcess-35] running all "atexit" finalizers with priority >= 0
[DEBUG/LokyProcess-35] running the remaining "atexit" finalizers
[INFO/LokyProcess-35] process exiting with exitcode 0
[INFO/LokyProcess-33] shutting down worker on sentinel
[INFO/LokyProcess-33] process shutting down
[DEBUG/LokyProcess-33] running all "atexit" finalizers with priority >= 0
[DEBUG/LokyProcess-33] running the remaining "atexit" finalizers
[INFO/LokyProcess-33] process exiting with exitcode 0
[DEBUG:MainProcess:ThreadManager] shutting down
[DEBUG/LokyProcess-34] Using default backend pickle for pickling.
[DEBUG/LokyProcess-34] recreated blocker with handle 20
[DEBUG/LokyProcess-34] recreated blocker with handle 24
[DEBUG/LokyProcess-34] Queue._after_fork()
[DEBUG/LokyProcess-34] recreated blocker with handle 28
[DEBUG/LokyProcess-34] recreated blocker with handle 32
[INFO/LokyProcess-34] child process calling self.run()
[DEBUG/LokyProcess-34] worker started with timeout=None
[INFO/LokyProcess-34] shutting down worker on sentinel
[INFO/LokyProcess-34] process shutting down
[DEBUG/LokyProcess-34] running all "atexit" finalizers with priority >= 0
[DEBUG/LokyProcess-34] running the remaining "atexit" finalizers
[INFO/LokyProcess-34] process exiting with exitcode 0
[DEBUG/LokyProcess-36] Using default backend pickle for pickling.
[DEBUG/LokyProcess-36] recreated blocker with handle 20
[DEBUG/LokyProcess-36] recreated blocker with handle 24
[DEBUG/LokyProcess-36] Queue._after_fork()
[DEBUG/LokyProcess-36] recreated blocker with handle 28
[DEBUG/LokyProcess-36] recreated blocker with handle 32
[INFO/LokyProcess-36] child process calling self.run()
[DEBUG/LokyProcess-36] worker started with timeout=None
[INFO/LokyProcess-36] shutting down worker on sentinel
[INFO/LokyProcess-36] process shutting down
[DEBUG/LokyProcess-36] running all "atexit" finalizers with priority >= 0
[DEBUG/LokyProcess-36] running the remaining "atexit" finalizers
[INFO/LokyProcess-36] process exiting with exitcode 0
[DEBUG:MainProcess:QueueManager] queue management thread clean shutdown of worker processes: {}
[DEBUG:MainProcess:MainThread] Queue.join_thread()
[DEBUG:MainProcess:MainThread] using context <loky.backend.context.LokyContext object at 0x03B0E670>
[DEBUG:MainProcess:MainThread] created semlock with handle 1244
[DEBUG:MainProcess:MainThread] ProcessPoolExecutor is setup
[DEBUG:MainProcess:MainThread] created semlock with handle 1576
[DEBUG:MainProcess:MainThread] created semlock with handle 1196
[DEBUG:MainProcess:MainThread] Queue._after_fork()
[DEBUG:MainProcess:MainThread] created semlock with handle 1352
[DEBUG:MainProcess:MainThread] Adjust process count : {1344: <LokyProcess(LokyProcess-37, started)>, 2056: <LokyProcess(LokyProcess-38, started)>, 1112: <LokyProcess(LokyProcess-39, started)>, 2172: <LokyProcess(LokyProcess-40, started)>}
[DEBUG:MainProcess:MainThread] _start_queue_management_thread called
[DEBUG:MainProcess:QueueManager] Queue._start_thread()
[DEBUG:MainProcess:QueueManager] doing self._thread.start()
[DEBUG:MainProcess:MainThread] _start_thread_management_thread called
[DEBUG:MainProcess:MainThread] shutting down executor <loky.process_executor.ProcessPoolExecutor object at 0x043D0370>
[DEBUG:MainProcess:QueueFeederThread] starting thread to feed data to pipe
[DEBUG/LokyProcess-39] Using default backend pickle for pickling.
[DEBUG:MainProcess:QueueManager] ... done self._thread.start()
[DEBUG:MainProcess:ThreadManager] shutting down
[DEBUG/LokyProcess-39] recreated blocker with handle 20
[DEBUG/LokyProcess-39] recreated blocker with handle 24
[DEBUG/LokyProcess-39] Queue._after_fork()
[DEBUG/LokyProcess-39] recreated blocker with handle 28
[DEBUG/LokyProcess-39] recreated blocker with handle 32
[INFO/LokyProcess-39] child process calling self.run()
[DEBUG/LokyProcess-39] worker started with timeout=None
[DEBUG/LokyProcess-38] Using default backend pickle for pickling.
[DEBUG/LokyProcess-38] recreated blocker with handle 20
[DEBUG/LokyProcess-38] recreated blocker with handle 24
[DEBUG/LokyProcess-38] Queue._after_fork()
[DEBUG/LokyProcess-38] recreated blocker with handle 28
[DEBUG/LokyProcess-38] recreated blocker with handle 32
[INFO/LokyProcess-38] child process calling self.run()
[DEBUG/LokyProcess-38] worker started with timeout=None
[DEBUG/LokyProcess-40] Using default backend pickle for pickling.
[DEBUG/LokyProcess-40] recreated blocker with handle 20
[DEBUG/LokyProcess-40] recreated blocker with handle 24
[DEBUG/LokyProcess-40] Queue._after_fork()
[DEBUG/LokyProcess-40] recreated blocker with handle 28
[DEBUG/LokyProcess-40] recreated blocker with handle 32
[INFO/LokyProcess-40] child process calling self.run()
[DEBUG/LokyProcess-40] worker started with timeout=None
[DEBUG/LokyProcess-37] Using default backend pickle for pickling.
[DEBUG/LokyProcess-37] recreated blocker with handle 32
[DEBUG/LokyProcess-37] recreated blocker with handle 36
[DEBUG/LokyProcess-37] Queue._after_fork()
[DEBUG/LokyProcess-37] recreated blocker with handle 48
[DEBUG/LokyProcess-37] recreated blocker with handle 52
[INFO/LokyProcess-37] child process calling self.run()
[DEBUG/LokyProcess-37] worker started with timeout=None
~~~~~~~~~~~~~~~~~~~~~~~~~ Stack of QueueManager (2928) ~~~~~~~~~~~~~~~~~~~~~~~~~
File "c:\python36\Lib\threading.py", line 884, in _bootstrap
self._bootstrap_inner()
File "c:\python36\Lib\threading.py", line 916, in _bootstrap_inner
self.run()
File "c:\python36\Lib\threading.py", line 864, in run
self._target(*self._args, **self._kwargs)
File "C:\projects\loky\loky\process_executor.py", line 510, in _queue_management_worker
timeout=_poll_timeout)
File "c:\python36\Lib\multiprocessing\connection.py", line 859, in wait
ready_handles = _exhaustive_wait(waithandle_to_obj.keys(), timeout)
File "c:\python36\Lib\multiprocessing\connection.py", line 791, in _exhaustive_wait
res = _winapi.WaitForMultipleObjects(L, False, timeout)
~~~~~~~~~~~~~~~~~~~~~~~~~~ Stack of Thread-26 (1468) ~~~~~~~~~~~~~~~~~~~~~~~~~~~
File "c:\python36\Lib\threading.py", line 884, in _bootstrap
self._bootstrap_inner()
File "c:\python36\Lib\threading.py", line 916, in _bootstrap_inner
self.run()
File "c:\python36\Lib\threading.py", line 864, in run
self._target(*self._args, **self._kwargs)
File "c:\python36\Lib\multiprocessing\resource_sharer.py", line 142, in _serve
with self._listener.accept() as conn:
File "c:\python36\Lib\multiprocessing\connection.py", line 453, in accept
c = self._listener.accept()
File "c:\python36\Lib\multiprocessing\connection.py", line 663, in accept
[ov.event], False, INFINITE)
~~~~~~~~~~~~~~~~~~~~~~~~~~ Stack of MainThread (2068) ~~~~~~~~~~~~~~~~~~~~~~~~~~
File "c:\python36\Lib\runpy.py", line 193, in _run_module_as_main
"__main__", mod_spec)
File "c:\python36\Lib\runpy.py", line 85, in _run_code
exec(code, run_globals)
File "C:\projects\loky\.tox\py36\Scripts\py.test.EXE\__main__.py", line 9, in <module>
sys.exit(main())
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\config.py", line 58, in main
return config.hook.pytest_cmdline_main(config=config)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 745, in __call__
return self._hookexec(self, self._nonwrappers + self._wrappers, kwargs)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 339, in _hookexec
return self._inner_hookexec(hook, methods, kwargs)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 334, in <lambda>
_MultiCall(methods, kwargs, hook.spec_opts).execute()
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 614, in execute
res = hook_impl.function(*args)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\main.py", line 134, in pytest_cmdline_main
return wrap_session(config, _main)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\main.py", line 105, in wrap_session
session.exitstatus = doit(config, session) or 0
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\main.py", line 141, in _main
config.hook.pytest_runtestloop(session=session)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 745, in __call__
return self._hookexec(self, self._nonwrappers + self._wrappers, kwargs)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 339, in _hookexec
return self._inner_hookexec(hook, methods, kwargs)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 334, in <lambda>
_MultiCall(methods, kwargs, hook.spec_opts).execute()
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 614, in execute
res = hook_impl.function(*args)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\main.py", line 164, in pytest_runtestloop
item.config.hook.pytest_runtest_protocol(item=item, nextitem=nextitem)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 745, in __call__
return self._hookexec(self, self._nonwrappers + self._wrappers, kwargs)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 339, in _hookexec
return self._inner_hookexec(hook, methods, kwargs)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 334, in <lambda>
_MultiCall(methods, kwargs, hook.spec_opts).execute()
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 613, in execute
return _wrapped_call(hook_impl.function(*args), self.execute)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 248, in _wrapped_call
call_outcome = _CallOutcome(func)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 265, in __init__
self.result = func()
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 613, in execute
return _wrapped_call(hook_impl.function(*args), self.execute)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 248, in _wrapped_call
call_outcome = _CallOutcome(func)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 265, in __init__
self.result = func()
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 613, in execute
return _wrapped_call(hook_impl.function(*args), self.execute)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 248, in _wrapped_call
call_outcome = _CallOutcome(func)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 265, in __init__
self.result = func()
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 614, in execute
res = hook_impl.function(*args)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\runner.py", line 60, in pytest_runtest_protocol
runtestprotocol(item, nextitem=nextitem)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\runner.py", line 73, in runtestprotocol
reports.append(call_and_report(item, "call", log))
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\runner.py", line 127, in call_and_report
call = call_runtest_hook(item, when, **kwds)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\runner.py", line 145, in call_runtest_hook
return CallInfo(lambda: ihook(item=item, **kwds), when=when)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\runner.py", line 157, in __init__
self.result = func()
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\runner.py", line 145, in <lambda>
return CallInfo(lambda: ihook(item=item, **kwds), when=when)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 745, in __call__
return self._hookexec(self, self._nonwrappers + self._wrappers, kwargs)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 339, in _hookexec
return self._inner_hookexec(hook, methods, kwargs)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 334, in <lambda>
_MultiCall(methods, kwargs, hook.spec_opts).execute()
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 613, in execute
return _wrapped_call(hook_impl.function(*args), self.execute)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 248, in _wrapped_call
call_outcome = _CallOutcome(func)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 265, in __init__
self.result = func()
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 614, in execute
res = hook_impl.function(*args)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\runner.py", line 98, in pytest_runtest_call
item.runtest()
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\python.py", line 1593, in runtest
self.ihook.pytest_pyfunc_call(pyfuncitem=self)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 745, in __call__
return self._hookexec(self, self._nonwrappers + self._wrappers, kwargs)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 339, in _hookexec
return self._inner_hookexec(hook, methods, kwargs)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 334, in <lambda>
_MultiCall(methods, kwargs, hook.spec_opts).execute()
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 613, in execute
return _wrapped_call(hook_impl.function(*args), self.execute)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 248, in _wrapped_call
call_outcome = _CallOutcome(func)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 265, in __init__
self.result = func()
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\vendored_packages\pluggy.py", line 614, in execute
res = hook_impl.function(*args)
File "c:\projects\loky\.tox\py36\lib\site-packages\_pytest\python.py", line 142, in pytest_pyfunc_call
testfunction(**testargs)
File "C:\projects\loky\tests\_test_process_executor.py", line 106, in test_shutdown_with_sys_exit_at_pickle
e.submit(id, ExitAtPickle())
File "C:\projects\loky\loky\_base.py", line 609, in __exit__
self.shutdown(wait=True)
File "C:\projects\loky\loky\process_executor.py", line 987, in shutdown
self._queue_management_thread.join()
File "c:\python36\Lib\threading.py", line 1056, in join
self._wait_for_tstate_lock()
File "c:\python36\Lib\threading.py", line 1072, in _wait_for_tstate_lock
elif lock.acquire(block, timeout):
+++++++++++++++++++++++++++++++++++ Timeout ++++++++++++++++++++++++++++++++++++
ERROR: InvocationError: 'C:\\projects\\loky\\.tox\\py36\\Scripts\\py.test.EXE -vlx --timeout=30'
___________________________________ summary ___________________________________
ERROR: py36: commands failed