src/dirbs/condition.py
def queue_update_classification_state_jobs(self, executor, app_config, run_id, curr_date):
        """
        Method to queue jobs to update the classification_state table after the IMEIs have been calculated.

        Arguments:
            executor: job executor instance to submit back the results to the queue
            app_config: current dirbs app config object to use configuration from
            run_id: run_id of the current running classification job
            curr_date: current date of the system
        """
        with create_db_connection(app_config.db_config) as conn:
            parallel_shards = partition_utils.num_physical_imei_shards(conn)
            virt_imei_shard_ranges = partition_utils.virt_imei_shard_bounds(parallel_shards)
            for virt_imei_range_start, virt_imei_range_end in virt_imei_shard_ranges:
                yield executor.submit(self._update_classification_state_job,
                                      app_config,
                                      run_id,
                                      curr_date,
                                      virt_imei_range_start,
                                      virt_imei_range_end)

        Method to queue jobs to update the classification_state table after the IMEIs have been calculated.

        Arguments:
            executor: job executor instance to submit back the results to the queue
            app_config: current dirbs app config object to use configuration from
            run_id: run_id of the current running classification job
            curr_date: current date of the system
        
Method to queue jobs to update the classification_state table after the IMEIs have been calculated.
Method to queue jobs to update the classification_state table after the IMEIs have been calculated .
def queue_update_classification_state_jobs(self, executor, app_config, run_id, curr_date):
        with create_db_connection(app_config.db_config) as conn:
            parallel_shards = partition_utils.num_physical_imei_shards(conn)
            virt_imei_shard_ranges = partition_utils.virt_imei_shard_bounds(parallel_shards)
            for virt_imei_range_start, virt_imei_range_end in virt_imei_shard_ranges:
                yield executor.submit(self._update_classification_state_job,
                                      app_config,
                                      run_id,
                                      curr_date,
                                      virt_imei_range_start,
                                      virt_imei_range_end)
def queue_update_classification_state_jobs ( self , executor , app_config , run_id , curr_date ) : with create_db_connection ( app_config . db_config ) as conn : parallel_shards = partition_utils . num_physical_imei_shards ( conn ) virt_imei_shard_ranges = partition_utils . virt_imei_shard_bounds ( parallel_shards ) for virt_imei_range_start , virt_imei_range_end in virt_imei_shard_ranges : yield executor . submit ( self . _update_classification_state_job , app_config , run_id , curr_date , virt_imei_range_start , virt_imei_range_end )
Method to queue jobs to update the classification_state table after the IMEIs have been calculated.
Method to queue jobs to update the classification_state table after the IMEIs have been calculated .
"""
        Method to queue jobs to update the classification_state table after the IMEIs have been calculated.

        Arguments:
            executor: job executor instance to submit back the results to the queue
            app_config: current dirbs app config object to use configuration from
            run_id: run_id of the current running classification job
            curr_date: current date of the system
        """
self
executor
job executor instance to submit back the results to the queue
job executor instance to submit back the results to the queue
app_config
current dirbs app config object to use configuration from
current dirbs app config object to use configuration from
run_id
run_id of the current running classification job
run_id of the current running classification job
curr_date
current date of the system
current date of the system