src/dirbs/reports/stats_generator.py
def _queue_compliance_jobs(executor, futures_to_cb, condition_counts, tac_compliance_data, compliance_data,
                           monthly_stats, db_config, operators, month, year, condition_tuples,
                           per_operator_record_counts, statsd, metrics_run_root, debug_query_performance, run_id):
    """Helper function to queue compliance stats jobs."""
    for op in operators:
        futures_to_cb[executor.submit(_calc_compliance_data, db_config, month, year, condition_tuples, operator=op,
                                      run_id=run_id)] \
            = partial(_process_per_operator_compliance_future,
                      op,
                      condition_counts,
                      per_operator_record_counts,
                      statsd,
                      metrics_run_root,
                      tac_compliance_data,
                      compliance_data,
                      monthly_stats,
                      debug_query_performance)
    futures_to_cb[executor.submit(_calc_compliance_data, db_config, month, year, condition_tuples, run_id=run_id)] \
        = partial(_process_per_operator_compliance_future,
                  OperatorConfig.COUNTRY_OPERATOR_NAME,
                  condition_counts,
                  per_operator_record_counts,
                  statsd,
                  metrics_run_root,
                  tac_compliance_data,
                  compliance_data,
                  monthly_stats,
                  debug_query_performance)
Helper function to queue compliance stats jobs.
Helper function to queue compliance stats jobs.
Helper function to queue compliance stats jobs .
def _queue_compliance_jobs(executor, futures_to_cb, condition_counts, tac_compliance_data, compliance_data,
                           monthly_stats, db_config, operators, month, year, condition_tuples,
                           per_operator_record_counts, statsd, metrics_run_root, debug_query_performance, run_id):
    for op in operators:
        futures_to_cb[executor.submit(_calc_compliance_data, db_config, month, year, condition_tuples, operator=op,
                                      run_id=run_id)] \
            = partial(_process_per_operator_compliance_future,
                      op,
                      condition_counts,
                      per_operator_record_counts,
                      statsd,
                      metrics_run_root,
                      tac_compliance_data,
                      compliance_data,
                      monthly_stats,
                      debug_query_performance)
    futures_to_cb[executor.submit(_calc_compliance_data, db_config, month, year, condition_tuples, run_id=run_id)] \
        = partial(_process_per_operator_compliance_future,
                  OperatorConfig.COUNTRY_OPERATOR_NAME,
                  condition_counts,
                  per_operator_record_counts,
                  statsd,
                  metrics_run_root,
                  tac_compliance_data,
                  compliance_data,
                  monthly_stats,
                  debug_query_performance)
def _queue_compliance_jobs ( executor , futures_to_cb , condition_counts , tac_compliance_data , compliance_data , monthly_stats , db_config , operators , month , year , condition_tuples , per_operator_record_counts , statsd , metrics_run_root , debug_query_performance , run_id ) : for op in operators : futures_to_cb [ executor . submit ( _calc_compliance_data , db_config , month , year , condition_tuples , operator = op , run_id = run_id ) ] = partial ( _process_per_operator_compliance_future , op , condition_counts , per_operator_record_counts , statsd , metrics_run_root , tac_compliance_data , compliance_data , monthly_stats , debug_query_performance ) futures_to_cb [ executor . submit ( _calc_compliance_data , db_config , month , year , condition_tuples , run_id = run_id ) ] = partial ( _process_per_operator_compliance_future , OperatorConfig . COUNTRY_OPERATOR_NAME , condition_counts , per_operator_record_counts , statsd , metrics_run_root , tac_compliance_data , compliance_data , monthly_stats , debug_query_performance )
Helper function to queue compliance stats jobs.
Helper function to queue compliance stats jobs .
"""Helper function to queue compliance stats jobs."""
executor
futures_to_cb
condition_counts
tac_compliance_data
compliance_data
monthly_stats
db_config
operators
month
year
condition_tuples
per_operator_record_counts
statsd
metrics_run_root
debug_query_performance
run_id