from ..stack_info import warn_at_user_stacklevel as warn_at_user_stacklevel
from _typeshed import Incomplete
from concurrent.futures import ProcessPoolExecutor, ThreadPoolExecutor
from logfire.propagate import ContextCarrier as ContextCarrier, attach_context as attach_context, get_context as get_context
from typing import Any, Callable

submit_t_orig: Incomplete
submit_p_orig: Incomplete

def instrument_executors() -> None:
    """Monkey-patch `submit()` methods of `ThreadPoolExecutor` and `ProcessPoolExecutor`
        to carry over OTEL context across threads and processes.
        """
def submit_t(s: ThreadPoolExecutor, fn: Callable[..., Any], /, *args: Any, **kwargs: Any):
    """A wrapper around ThreadPoolExecutor.submit() that carries over OTEL context across threads."""
def submit_p(s: ProcessPoolExecutor, fn: Callable[..., Any], /, *args: Any, **kwargs: Any):
    """A wrapper around ProcessPoolExecutor.submit() that carries over OTEL context across processes."""
def serialize_config() -> dict[str, Any] | None:
    """Serialize the global config for transmission to child processes.

    Returns None if the config cannot be pickled, in which case a warning is emitted.
    See: https://github.com/pydantic/logfire/issues/1556
    """
def deserialize_config(config: dict[str, Any] | None) -> None:
    """Deserialize a config dict and apply it to the global config."""