prozorro_sale.tools.executors module

class prozorro_sale.tools.executors.ProcessExecutorWrapper(nthreads=1, shutdown_wait=True, shutdown_cancel_futures=True)

Bases: prozorro_sale.tools.executors.ThreatExecutorWrapper

Initializes a new ProcessPoolExecutor instance.

__slots__ = []

static _executor_init(ppid)

executor

alias of concurrent.futures.process.ProcessPoolExecutor

exception prozorro_sale.tools.executors.ProcessExit

Bases: SystemExit

code = 1

class prozorro_sale.tools.executors.ThreatExecutorWrapper(nthreads=1, shutdown_wait=True, shutdown_cancel_futures=True)

Bases: object

Initializes a new ThreadPoolExecutor instance.

__call__(func, *args, **kw)

Call self as a function.

__init__(nthreads=1, shutdown_wait=True, shutdown_cancel_futures=True)

__slots__ = ['_ex', '_loop', '_shutdown_wait', '_shutdown_cancel_futures']

_ex

static _executor_init(ppid)

_loop

_shutdown_cancel_futures

_shutdown_wait

executor

alias of concurrent.futures.thread.ThreadPoolExecutor

shutdown()

Tear down an executor and clean-up the resources associated with the it.

async prozorro_sale.tools.executors.close_process_executor(app: aiohttp.web_app.Application)

Closing an executor in app.

async prozorro_sale.tools.executors.close_threads_executor(app: aiohttp.web_app.Application)

Closing an executor in app.

async prozorro_sale.tools.executors.init_process_executor(app: aiohttp.web_app.Application)

Initialize an executor in app.

async prozorro_sale.tools.executors.init_threads_executor(app: aiohttp.web_app.Application)

Initialize an executor in app.

prozorro_sale.tools.executors.setup_process_executor(app: aiohttp.web_app.Application) → None

Append ProcessExecutor wrapper to app.

Parameters

app (object) – aiohttp.web.Application instance.

prozorro_sale.tools.executors.setup_threads_executor(app: aiohttp.web_app.Application) → None

Append ThreatExecutor wrapper to app.

Parameters

app (object) – aiohttp.web.Application instance.