Delete format duration

Author: tolik0

airbyte_cdk/sources/declarative/declarative_component_schema.yaml

@@ -1426,7 +1426,6 @@ definitions:
         title: Period
         description: The time interval for the rate limit window.
         type: string
-        format: duration
       call_limit:
         title: Call Limit
         description: The maximum number of calls allowed within the period.

airbyte_cdk/sources/declarative/models/declarative_component_schema.py

@@ -3,7 +3,6 @@
 
 from __future__ import annotations
 
-from datetime import timedelta
 from enum import Enum
 from typing import Any, Dict, List, Literal, Optional, Union
 
@@ -1632,7 +1631,7 @@ class Config:
         extra = Extra.allow
 
     type: Literal["FixedWindowCallRatePolicy"]
-    period: timedelta = Field(
+    period: str = Field(
         ..., description="The time interval for the rate limit window.", title="Period"
     )
     call_limit: int = Field(

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

@@ -2973,7 +2973,7 @@ def create_http_api_budget(
             policies=policies,
             ratelimit_reset_header=model.ratelimit_reset_header or "ratelimit-reset",
             ratelimit_remaining_header=model.ratelimit_remaining_header or "ratelimit-remaining",
-            status_codes_for_ratelimit_hit=model.status_codes_for_ratelimit_hit or (429,),
+            status_codes_for_ratelimit_hit=model.status_codes_for_ratelimit_hit or [429],
         )
 
     def create_fixed_window_call_rate_policy(
@@ -2988,7 +2988,7 @@ def create_fixed_window_call_rate_policy(
         # This value will be updated by the first request.
         return FixedWindowCallRatePolicy(
             next_reset_ts=datetime.datetime.now() + datetime.timedelta(days=10),
-            period=model.period,
+            period=parse_duration(model.period),
             call_limit=model.call_limit,
             matchers=matchers,
         )

airbyte_cdk/sources/streams/call_rate.py

@@ -8,10 +8,9 @@
 import logging
 import re
 import time
-from dataclasses import InitVar, dataclass, field
 from datetime import timedelta
 from threading import RLock
-from typing import TYPE_CHECKING, Any, Mapping, Optional, Union
+from typing import TYPE_CHECKING, Any, Mapping, Optional
 from urllib import parse
 
 import requests
@@ -653,7 +652,7 @@ def __init__(
         self,
         ratelimit_reset_header: str = "ratelimit-reset",
         ratelimit_remaining_header: str = "ratelimit-remaining",
-        status_codes_for_ratelimit_hit: Union[tuple[int], list[int]] = (429,),
+        status_codes_for_ratelimit_hit: list[int] = [429],
         **kwargs: Any,
     ):
         """Constructor