make autoformat

elastic · Dec 25, 2024 · 30e46e7 · 30e46e7
1 parent eb75bac
commit 30e46e7
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/connectors/protocol/connectors.py b/connectors/protocol/connectors.py
@@ -820,11 +820,7 @@ async def error(self, error):
         await self.index.update(doc_id=self.id, doc=doc)
 
     async def connected(self):
-        doc = {
-            "status": Status.CONNECTED.value,
-            "error": None
-
-        }
+        doc = {"status": Status.CONNECTED.value, "error": None}
         await self.index.update(doc_id=self.id, doc=doc)
 
     async def sync_done(self, job, cursor=None):

diff --git a/connectors/services/job_scheduling.py b/connectors/services/job_scheduling.py
@@ -107,7 +107,9 @@ async def _schedule(self, connector):
             if connector.features.sync_rules_enabled():
                 await connector.validate_filtering(validator=data_source)
 
-            self.logger.info("Connector is configured correctly and can reach the data source")
+            self.logger.info(
+                "Connector is configured correctly and can reach the data source"
+            )
             await connector.connected()
         except Exception as e:
             connector.log_error(e, exc_info=True)

diff --git a/tests/services/test_job_scheduling.py b/tests/services/test_job_scheduling.py
@@ -403,7 +403,9 @@ def _error_once():
     data_source_mock.close = AsyncMock()
 
     connector = mock_connector(next_sync=datetime.now(timezone.utc))
-    connector_index_mock.supported_connectors.return_value = AsyncIterator([connector], reusable=True)
+    connector_index_mock.supported_connectors.return_value = AsyncIterator(
+        [connector], reusable=True
+    )
     await create_and_run_service(JobSchedulingService, stop_after=0.15)
 
     data_source_mock.validate_config_fields.assert_called()