Spaces:
Running
Running
chore: update something
Browse files
lightweight_embeddings/analytics.py
CHANGED
@@ -146,7 +146,6 @@ class Analytics:
|
|
146 |
),
|
147 |
)
|
148 |
cursor, keys = scan_result[0], scan_result[1]
|
149 |
-
|
150 |
for key in keys:
|
151 |
# key is "analytics:access:<period>"
|
152 |
period = key.replace("analytics:access:", "")
|
@@ -155,9 +154,7 @@ class Analytics:
|
|
155 |
)
|
156 |
for model_id, count_str in data.items():
|
157 |
self.local_buffer["access"][period][model_id] = int(count_str)
|
158 |
-
|
159 |
-
if cursor == 0:
|
160 |
-
break
|
161 |
|
162 |
# Scan 'tokens' keys
|
163 |
cursor = 0
|
@@ -172,7 +169,6 @@ class Analytics:
|
|
172 |
),
|
173 |
)
|
174 |
cursor, keys = scan_result[0], scan_result[1]
|
175 |
-
|
176 |
for key in keys:
|
177 |
# key is "analytics:tokens:<period>"
|
178 |
period = key.replace("analytics:tokens:", "")
|
@@ -181,9 +177,7 @@ class Analytics:
|
|
181 |
)
|
182 |
for model_id, count_str in data.items():
|
183 |
self.local_buffer["tokens"][period][model_id] = int(count_str)
|
184 |
-
|
185 |
-
if cursor == 0:
|
186 |
-
break
|
187 |
|
188 |
async def _sync_to_redis(self):
|
189 |
"""
|
|
|
146 |
),
|
147 |
)
|
148 |
cursor, keys = scan_result[0], scan_result[1]
|
|
|
149 |
for key in keys:
|
150 |
# key is "analytics:access:<period>"
|
151 |
period = key.replace("analytics:access:", "")
|
|
|
154 |
)
|
155 |
for model_id, count_str in data.items():
|
156 |
self.local_buffer["access"][period][model_id] = int(count_str)
|
157 |
+
break
|
|
|
|
|
158 |
|
159 |
# Scan 'tokens' keys
|
160 |
cursor = 0
|
|
|
169 |
),
|
170 |
)
|
171 |
cursor, keys = scan_result[0], scan_result[1]
|
|
|
172 |
for key in keys:
|
173 |
# key is "analytics:tokens:<period>"
|
174 |
period = key.replace("analytics:tokens:", "")
|
|
|
177 |
)
|
178 |
for model_id, count_str in data.items():
|
179 |
self.local_buffer["tokens"][period][model_id] = int(count_str)
|
180 |
+
break
|
|
|
|
|
181 |
|
182 |
async def _sync_to_redis(self):
|
183 |
"""
|