driver/pipeline.py
def _get_interval(config: DriverConfig, job_id: str) -> int:
    """Get the scheduled time interval (sec) based on job id."""

    if job_id == DB_LEVEL_MONITOR_JOB_ID:
        interval_s = int(config.monitor_interval)
    elif job_id == TABLE_LEVEL_MONITOR_JOB_ID:
        interval_s = int(config.table_level_monitor_interval)
    else:
        raise ValueError(f"Job {job_id} is not supported")
    return interval_s
Get the scheduled time interval (sec) based on job id.
Get the scheduled time interval (sec) based on job id.
Get the scheduled time interval ( sec ) based on job id .
def _get_interval(config: DriverConfig, job_id: str) -> int:
    if job_id == DB_LEVEL_MONITOR_JOB_ID:
        interval_s = int(config.monitor_interval)
    elif job_id == TABLE_LEVEL_MONITOR_JOB_ID:
        interval_s = int(config.table_level_monitor_interval)
    else:
        raise ValueError(f"Job {job_id} is not supported")
    return interval_s
def _get_interval ( config : DriverConfig , job_id : str ) -> int : if job_id == DB_LEVEL_MONITOR_JOB_ID : interval_s = int ( config . monitor_interval ) elif job_id == TABLE_LEVEL_MONITOR_JOB_ID : interval_s = int ( config . table_level_monitor_interval ) else : raise ValueError ( f"Job {job_id} is not supported" ) return interval_s
Get the scheduled time interval (sec) based on job id.
Get the scheduled time interval ( sec ) based on job id .
"""Get the scheduled time interval (sec) based on job id."""
config
DriverConfig
job_id
str