driver/pipeline.py
def schedule_or_update_job(
    scheduler: BlockingScheduler, config: DriverConfig, job_id: str
) -> None:
    """
    Apply configuration change to the job. If the configuration does not change, it will do nothing.
    If the job is not scheduled, it will start a job.

    Args:
        config: Driver configuration.
        job_id: Job ID.
    Raises:
        DriverException: Driver error.
        Exception: Other unknown exceptions that are not caught as DriverException.
    """
    interval = _get_interval(config, job_id)
    job = scheduler.get_job(job_id)

    if not job:
        # NB: first invocation is at current_time + interval
        _start_job(scheduler=scheduler, config=config, job_id=job_id, interval=interval)
    else:
        old_config = job.args[0]
        if old_config != config:
            _update_job(
                scheduler=scheduler,
                old_config=old_config,
                new_config=config,
                job_id=job_id,
                interval=interval,
            )

    Apply configuration change to the job. If the configuration does not change, it will do nothing.
    If the job is not scheduled, it will start a job.

    Args:
        config: Driver configuration.
        job_id: Job ID.
    Raises:
        DriverException: Driver error.
        Exception: Other unknown exceptions that are not caught as DriverException.
    
Apply configuration change to the job. If the configuration does not change, it will do nothing.
If the job is not scheduled, it will start a job.
Apply configuration change to the job . If the configuration does not change it will do nothing . If the job is not scheduled it will start a job .
def schedule_or_update_job(
    scheduler: BlockingScheduler, config: DriverConfig, job_id: str
) -> None:
    interval = _get_interval(config, job_id)
    job = scheduler.get_job(job_id)
    if not job:
        _start_job(scheduler=scheduler, config=config, job_id=job_id, interval=interval)
    else:
        old_config = job.args[0]
        if old_config != config:
            _update_job(
                scheduler=scheduler,
                old_config=old_config,
                new_config=config,
                job_id=job_id,
                interval=interval,
            )
def schedule_or_update_job ( scheduler : BlockingScheduler , config : DriverConfig , job_id : str ) -> None : interval = _get_interval ( config , job_id ) job = scheduler . get_job ( job_id ) if not job : _start_job ( scheduler = scheduler , config = config , job_id = job_id , interval = interval ) else : old_config = job . args [ 0 ] if old_config != config : _update_job ( scheduler = scheduler , old_config = old_config , new_config = config , job_id = job_id , interval = interval , )
Apply configuration change to the job.
Apply configuration change to the job .
"""
    Apply configuration change to the job. If the configuration does not change, it will do nothing.
    If the job is not scheduled, it will start a job.

    Args:
        config: Driver configuration.
        job_id: Job ID.
    Raises:
        DriverException: Driver error.
        Exception: Other unknown exceptions that are not caught as DriverException.
    """ # NB: first invocation is at current_time + interval
None
DriverException
Other unknown exceptions that are not caught as DriverException.
Other unknown exceptions that are not caught as DriverException .
Exception
scheduler
BlockingScheduler
config
DriverConfig
None
job_id
str
None