From ac55696b03e7c0ca37e2470be1b90f9e69e93f07 Mon Sep 17 00:00:00 2001 From: Munir Abdinur Date: Thu, 6 Feb 2025 16:44:57 -0500 Subject: [PATCH] remove gevent deps --- ddtrace/contrib/internal/gevent/provider.py | 47 --------------------- 1 file changed, 47 deletions(-) delete mode 100644 ddtrace/contrib/internal/gevent/provider.py diff --git a/ddtrace/contrib/internal/gevent/provider.py b/ddtrace/contrib/internal/gevent/provider.py deleted file mode 100644 index c07b0512d6d..00000000000 --- a/ddtrace/contrib/internal/gevent/provider.py +++ /dev/null @@ -1,47 +0,0 @@ -import gevent - -from ddtrace._trace.provider import BaseContextProvider -from ddtrace._trace.provider import DatadogContextMixin -from ddtrace.trace import Span -from ddtrace.vendor.debtcollector import deprecate - - -class GeventContextProvider(BaseContextProvider, DatadogContextMixin): - """Manages the active context for gevent execution. - - This provider depends on corresponding monkey patches to copy the active - context from one greenlet to another. - """ - - # Greenlet attribute used to set/get the context - _CONTEXT_ATTR = "__datadog_context" - - def __init__(self) -> None: - deprecate("GeventContextProvider is deprecated and will be removed in a future version.", "3.0.0") - super().__init__() - - def _get_current_context(self): - """Helper to get the active context from the current greenlet.""" - current_g = gevent.getcurrent() - if current_g is not None: - return getattr(current_g, self._CONTEXT_ATTR, None) - return None - - def _has_active_context(self): - """Helper to determine if there is an active context.""" - return self._get_current_context() is not None - - def activate(self, context): - """Sets the active context for the current running ``Greenlet``.""" - current_g = gevent.getcurrent() - if current_g is not None: - setattr(current_g, self._CONTEXT_ATTR, context) - super(GeventContextProvider, self).activate(context) - return context - - def active(self): - """Returns the active context for this execution flow.""" - ctx = self._get_current_context() - if isinstance(ctx, Span): - return self._update_active(ctx) - return ctx