projects
/
python_utils.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
f41c2bb
)
Tweak histograms in executors to include seconds label.
author
Scott
<
[email protected]
>
Mon, 31 Jan 2022 17:58:30 +0000
(09:58 -0800)
committer
Scott
<
[email protected]
>
Mon, 31 Jan 2022 17:58:30 +0000
(09:58 -0800)
executors.py
patch
|
blob
|
history
diff --git
a/executors.py
b/executors.py
index 28507b0e8a547e9d1edc615daa5de7945edb457d..633b11b3b616cc2536ea514d274cbf2874a99282 100644
(file)
--- a/
executors.py
+++ b/
executors.py
@@
-158,7
+158,7
@@
class ThreadExecutor(BaseExecutor):
def shutdown(self, wait=True) -> None:
if not self.already_shutdown:
logger.debug(f'Shutting down threadpool executor {self.title}')
def shutdown(self, wait=True) -> None:
if not self.already_shutdown:
logger.debug(f'Shutting down threadpool executor {self.title}')
- print(self.histogram.__repr__(label_formatter='%d'))
+ print(self.histogram.__repr__(label_formatter='%d
s
'))
self._thread_pool_executor.shutdown(wait)
self.already_shutdown = True
self._thread_pool_executor.shutdown(wait)
self.already_shutdown = True
@@
-201,7
+201,7
@@
class ProcessExecutor(BaseExecutor):
if not self.already_shutdown:
logger.debug(f'Shutting down processpool executor {self.title}')
self._process_executor.shutdown(wait)
if not self.already_shutdown:
logger.debug(f'Shutting down processpool executor {self.title}')
self._process_executor.shutdown(wait)
- print(self.histogram.__repr__(label_formatter='%d'))
+ print(self.histogram.__repr__(label_formatter='%d
s
'))
self.already_shutdown = True
def __getstate__(self):
self.already_shutdown = True
def __getstate__(self):
@@
-1113,7
+1113,7
@@
class RemoteExecutor(BaseExecutor):
self.heartbeat_stop_event.set()
self.heartbeat_thread.join()
self._helper_executor.shutdown(wait)
self.heartbeat_stop_event.set()
self.heartbeat_thread.join()
self._helper_executor.shutdown(wait)
- print(self.histogram.__repr__(label_formatter='%d'))
+ print(self.histogram.__repr__(label_formatter='%d
s
'))
self.already_shutdown = True
self.already_shutdown = True