graingert

import asyncio
import async_timeout
import quattro
import contextlib
import anyio


async def main(note, cmgr):
    try:
        async with cmgr(-11):

graingert

import asyncio

async def main():
    try:
        async with asyncio.timeout(0):
            await asyncio.sleep(0)
    except TimeoutError:
        print("PASS: great a timeout is here!")
    else:
        print("FAILED: expected a timeout")

graingert

import psutil
import multiprocessing
import socket
import sys
import concurrent.futures


ctx = multiprocessing.get_context("spawn")

def target(sock):

graingert

import timeit, random
import heapq

random.seed(42)

left = []
right = []

# Create two sorted lists of integers
n = 0

graingert

import asyncio
import ipaddress
import pprint
import socket
import sys
from socket import AddressFamily, SocketKind

from jeepney.wrappers import MessageGenerator, new_method_call

graingert

#!/usr/bin/env python3
from distributed import default_client
import sys
import asyncio
import concurrent.futures
from concurrent import futures
import contextlib
from tornado.ioloop import IOLoop
import random
import time

graingert

# Test BaseEventLoop.getaddrinfo performance, before and after my commit 39c135b
# Try a variety of getaddrinfo parameters and log the duration of 10k calls

import socket
import time
from asyncio import get_event_loop

try:
    from asyncio.base_events import _ipaddr_info
except ImportError:

graingert

import dataclasses
import operator


@dataclasses.dataclass
class WarningFilter:
    command: str
    msg: str
    cls: str
    module: str | None = None

graingert

import sys
import logging
import threading
import collections


class Record:
    def __init__(self):
        self.levelno = 0

graingert

from __future__ import annotations

import sys
import asyncio
import concurrent.futures
import contextlib


class _Client:
    def __init__(self, loop):