linting

elastic · Jan 9, 2024 · 2dfc3a3 · 2dfc3a3
1 parent 1a13bc0
commit 2dfc3a3
Showing 1 changed file with 4 additions and 8 deletions.
diff --git a/connectors/services/job_cleanup.py b/connectors/services/job_cleanup.py
@@ -21,10 +21,8 @@ class JobCleanUpService(BaseService):
 
     def __init__(self, config):
         super().__init__(config)
-        self.idling = int(self.service_config.get(
-            "job_cleanup_interval", 60 * 5))
-        self.native_service_types = self.config.get(
-            "native_service_types", []) or []
+        self.idling = int(self.service_config.get("job_cleanup_interval", 60 * 5))
+        self.native_service_types = self.config.get("native_service_types", []) or []
         self.connector_ids = list(self.connectors.keys())
 
     async def _run(self):
@@ -75,8 +73,7 @@ async def _process_orphaned_jobs(self):
 
             result = await self.sync_job_index.delete_jobs(job_ids=job_ids)
             if len(result["failures"]) > 0:
-                logger.error(
-                    f"Error found when deleting jobs: {result['failures']}")
+                logger.error(f"Error found when deleting jobs: {result['failures']}")
             logger.info(
                 f"Successfully deleted {result['deleted']} out of {result['total']} orphaned jobs"
             )
@@ -121,8 +118,7 @@ async def _process_idle_jobs(self):
                         job = None
                     await connector.sync_done(job=job)
                 except Exception as e:
-                    logger.error(
-                        f"Failed to mark idle job #{job_id} as error: {e}")
+                    logger.error(f"Failed to mark idle job #{job_id} as error: {e}")
                 finally:
                     total_count += 1