AdvancePythonScheduler приостановить задание - PullRequest
Новая
       72

AdvancePythonScheduler приостановить задание

0 голосов
/ 03 августа 2020

Я работаю с APScheduler и хотел бы приостановить и возобновить работу на основе запроса. Ниже приведен код, который я пробовал. 

        from apscheduler.schedulers.background import BackgroundScheduler
        from apscheduler.jobstores.mongodb import MongoDBJobStore
        from apscheduler.jobstores.sqlalchemy import SQLAlchemyJobStore
        from apscheduler.executors.pool import ThreadPoolExecutor, ProcessPoolExecutor
        from apscheduler.schedulers.base import BaseScheduler
        
        jobstores = {
            'default': SQLAlchemyJobStore(url='sqlite:///jobs.sqlite')
        }
        
        executors = {
            'default': ThreadPoolExecutor(20),
            'processpool': ProcessPoolExecutor(5)
        }
        job_defaults = {
            'coalesce': False,
            'max_instances': 3
        }
        scheduler = BackgroundScheduler(jobstores=jobstores, executors=executors, 
        job_defaults=job_defaults, timezone=utc)
    
           def testTrigger():
             print("APScheduler...")

    //Adding Job
    scheduler.add_job(testTrigger,'interval',seconds=5,id='schedule_1')
    
    //Pausing Job
    BaseScheduler.pause_job(job_id='schedule_1')

Я столкнулся со следующей ошибкой pause_job() missing 1 required positional argument: 'self'. Где я ошибаюсь?

...