1919from ldclient .datasystem import (
2020 custom ,
2121 polling_ds_builder ,
22- streaming_ds_builder
22+ streaming_ds_builder ,
23+ fdv1_fallback_ds_builder
2324)
2425
2526
@@ -59,6 +60,7 @@ def __init__(self, tag, config):
5960
6061 primary_builder = None
6162 secondary_builder = None
63+ fallback_builder = None
6264
6365 if primary is not None :
6466 streaming = primary .get ('streaming' )
@@ -74,6 +76,7 @@ def __init__(self, tag, config):
7476 opts ["base_uri" ] = polling ["baseUri" ]
7577 _set_optional_time_prop (polling , "pollIntervalMs" , opts , "poll_interval" )
7678 primary_builder = polling_ds_builder ()
79+ fallback_builder = fdv1_fallback_ds_builder ()
7780
7881 if secondary is not None :
7982 streaming = secondary .get ('streaming' )
@@ -89,9 +92,12 @@ def __init__(self, tag, config):
8992 opts ["base_uri" ] = polling ["baseUri" ]
9093 _set_optional_time_prop (polling , "pollIntervalMs" , opts , "poll_interval" )
9194 secondary_builder = polling_ds_builder ()
95+ fallback_builder = fdv1_fallback_ds_builder ()
9296
9397 if primary_builder is not None :
9498 datasystem .synchronizers (primary_builder , secondary_builder )
99+ if fallback_builder is not None :
100+ datasystem .fdv1_compatible_synchronizer (fallback_builder )
95101
96102 if datasystem_config .get ("payloadFilter" ) is not None :
97103 opts ["payload_filter_key" ] = datasystem_config ["payloadFilter" ]
0 commit comments