contextvars_usage_pypi.txt

airflow/utils/log/trigger_handler.py:ctx_indiv_trigger: ContextVar = ContextVar("__individual_trigger")
airflow/utils/log/trigger_handler.py:ctx_task_instance: ContextVar = ContextVar("task_instance")
airflow/utils/log/trigger_handler.py:ctx_trigger_end: ContextVar = ContextVar("trigger_end")
airflow/utils/log/trigger_handler.py:ctx_trigger_id: ContextVar = ContextVar("trigger_id")
asgiref/local.py:        self._data: "contextvars.ContextVar[Dict[str, Any]]" = contextvars.ContextVar(
asgiref/sync.py:        contextvars.ContextVar("thread_sensitive_context")
asgiref/sync.py:    deadlock_context: "contextvars.ContextVar[bool]" = contextvars.ContextVar(
asgiref/sync.py:    thread_sensitive_context: "contextvars.ContextVar[ThreadSensitiveContext]" = (
azure/identity/_internal/utils.py:within_credential_chain = ContextVar("within_credential_chain", default=False)
azure/identity/_internal/utils.py:within_dac = ContextVar("within_dac", default=False)
dbt_common/context.py:_INVOCATION_CONTEXT_VAR: ContextVar[InvocationContext] = ContextVar("DBT_INVOCATION_CONTEXT_VAR")
dbt_common/events/contextvars.py:            var = contextvars.ContextVar(prefix_key, default=Ellipsis)
dbt_common/events/contextvars.py:_context_vars: Dict[str, contextvars.ContextVar] = {}
dns/_immutable_ctx.py:_in__init__ = contextvars.ContextVar("_immutable_in__init__", default=False)
flask/globals.py:_cv_app: ContextVar["AppContext"] = ContextVar("flask.app_ctx")
flask/globals.py:_cv_request: ContextVar["RequestContext"] = ContextVar("flask.request_ctx")
hypothesis/strategies/_internal/core.py:_recurse_guard: ContextVar = ContextVar("recurse_guard")
ipykernel/iostream.py:        self._parent_header: contextvars.ContextVar[Dict[str, Any]] = contextvars.ContextVar(
jupyter_core/utils/__init__.py:_loop: ContextVar[asyncio.AbstractEventLoop | None] = ContextVar("_loop", default=None)
jupyter_server/base/call_context.py:    _name_value_map: ContextVar[dict[str, Any]] = ContextVar(_NAME_VALUE_MAP)
langchain_community/callbacks/llmonitor_callback.py:user_ctx = ContextVar[Union[str, None]]("user_ctx", default=None)
langchain_community/callbacks/llmonitor_callback.py:user_props_ctx = ContextVar[Union[str, None]]("user_props_ctx", default=None)
langchain_community/callbacks/manager.py:] = ContextVar("bedrock_anthropic_callback", default=None)
langchain_community/callbacks/manager.py:bedrock_anthropic_callback_var: (ContextVar)[
langchain_community/callbacks/manager.py:comet_tracing_callback_var: ContextVar[Optional[CometTracer]] = ContextVar(
langchain_community/callbacks/manager.py:openai_callback_var: ContextVar[Optional[OpenAICallbackHandler]] = ContextVar(
langchain_community/callbacks/manager.py:wandb_tracing_callback_var: ContextVar[Optional[WandbTracer]] = ContextVar(
langchain_core/runnables/config.py:var_child_runnable_config = ContextVar(
langchain_core/tracers/context.py:    context_var: ContextVar[Optional[Any]],
langchain_core/tracers/context.py:run_collector_var: ContextVar[Optional[RunCollectorCallbackHandler]] = ContextVar(
langchain_core/tracers/context.py:tracing_v2_callback_var: ContextVar[Optional[LangChainTracer]] = ContextVar(
langsmith/run_helpers.py:_CLIENT = contextvars.ContextVar[Optional[ls_client.Client]]("_CLIENT", default=None)
langsmith/run_helpers.py:_CONTEXT_KEYS: Dict[str, contextvars.ContextVar] = {
langsmith/run_helpers.py:_METADATA = contextvars.ContextVar[Optional[Dict[str, Any]]]("_METADATA", default=None)
langsmith/run_helpers.py:_PARENT_RUN_TREE = contextvars.ContextVar[Optional[run_trees.RunTree]](
langsmith/run_helpers.py:_PROJECT_NAME = contextvars.ContextVar[Optional[str]]("_PROJECT_NAME", default=None)
langsmith/run_helpers.py:_TAGS = contextvars.ContextVar[Optional[List[str]]]("_TAGS", default=None)
langsmith/run_helpers.py:_TRACING_ENABLED = contextvars.ContextVar[Optional[Union[bool, Literal["local"]]]](
loguru/_logger.py:context = ContextVar("loguru_context", default={})
numpy/_core/_ufunc_config.py:NO_NEP50_WARNING = contextvars.ContextVar("_no_nep50_warning", default=False)
prompt_toolkit/application/current.py:_current_app_session: ContextVar[AppSession] = ContextVar(
pydantic/_internal/_generics.py:_generic_recursion_cache: ContextVar[set[str] | None] = ContextVar('_generic_recursion_cache', default=None)
pymongo/_csot.py:DEADLINE: ContextVar[float] = ContextVar("DEADLINE", default=float("inf"))
pymongo/_csot.py:RTT: ContextVar[float] = ContextVar("RTT", default=0.0)
pymongo/_csot.py:TIMEOUT: ContextVar[Optional[float]] = ContextVar("TIMEOUT", default=None)
selenium/webdriver/common/bidi/cdp.py:    _connection_context = contextvars.ContextVar("_connection_context", default=connection)
selenium/webdriver/common/bidi/cdp.py:    _session_context = contextvars.ContextVar("_session_context", default=session)
selenium/webdriver/common/bidi/cdp.py:_connection_context: contextvars.ContextVar = contextvars.ContextVar("connection_context")
selenium/webdriver/common/bidi/cdp.py:_session_context: contextvars.ContextVar = contextvars.ContextVar("session_context")
sentry_sdk/ai/monitoring.py:_ai_pipeline_name = ContextVar("ai_pipeline_name", default=None)
sentry_sdk/client.py:_client_init_debug = ContextVar("client_init_debug")
sentry_sdk/hub.py:_local = ContextVar("sentry_current_hub")
sentry_sdk/integrations/asgi.py:_asgi_middleware_applied = ContextVar("sentry_asgi_middleware_applied")
sentry_sdk/integrations/dedupe.py:        self._last_seen = ContextVar("last-seen")
sentry_sdk/integrations/django/middleware.py:_import_string_should_wrap_middleware = ContextVar(
sentry_sdk/integrations/wsgi.py:_wsgi_middleware_applied = ContextVar("sentry_wsgi_middleware_applied")
sentry_sdk/metrics.py:_in_metrics = ContextVar("in_metrics", default=False)
sentry_sdk/scope.py:_current_scope = ContextVar("current_scope", default=None)
sentry_sdk/scope.py:_isolation_scope = ContextVar("isolation_scope", default=None)
sentry_sdk/utils.py:disable_capture_event = ContextVar("disable_capture_event")
sniffio/_impl.py:current_async_library_cvar = ContextVar(
structlog/contextvars.py:            var = contextvars.ContextVar(structlog_k, default=Ellipsis)
structlog/contextvars.py:    contextvars.ContextVar("_ASYNC_CALLING_STACK")
structlog/contextvars.py:_ASYNC_CALLING_STACK: contextvars.ContextVar[FrameType] = (
structlog/contextvars.py:_CONTEXT_VARS: dict[str, contextvars.ContextVar[Any]] = {}
werkzeug/debug/console.py:_ipy: ContextVar = ContextVar("werkzeug.debug.console.ipy")
werkzeug/debug/console.py:_stream: ContextVar["HTMLStringO"] = ContextVar("werkzeug.debug.console.stream")
werkzeug/local.py:            context_var = ContextVar(f"werkzeug.LocalStack<{id(self)}>.storage")
werkzeug/local.py:        _request_var = ContextVar("request")