File tree Expand file tree Collapse file tree 1 file changed +0
-16
lines changed
Expand file tree Collapse file tree 1 file changed +0
-16
lines changed 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