src/dirbs/reports/stats_generator.py
def _queue_record_count_jobs(executor, futures_to_cb, results, db_config, operators, month, year,
                             statsd, metrics_run_root, debug_query_performance):
    """Helper function to queue jobs to calculate the record counts for each operator."""
    for op in operators:
        futures_to_cb[executor.submit(_calc_record_count, db_config, month, year, op)] \
            = partial(_process_per_operator_monthly_future, op, 'monthly record count',
                      statsd, metrics_run_root, results, debug_query_performance)
    futures_to_cb[executor.submit(_calc_record_count, db_config, month, year)] \
        = partial(_process_per_operator_monthly_future,
                  OperatorConfig.COUNTRY_OPERATOR_NAME,
                  'monthly record count',
                  statsd,
                  metrics_run_root,
                  results,
                  debug_query_performance)
Helper function to queue jobs to calculate the record counts for each operator.
Helper function to queue jobs to calculate the record counts for each operator.
Helper function to queue jobs to calculate the record counts for each operator .
def _queue_record_count_jobs(executor, futures_to_cb, results, db_config, operators, month, year,
                             statsd, metrics_run_root, debug_query_performance):
    for op in operators:
        futures_to_cb[executor.submit(_calc_record_count, db_config, month, year, op)] \
            = partial(_process_per_operator_monthly_future, op, 'monthly record count',
                      statsd, metrics_run_root, results, debug_query_performance)
    futures_to_cb[executor.submit(_calc_record_count, db_config, month, year)] \
        = partial(_process_per_operator_monthly_future,
                  OperatorConfig.COUNTRY_OPERATOR_NAME,
                  'monthly record count',
                  statsd,
                  metrics_run_root,
                  results,
                  debug_query_performance)
def _queue_record_count_jobs ( executor , futures_to_cb , results , db_config , operators , month , year , statsd , metrics_run_root , debug_query_performance ) : for op in operators : futures_to_cb [ executor . submit ( _calc_record_count , db_config , month , year , op ) ] = partial ( _process_per_operator_monthly_future , op , 'monthly record count' , statsd , metrics_run_root , results , debug_query_performance ) futures_to_cb [ executor . submit ( _calc_record_count , db_config , month , year ) ] = partial ( _process_per_operator_monthly_future , OperatorConfig . COUNTRY_OPERATOR_NAME , 'monthly record count' , statsd , metrics_run_root , results , debug_query_performance )
Helper function to queue jobs to calculate the record counts for each operator.
Helper function to queue jobs to calculate the record counts for each operator .
"""Helper function to queue jobs to calculate the record counts for each operator."""
executor
futures_to_cb
results
db_config
operators
month
year
statsd
metrics_run_root
debug_query_performance