utils.env.handlers.infinito.worker packageΒΆ

SubmodulesΒΆ

utils.env.handlers.infinito.worker.cpu moduleΒΆ

INFINITO_WORKER_CPU: CPU-count base for the worker SPOT chain.

Resolves to os.cpu_count() when INFINITO_WORKER_ENABLED is truthy, otherwise to 1 (sequential).

utils.env.handlers.infinito.worker.cpu.apply(eb: EnvBuilder, ctx: BuildContext) β†’ NoneΒΆ

utils.env.handlers.infinito.worker.fetch moduleΒΆ

INFINITO_WORKER_FETCH: I/O-bound network-fetch worker count.

INFINITO_WORKER_CPU * 20, with a base of 1 collapsing to 1 (the operator’s sequential-fallback signal). Consumed by URL probers and upstream tag fetchers.

utils.env.handlers.infinito.worker.fetch.apply(eb: EnvBuilder, ctx: BuildContext) β†’ NoneΒΆ

Module contentsΒΆ

Worker resource env handlers.