driver/pipeline.py
def driver_pipeline(
    config: DriverConfig,
    job_id: str,  # pylint: disable=unused-argument
) -> None:
    """
    Run the core pipeline for the driver deployment
    """
    logging.info("Running driver pipeline deployment!")


    compute_server_client = ComputeServerClient(
        config.server_url, Session(), config.api_key
    )

    if job_id == DB_LEVEL_MONITOR_JOB_ID:
        _db_level_monitor_driver_pipeline_for_on_prem(config, compute_server_client)
    elif job_id == TABLE_LEVEL_MONITOR_JOB_ID:
        _table_level_monitor_driver_pipeline_for_on_prem(config, compute_server_client)

    Run the core pipeline for the driver deployment
    
Run the core pipeline for the driver deployment
Run the core pipeline for the driver deployment
def driver_pipeline(
    config: DriverConfig,
    job_id: str,  
) -> None:
    logging.info("Running driver pipeline deployment!")
    compute_server_client = ComputeServerClient(
        config.server_url, Session(), config.api_key
    )
    if job_id == DB_LEVEL_MONITOR_JOB_ID:
        _db_level_monitor_driver_pipeline_for_on_prem(config, compute_server_client)
    elif job_id == TABLE_LEVEL_MONITOR_JOB_ID:
        _table_level_monitor_driver_pipeline_for_on_prem(config, compute_server_client)
def driver_pipeline ( config : DriverConfig , job_id : str , ) -> None : logging . info ( "Running driver pipeline deployment!" ) compute_server_client = ComputeServerClient ( config . server_url , Session ( ) , config . api_key ) if job_id == DB_LEVEL_MONITOR_JOB_ID : _db_level_monitor_driver_pipeline_for_on_prem ( config , compute_server_client ) elif job_id == TABLE_LEVEL_MONITOR_JOB_ID : _table_level_monitor_driver_pipeline_for_on_prem ( config , compute_server_client )
Run the core pipeline for the driver deployment
Run the core pipeline for the driver deployment
# pylint: disable=unused-argument """
    Run the core pipeline for the driver deployment
    """
config
DriverConfig
job_id
str