src/dirbs/reports/stats_generator.py
def _queue_monthly_stats_jobs(executor, futures_to_cb, results, db_config, operators, month, year,
                              per_operator_record_counts, statsd, metrics_run_root, debug_query_performance):
    """Helper function to queue monthly stats jobs."""
    futures_to_cb[executor.submit(_calc_imei_gross_adds, db_config, operators, month, year)] \
        = partial(_process_monthly_future, 'IMEI gross add', per_operator_record_counts, statsd,
                  metrics_run_root, results, debug_query_performance)
    futures_to_cb[executor.submit(_calc_invalid_id_null_counts, db_config, month, year)] \
        = partial(_process_monthly_future, 'invalid identifier (null)', per_operator_record_counts, statsd,
                  metrics_run_root, results, debug_query_performance)
    futures_to_cb[executor.submit(_calc_invalid_id_pair_and_triplet_counts, db_config, month, year)] \
        = partial(_process_monthly_future, 'invalid identifier (pairs and triplets)', per_operator_record_counts,
                  statsd, metrics_run_root, results, debug_query_performance)
Helper function to queue monthly stats jobs.
Helper function to queue monthly stats jobs.
Helper function to queue monthly stats jobs .
def _queue_monthly_stats_jobs(executor, futures_to_cb, results, db_config, operators, month, year,
                              per_operator_record_counts, statsd, metrics_run_root, debug_query_performance):
    futures_to_cb[executor.submit(_calc_imei_gross_adds, db_config, operators, month, year)] \
        = partial(_process_monthly_future, 'IMEI gross add', per_operator_record_counts, statsd,
                  metrics_run_root, results, debug_query_performance)
    futures_to_cb[executor.submit(_calc_invalid_id_null_counts, db_config, month, year)] \
        = partial(_process_monthly_future, 'invalid identifier (null)', per_operator_record_counts, statsd,
                  metrics_run_root, results, debug_query_performance)
    futures_to_cb[executor.submit(_calc_invalid_id_pair_and_triplet_counts, db_config, month, year)] \
        = partial(_process_monthly_future, 'invalid identifier (pairs and triplets)', per_operator_record_counts,
                  statsd, metrics_run_root, results, debug_query_performance)
def _queue_monthly_stats_jobs ( executor , futures_to_cb , results , db_config , operators , month , year , per_operator_record_counts , statsd , metrics_run_root , debug_query_performance ) : futures_to_cb [ executor . submit ( _calc_imei_gross_adds , db_config , operators , month , year ) ] = partial ( _process_monthly_future , 'IMEI gross add' , per_operator_record_counts , statsd , metrics_run_root , results , debug_query_performance ) futures_to_cb [ executor . submit ( _calc_invalid_id_null_counts , db_config , month , year ) ] = partial ( _process_monthly_future , 'invalid identifier (null)' , per_operator_record_counts , statsd , metrics_run_root , results , debug_query_performance ) futures_to_cb [ executor . submit ( _calc_invalid_id_pair_and_triplet_counts , db_config , month , year ) ] = partial ( _process_monthly_future , 'invalid identifier (pairs and triplets)' , per_operator_record_counts , statsd , metrics_run_root , results , debug_query_performance )
Helper function to queue monthly stats jobs.
Helper function to queue monthly stats jobs .
"""Helper function to queue monthly stats jobs."""
executor
futures_to_cb
results
db_config
operators
month
year
per_operator_record_counts
statsd
metrics_run_root
debug_query_performance