standardize no ttl

Author: cbrady

README.md

@@ -368,7 +368,7 @@ asyncio.run(main())
 
 #### Cache TTL Configuration
 
-When using Replicator Mode, you should set the SDK's cache TTL to match the replicator's cache TTL. The replicator defaults to an unlimited cache TTL (`0`). If the SDK uses a shorter TTL (the default is 24 hours), locally updated cache entries will be written back with the shorter TTL and eventually evicted from the shared cache.
+When using Replicator Mode, you should set the SDK's cache TTL to match the replicator's cache TTL. The replicator defaults to an unlimited cache TTL. If the SDK uses a shorter TTL (the default is 24 hours), locally updated cache entries will be written back with the shorter TTL and eventually evicted from the shared cache.
 
 To match the replicator's default unlimited TTL:
 
@@ -377,7 +377,7 @@ config = AsyncSchematicConfig(
     use_datastream=True,
     datastream=DataStreamConfig(
         replicator_mode=True,
-        cache_ttl=0,  # Unlimited, matching the replicator default
+        cache_ttl=None,  # Unlimited, matching the replicator default
     ),
 )
 ```
@@ -389,7 +389,7 @@ config = AsyncSchematicConfig(
     use_datastream=True,
     datastream=DataStreamConfig(
         replicator_mode=True,
-        cache_ttl=0,
+        cache_ttl=None,
         replicator_health_url="http://my-replicator:8090/ready",
         replicator_health_check=60_000,  # 60 seconds, in milliseconds
     ),

src/schematic/datastream/datastream_client.py

@@ -88,7 +88,7 @@ class DataStreamClientOptions:
     api_key: str
     logger: logging.Logger
     base_url: Optional[str] = None
-    cache_ttl: int = DEFAULT_TTL_MS
+    cache_ttl: Optional[int] = DEFAULT_TTL_MS
 
     # Custom cache providers (override defaults)
     company_cache: Optional[AsyncCacheProvider[Any]] = None
@@ -174,14 +174,15 @@ def __init__(self, options: DataStreamClientOptions) -> None:
                     )
 
         # Cache providers
-        flag_ttl = max(MAX_CACHE_TTL_MS, self._cache_ttl)
-        self._company_cache: AsyncCacheProvider[RulesengineCompany] = options.company_cache or AsyncLocalCache(ttl=self._cache_ttl)
-        self._user_cache: AsyncCacheProvider[RulesengineUser] = options.user_cache or AsyncLocalCache(ttl=self._cache_ttl)
+        local_ttl = self._cache_ttl if self._cache_ttl is not None else DEFAULT_TTL_MS
+        flag_ttl = max(MAX_CACHE_TTL_MS, local_ttl)
+        self._company_cache: AsyncCacheProvider[RulesengineCompany] = options.company_cache or AsyncLocalCache(ttl=local_ttl)
+        self._user_cache: AsyncCacheProvider[RulesengineUser] = options.user_cache or AsyncLocalCache(ttl=local_ttl)
         self._flag_cache: AsyncCacheProvider[RulesengineFlag] = options.flag_cache or AsyncLocalCache(ttl=flag_ttl)
 
         # Key -> ID mapping caches (two-level caching)
-        self._company_key_cache: AsyncCacheProvider[str] = options.company_lookup_cache or AsyncLocalCache(ttl=self._cache_ttl)
-        self._user_key_cache: AsyncCacheProvider[str] = options.user_lookup_cache or AsyncLocalCache(ttl=self._cache_ttl)
+        self._company_key_cache: AsyncCacheProvider[str] = options.company_lookup_cache or AsyncLocalCache(ttl=local_ttl)
+        self._user_key_cache: AsyncCacheProvider[str] = options.user_lookup_cache or AsyncLocalCache(ttl=local_ttl)
 
         # WebSocket client
         self._ws_client: Optional[DatastreamWSClient] = None