From 384f7e9caebc16aa11ed62a0ac1af0deb9f8848d Mon Sep 17 00:00:00 2001
From: gifrerenom <lluis.gifre@cttc.es>
Date: Mon, 20 Feb 2023 16:35:34 +0000
Subject: [PATCH] Service component:
- Reduced log level of TaskScheduler internal log messages
---
src/service/service/task_scheduler/TaskScheduler.py | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/src/service/service/task_scheduler/TaskScheduler.py b/src/service/service/task_scheduler/TaskScheduler.py
index f55527e47..fbc554aa2 100644
--- a/src/service/service/task_scheduler/TaskScheduler.py
+++ b/src/service/service/task_scheduler/TaskScheduler.py
@@ -130,7 +130,7 @@ class TasksScheduler:
self._dag.add(connection_key, service_key_done)
t1 = time.time()
- LOGGER.info('[compose_from_pathcompreply] elapsed_time: {:f} sec'.format(t1-t0))
+ LOGGER.debug('[compose_from_pathcompreply] elapsed_time: {:f} sec'.format(t1-t0))
def compose_from_service(self, service : Service, is_delete : bool = False) -> None:
t0 = time.time()
@@ -196,11 +196,11 @@ class TasksScheduler:
raise Exception(MSG.format(type(item).__name__, grpc_message_to_json_string(item)))
t1 = time.time()
- LOGGER.info('[compose_from_service] elapsed_time: {:f} sec'.format(t1-t0))
+ LOGGER.debug('[compose_from_service] elapsed_time: {:f} sec'.format(t1-t0))
def execute_all(self, dry_run : bool = False) -> None:
ordered_task_keys = list(self._dag.static_order())
- LOGGER.info('[execute_all] ordered_task_keys={:s}'.format(str(ordered_task_keys)))
+ LOGGER.debug('[execute_all] ordered_task_keys={:s}'.format(str(ordered_task_keys)))
results = []
for task_key in ordered_task_keys:
@@ -208,5 +208,5 @@ class TasksScheduler:
succeeded = True if dry_run else task.execute()
results.append(succeeded)
- LOGGER.info('[execute_all] results={:s}'.format(str(results)))
+ LOGGER.debug('[execute_all] results={:s}'.format(str(results)))
return zip(ordered_task_keys, results)
--
GitLab