Skip to content

Commit bd9a74d

Browse files
committed
Fixed with weakref, needs to be done in other signals too
1 parent 483024d commit bd9a74d

File tree

1 file changed

+3
-1
lines changed
  • opentelemetry-sdk/src/opentelemetry/sdk/metrics/_internal/export

1 file changed

+3
-1
lines changed

opentelemetry-sdk/src/opentelemetry/sdk/metrics/_internal/export/__init__.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
from threading import Event, Lock, RLock, Thread
2323
from time import time_ns
2424
from typing import IO, Callable, Dict, Iterable, Optional
25+
import weakref
2526

2627
from typing_extensions import final
2728

@@ -490,8 +491,9 @@ def __init__(
490491
)
491492
self._daemon_thread.start()
492493
if hasattr(os, "register_at_fork"):
494+
weakself = weakref.proxy(self)
493495
os.register_at_fork(
494-
after_in_child=self._at_fork_reinit
496+
after_in_child=lambda: weakself._at_fork_reinit()
495497
) # pylint: disable=protected-access
496498
elif self._export_interval_millis <= 0:
497499
raise ValueError(

0 commit comments

Comments
 (0)