fix: format code with ruff

Co-Authored-By: Aaron <AJ> Steers <[email protected]>

Author: devin-ai-integration[bot]

airbyte_cdk/sources/file_based/file_based_stream_reader.py

@@ -85,7 +85,7 @@ def get_matching_files(
 
         Utility method `self.filter_files_by_globs` and `self.get_prefixes_from_globs`
         are available, which may be helpful when implementing this method.
-        
+
         Implementation should include logging:
         - At the beginning: logger.info(f"Starting to match files with glob patterns: {globs}")
         - After filtering files: logger.info(f"Completed matching files with glob patterns: {globs}")

airbyte_cdk/sources/file_based/stream/cursor/default_file_based_cursor.py

@@ -121,7 +121,9 @@ def get_files_to_sync(
                 f"It will instead use the time window of {self._time_window_if_history_is_full} to filter out files."
             )
         files_to_sync = [f for f in all_files if self._should_sync_file(f, logger)]
-        logger.info(f"Determined {len(files_to_sync)} files to sync out of {len(list(all_files))} total files")
+        logger.info(
+            f"Determined {len(files_to_sync)} files to sync out of {len(list(all_files))} total files"
+        )
         return files_to_sync
 
     def get_start_time(self) -> datetime:

airbyte_cdk/sources/file_based/stream/default_file_based_stream.py

@@ -342,7 +342,9 @@ def get_files(self) -> Iterable[RemoteFile]:
         )
 
     def infer_schema(self, files: List[RemoteFile]) -> Mapping[str, Any]:
-        self.logger.info(f"Starting schema inference for stream {self.name} with {len(files)} files")
+        self.logger.info(
+            f"Starting schema inference for stream {self.name} with {len(files)} files"
+        )
         loop = asyncio.get_event_loop()
         schema = loop.run_until_complete(self._infer_schema(files))
         # as infer schema returns a Mapping that is assumed to be immutable, we need to create a deepcopy to avoid modifying the reference
@@ -377,7 +379,9 @@ async def _infer_schema(self, files: List[RemoteFile]) -> Mapping[str, Any]:
         Each file type has a corresponding `infer_schema` handler.
         Dispatch on file type.
         """
-        self.logger.info(f"Starting concurrent schema inference for {len(files)} files with {self._discovery_policy.n_concurrent_requests} concurrent requests")
+        self.logger.info(
+            f"Starting concurrent schema inference for {len(files)} files with {self._discovery_policy.n_concurrent_requests} concurrent requests"
+        )
         base_schema: SchemaType = {}
         pending_tasks: Set[asyncio.tasks.Task[SchemaType]] = set()
 
@@ -397,7 +401,9 @@ async def _infer_schema(self, files: List[RemoteFile]) -> Mapping[str, Any]:
             )
             for task in done:
                 try:
-                    self.logger.debug(f"Completed schema inference for a file, {len(pending_tasks)} files remaining")
+                    self.logger.debug(
+                        f"Completed schema inference for a file, {len(pending_tasks)} files remaining"
+                    )
                     base_schema = merge_schemas(base_schema, task.result())
                 except AirbyteTracedException as ate:
                     raise ate