@@ -126,7 +126,7 @@ async def add_flag_set(self, flag_set):
126126 :type flag_set: str
127127 """
128128 async with self ._lock :
129- if not self .flag_set_exist ( flag_set ):
129+ if not flag_set in self .sets_feature_flag_map . keys ( ):
130130 self .sets_feature_flag_map [flag_set ] = set ()
131131
132132 async def remove_flag_set (self , flag_set ):
@@ -136,7 +136,7 @@ async def remove_flag_set(self, flag_set):
136136 :type flag_set: str
137137 """
138138 async with self ._lock :
139- if self .flag_set_exist ( flag_set ):
139+ if flag_set in self .sets_feature_flag_map . keys ( ):
140140 del self .sets_feature_flag_map [flag_set ]
141141
142142 async def add_feature_flag_to_flag_set (self , flag_set , feature_flag ):
@@ -148,7 +148,7 @@ async def add_feature_flag_to_flag_set(self, flag_set, feature_flag):
148148 :type feature_flag: str
149149 """
150150 async with self ._lock :
151- if self .flag_set_exist ( flag_set ):
151+ if flag_set in self .sets_feature_flag_map . keys ( ):
152152 self .sets_feature_flag_map [flag_set ].add (feature_flag )
153153
154154 async def remove_feature_flag_to_flag_set (self , flag_set , feature_flag ):
@@ -160,7 +160,7 @@ async def remove_feature_flag_to_flag_set(self, flag_set, feature_flag):
160160 :type feature_flag: str
161161 """
162162 async with self ._lock :
163- if self .flag_set_exist ( flag_set ):
163+ if flag_set in self .sets_feature_flag_map . keys ( ):
164164 self .sets_feature_flag_map [flag_set ].remove (feature_flag )
165165
166166class InMemorySplitStorageBase (SplitStorage ):
@@ -503,7 +503,7 @@ def __init__(self, flag_sets=[]):
503503 self ._feature_flags = {}
504504 self ._change_number = - 1
505505 self ._traffic_types = Counter ()
506- self .flag_set = FlagSets (flag_sets )
506+ self .flag_set = FlagSetsAsync (flag_sets )
507507 self .flag_set_filter = FlagSetsFilter (flag_sets )
508508
509509 async def get (self , feature_flag_name ):
0 commit comments