blob: 6dfb59c39f264c87f766054461b000096dbf99b0 [file]
from .metrics import metrics as metrics
from concurrent.futures import Executor
from typing import Any
class AsyncioExecutor(Executor):
def __init__(self, delegate, loop: Any | None = ..., logger: Any | None = ..., name: str = ...) -> None: ...
def submit(self, *args, **kwargs): ...
def submit_with_loop(self, loop, fn, *args, **kwargs): ...
def shutdown(self, wait: bool = ..., **_kwargs) -> None: ...