|
@@ -61,7 +61,7 @@ class _JobDispatcher(threading.Thread):
|
|
|
self.join(timeout=timeout)
|
|
|
|
|
|
def run(self):
|
|
|
- self._logger.info("Start job dispatcher...")
|
|
|
+ self._logger.debug("Job dispatcher started.")
|
|
|
while not self._STOP_FLAG:
|
|
|
try:
|
|
|
if self._can_execute():
|
|
@@ -77,7 +77,7 @@ class _JobDispatcher(threading.Thread):
|
|
|
except Exception as e:
|
|
|
self._logger.exception(e)
|
|
|
pass
|
|
|
- self._logger.info("Job dispatcher stopped.")
|
|
|
+ self._logger.debug("Job dispatcher stopped.")
|
|
|
|
|
|
def _can_execute(self) -> bool:
|
|
|
"""Returns True if the dispatcher have resources to execute a new job."""
|