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='%ds'))
self._thread_pool_executor.shutdown(wait)
self.already_shutdown = True
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='%ds'))
self.already_shutdown = True
def __getstate__(self):
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='%ds'))
self.already_shutdown = True