Skip to main content

contextvars friendly ThreadPoolExecutor

Project description

info:contextvars friendly ThreadPoolExecutor


pip install contextvars_executor


import asyncio
import contextvars

from contextvars_executor import ContextVarExecutor

ctx = contextvars.ContextVar('42')

def thread():
    ret = ctx.get()

    assert ret == 42

    return ret

async def main(*, loop):

    ret = await loop.run_in_executor(None, thread)

    assert ret == 42

loop = asyncio.get_event_loop()

Python 3.7+ is required, there is no need to support older python versions!!!

Project details

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

contextvars_executor-0.0.1.tar.gz (2.2 kB view hashes)

Uploaded source

Supported by

AWS AWS Cloud computing Datadog Datadog Monitoring Facebook / Instagram Facebook / Instagram PSF Sponsor Fastly Fastly CDN Google Google Object Storage and Download Analytics Huawei Huawei PSF Sponsor Microsoft Microsoft PSF Sponsor NVIDIA NVIDIA PSF Sponsor Pingdom Pingdom Monitoring Salesforce Salesforce PSF Sponsor Sentry Sentry Error logging StatusPage StatusPage Status page