squash me

Author: aabmass

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

@@ -216,10 +216,10 @@ def __init__(
         self._flush_request = None
         self._log_records = [None] * self._max_export_batch_size
         self._worker_thread.start()
-        # if hasattr(os, "register_at_fork"):
-        #     os.register_at_fork(
-        #         after_in_child=self._at_fork_reinit
-        #     )  # pylint: disable=protected-access
+        if hasattr(os, "register_at_fork"):
+            os.register_at_fork(
+                after_in_child=self._at_fork_reinit
+            )  # pylint: disable=protected-access
         self._pid = os.getpid()
 
     def _at_fork_reinit(self):

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

@@ -489,10 +489,10 @@ def __init__(
                 daemon=True,
             )
             self._daemon_thread.start()
-            # if hasattr(os, "register_at_fork"):
-            #     os.register_at_fork(
-            #         after_in_child=self._at_fork_reinit
-            #     )  # pylint: disable=protected-access
+            if hasattr(os, "register_at_fork"):
+                os.register_at_fork(
+                    after_in_child=self._at_fork_reinit
+                )  # pylint: disable=protected-access
         elif self._export_interval_millis <= 0:
             raise ValueError(
                 f"interval value {self._export_interval_millis} is invalid \

opentelemetry-sdk/src/opentelemetry/sdk/trace/export/__init__.py

@@ -203,10 +203,10 @@ def __init__(
             None
         ] * self.max_export_batch_size  # type: typing.List[typing.Optional[Span]]
         self.worker_thread.start()
-        # if hasattr(os, "register_at_fork"):
-        #     os.register_at_fork(
-        #         after_in_child=self._at_fork_reinit
-        #     )  # pylint: disable=protected-access
+        if hasattr(os, "register_at_fork"):
+            os.register_at_fork(
+                after_in_child=self._at_fork_reinit
+            )  # pylint: disable=protected-access
         self._pid = os.getpid()
 
     def on_start(