fix: apply ruff formatting

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

Author: devin-ai-integration[bot]

airbyte_cdk/sources/declarative/datetime/datetime_parser.py

@@ -51,7 +51,7 @@ def parse(self, date: Union[str, int], format: str) -> datetime.datetime:
         elif "%_ms" in format:
             # Convert custom millisecond format to standard format
             format = format.replace("%_ms", "%f")
-            
+
         # For standard formats, use ab_datetime_parse with the specific format
         try:
             result = ab_datetime_parse(date, formats=[format], disallow_other_formats=True)

airbyte_cdk/sources/declarative/datetime/min_max_datetime.py

@@ -72,18 +72,22 @@ def get_datetime(
                     **additional_parameters,
                 )
             ),
-            formats=[datetime_format] if datetime_format else None
+            formats=[datetime_format] if datetime_format else None,
         ).to_datetime()  # type: ignore # datetime is always cast to an interpolated string
 
         if self.min_datetime:
             min_time = str(self.min_datetime.eval(config, **additional_parameters))  # type: ignore # min_datetime is always cast to an interpolated string
             if min_time:
-                min_datetime = ab_datetime_parse(min_time, formats=[datetime_format] if datetime_format else None).to_datetime()  # type: ignore # min_datetime is always cast to an interpolated string
+                min_datetime = ab_datetime_parse(
+                    min_time, formats=[datetime_format] if datetime_format else None
+                ).to_datetime()  # type: ignore # min_datetime is always cast to an interpolated string
                 time = max(time, min_datetime)
         if self.max_datetime:
             max_time = str(self.max_datetime.eval(config, **additional_parameters))  # type: ignore # max_datetime is always cast to an interpolated string
             if max_time:
-                max_datetime = ab_datetime_parse(max_time, formats=[datetime_format] if datetime_format else None).to_datetime()
+                max_datetime = ab_datetime_parse(
+                    max_time, formats=[datetime_format] if datetime_format else None
+                ).to_datetime()
                 time = min(time, max_datetime)
         return time
 

airbyte_cdk/sources/declarative/incremental/datetime_based_cursor.py

@@ -310,9 +310,13 @@ def _get_date(
     def parse_date(self, date: str) -> datetime.datetime:
         try:
             # Try each format in the list, falling back to the default format
-            return ab_datetime_parse(date, formats=self.cursor_datetime_formats + [self.datetime_format]).to_datetime()
+            return ab_datetime_parse(
+                date, formats=self.cursor_datetime_formats + [self.datetime_format]
+            ).to_datetime()
         except ValueError:
-            raise ValueError(f"No format in {self.cursor_datetime_formats + [self.datetime_format]} matching {date}")
+            raise ValueError(
+                f"No format in {self.cursor_datetime_formats + [self.datetime_format]} matching {date}"
+            )
 
     @classmethod
     def _parse_timedelta(cls, time_str: Optional[str]) -> Union[datetime.timedelta, Duration]:

airbyte_cdk/sources/declarative/interpolation/macros.py

@@ -144,8 +144,7 @@ def day_delta(num_days: int, format: str = "%Y-%m-%dT%H:%M:%S.%f%z") -> str:
     :return: datetime formatted as RFC3339
     """
     return ab_datetime_format(
-        ab_datetime_now().to_datetime() + datetime.timedelta(days=num_days),
-        format
+        ab_datetime_now().to_datetime() + datetime.timedelta(days=num_days), format
     )
 
 
@@ -176,10 +175,14 @@ def format_datetime(
         return ab_datetime_format(dt, format)
 
     if isinstance(dt, int):
-        dt_datetime = ab_datetime_parse(dt, formats=[input_format] if input_format else None).to_datetime()
+        dt_datetime = ab_datetime_parse(
+            dt, formats=[input_format] if input_format else None
+        ).to_datetime()
     else:
         dt_datetime = (
-            ab_datetime_parse(dt, formats=[input_format] if input_format else None).to_datetime() if input_format else str_to_datetime(dt)
+            ab_datetime_parse(dt, formats=[input_format] if input_format else None).to_datetime()
+            if input_format
+            else str_to_datetime(dt)
         )
     if dt_datetime.tzinfo is None:
         dt_datetime = dt_datetime.replace(tzinfo=pytz.utc)

airbyte_cdk/sources/file_based/stream/concurrent/cursor/file_based_concurrent_cursor.py

@@ -111,7 +111,9 @@ def _compute_prev_sync_cursor(self, value: Optional[StreamState]) -> Tuple[datet
         )
         cursor_str = min(prev_cursor_str, earliest_file_cursor_value)
         cursor_dt, cursor_uri = cursor_str.split("_", 1)
-        return ab_datetime_parse(cursor_dt, formats=[self.DATE_TIME_FORMAT]).to_datetime(), cursor_uri
+        return ab_datetime_parse(
+            cursor_dt, formats=[self.DATE_TIME_FORMAT]
+        ).to_datetime(), cursor_uri
 
     def _get_cursor_key_from_file(self, file: Optional[RemoteFile]) -> str:
         if file:
@@ -126,7 +128,9 @@ def _compute_earliest_file_in_history(self) -> Optional[RemoteFile]:
                 )
                 return RemoteFile(
                     uri=filename,
-                    last_modified=ab_datetime_parse(last_modified, formats=[self.DATE_TIME_FORMAT]).to_datetime(),
+                    last_modified=ab_datetime_parse(
+                        last_modified, formats=[self.DATE_TIME_FORMAT]
+                    ).to_datetime(),
                 )
             else:
                 return None
@@ -211,7 +215,9 @@ def _compute_latest_file_in_history(self) -> Optional[RemoteFile]:
                 )
                 return RemoteFile(
                     uri=filename,
-                    last_modified=ab_datetime_parse(last_modified, formats=[self.DATE_TIME_FORMAT]).to_datetime(),
+                    last_modified=ab_datetime_parse(
+                        last_modified, formats=[self.DATE_TIME_FORMAT]
+                    ).to_datetime(),
                 )
             else:
                 return None

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

@@ -133,7 +133,10 @@ def _compute_earliest_file_in_history(self) -> Optional[RemoteFile]:
                 self._file_to_datetime_history.items(), key=lambda f: (f[1], f[0])
             )
             return RemoteFile(
-                uri=filename, last_modified=ab_datetime_parse(last_modified, formats=[self.DATE_TIME_FORMAT]).to_datetime()
+                uri=filename,
+                last_modified=ab_datetime_parse(
+                    last_modified, formats=[self.DATE_TIME_FORMAT]
+                ).to_datetime(),
             )
         else:
             return None