Почему ProcessPoolExecutor игнорирует аргумент max_workers?

Question

Я ожидал, что аргумент apscheduler.executors.pool.ProcessPoolExecutor с аргументом max_workers, установленным в 1, не будет выполнять более одного задания параллельно.

import subprocess 

from apscheduler.executors.pool import ProcessPoolExecutor 
from apscheduler.schedulers.blocking import BlockingScheduler 


def run_job(): 
    subprocess.check_call('echo start; sleep 3; echo done', shell=True) 

scheduler = BlockingScheduler(
     executors={'processpool': ProcessPoolExecutor(max_workers=1)}) 

for i in range(20): 
    scheduler.add_job(run_job) 
scheduler.start()         

Однако фактически параллельно выполняется до десяти заданий.

Не понял ли я концепт или это ошибка? .

Answer 1

Причина этого не работает, как ожидалось, потому что вы не уточняя, которые ИСПОЛНИТЕЛЬ вы хотите запустить работу в

Попробуйте вместо этого:

for i in range(20): 
    scheduler.add_job(run_job, executor='processpool')