Commit 384f7e9c authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Service component: 

- Reduced log level of TaskScheduler internal log messages
parent ab663513

src/service/service/task_scheduler/TaskScheduler.py

+4 −4
Original line number Diff line number Diff line
@@ -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)