Skip to content

Commit e66ef81

Browse files
committed
fix
1 parent 975a424 commit e66ef81

1 file changed

Lines changed: 5 additions & 2 deletions

File tree

langfuse/_client/resource_manager.py

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -256,8 +256,11 @@ def _initialize_instance(
256256

257257
@classmethod
258258
def reset(cls):
259-
for key in cls._instances:
260-
cls._instances.pop(key).shutdown()
259+
with cls._lock:
260+
for key in cls._instances:
261+
cls._instances[key].shutdown()
262+
263+
cls._instances.clear()
261264

262265
def add_score_task(self, event: dict, *, force_sample: bool = False):
263266
try:

0 commit comments

Comments
 (0)