src/dirbs/reports/stats_generator.py
def _queue_imei_imsi_overloading_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 IMEI-IMSI overloading jobs."""
    for op in operators:
        futures_to_cb[executor.submit(_calc_imei_imsi_overloading, db_config, month, year, op)] \
            = partial(_process_per_operator_monthly_future, op, 'IMEI-IMSI overloading',
                      statsd, metrics_run_root, results, debug_query_performance,
                      per_operator_record_counts=per_operator_record_counts)
    futures_to_cb[executor.submit(_calc_imei_imsi_overloading, db_config, month, year)] \
        = partial(_process_per_operator_monthly_future,
                  OperatorConfig.COUNTRY_OPERATOR_NAME,
                  'IMEI-IMSI overloading',
                  statsd,
                  metrics_run_root,
                  results,
                  debug_query_performance,
                  per_operator_record_counts=per_operator_record_counts)
Helper function to queue IMEI-IMSI overloading jobs.
Helper function to queue IMEI-IMSI overloading jobs.
Helper function to queue IMEI - IMSI overloading jobs .
def _queue_imei_imsi_overloading_jobs(executor, futures_to_cb, results,
                                      db_config, operators, month, year, per_operator_record_counts,
                                      statsd, metrics_run_root, debug_query_performance):
    for op in operators:
        futures_to_cb[executor.submit(_calc_imei_imsi_overloading, db_config, month, year, op)] \
            = partial(_process_per_operator_monthly_future, op, 'IMEI-IMSI overloading',
                      statsd, metrics_run_root, results, debug_query_performance,
                      per_operator_record_counts=per_operator_record_counts)
    futures_to_cb[executor.submit(_calc_imei_imsi_overloading, db_config, month, year)] \
        = partial(_process_per_operator_monthly_future,
                  OperatorConfig.COUNTRY_OPERATOR_NAME,
                  'IMEI-IMSI overloading',
                  statsd,
                  metrics_run_root,
                  results,
                  debug_query_performance,
                  per_operator_record_counts=per_operator_record_counts)
def _queue_imei_imsi_overloading_jobs ( executor , futures_to_cb , results , db_config , operators , month , year , per_operator_record_counts , statsd , metrics_run_root , debug_query_performance ) : for op in operators : futures_to_cb [ executor . submit ( _calc_imei_imsi_overloading , db_config , month , year , op ) ] = partial ( _process_per_operator_monthly_future , op , 'IMEI-IMSI overloading' , statsd , metrics_run_root , results , debug_query_performance , per_operator_record_counts = per_operator_record_counts ) futures_to_cb [ executor . submit ( _calc_imei_imsi_overloading , db_config , month , year ) ] = partial ( _process_per_operator_monthly_future , OperatorConfig . COUNTRY_OPERATOR_NAME , 'IMEI-IMSI overloading' , statsd , metrics_run_root , results , debug_query_performance , per_operator_record_counts = per_operator_record_counts )
Helper function to queue IMEI-IMSI overloading jobs.
Helper function to queue IMEI - IMSI overloading jobs .
"""Helper function to queue IMEI-IMSI overloading jobs."""
executor
futures_to_cb
results
db_config
operators
month
year
per_operator_record_counts
statsd
metrics_run_root
debug_query_performance