File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2222from ldclient .impl .listeners import Listeners
2323from ldclient .impl .stubs import NullUpdateProcessor
2424from ldclient .interfaces import (
25- DataSourceState ,
26- DataSourceStatus ,
2725 DataSourceStatusProvider ,
2826 DataStoreStatusProvider ,
2927 FeatureStore ,
@@ -84,20 +82,6 @@ def __init__(self, config: Config):
8482 # Diagnostic accumulator provided by client for streaming metrics
8583 self ._diagnostic_accumulator : Optional [DiagnosticAccumulator ] = None
8684
87- # Track current data availability
88- self ._data_availability : DataAvailability = (
89- DataAvailability .CACHED
90- if getattr (self ._store_wrapper , "initialized" , False )
91- else DataAvailability .DEFAULTS
92- )
93-
94- # React to data source status updates to adjust availability
95- def _on_status_change (status : DataSourceStatus ):
96- if status .state == DataSourceState .VALID :
97- self ._data_availability = DataAvailability .REFRESHED
98-
99- self ._data_source_status_provider_impl .add_listener (_on_status_change )
100-
10185 def start (self , set_on_ready : Event ):
10286 """
10387 Starts the v1 update processor and returns immediately. The provided
You can’t perform that action at this time.
0 commit comments