From 848e3e832d102f58340b7dc94d1f9460579e7dcf Mon Sep 17 00:00:00 2001 From: Yoan Salambashev Date: Wed, 1 Mar 2023 19:32:03 +0200 Subject: [PATCH] vdk-meta-jobs: fix a minor technical error Signed-off-by: Yoan Salambashev --- .../vdk-meta-jobs/src/vdk/plugin/meta_jobs/meta_dag.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/projects/vdk-plugins/vdk-meta-jobs/src/vdk/plugin/meta_jobs/meta_dag.py b/projects/vdk-plugins/vdk-meta-jobs/src/vdk/plugin/meta_jobs/meta_dag.py index 9d094607c3..be2974e9df 100644 --- a/projects/vdk-plugins/vdk-meta-jobs/src/vdk/plugin/meta_jobs/meta_dag.py +++ b/projects/vdk-plugins/vdk-meta-jobs/src/vdk/plugin/meta_jobs/meta_dag.py @@ -6,11 +6,11 @@ import pprint import sys import time -from graphlib import TopologicalSorter from typing import Any from typing import Dict from typing import List +from graphlib import TopologicalSorter from taurus_datajob_api import ApiException from vdk.internal.core import errors from vdk.plugin.meta_jobs.cached_data_job_executor import TrackingDataJobExecutor @@ -122,7 +122,7 @@ def _start_job(self, node): > self.max_concurrent_starting_jobs ): log.info( - f"Starting job fail - too many concurrently running jobs. Will be re-tried later" + "Starting job fail - too many concurrently running jobs. Will be re-tried later" ) self._delayed_starting_jobs.enqueue(node) else: