src/dirbs/reports/stats_generator.py
def _process_per_operator_compliance_future(operator, condition_counts, per_operator_record_counts, statsd,
                                            metrics_run_root, tac_compliance_data, compliance_data, monthly_stats,
                                            debug_query_performance, f):
    """Helper function to process a compliance future and populate the results data structures."""
    logger = logging.getLogger('dirbs.report')
    per_tac_results, results, per_condition_counts, compliance_breakdown, \
        total_duration, component_durations = f.result()
    logger.info('Calculated compliance data for operator {0} (duration {1:.3f}s)'
                .format(operator, total_duration / 1000))
    _print_component_query_perfomance(component_durations, debug_query_performance)
    tac_compliance_data[operator] = per_tac_results
    compliance_data[operator] = results
    condition_counts[operator] = per_condition_counts
    monthly_stats[operator].update(compliance_breakdown)
    _log_perf_metric(statsd, metrics_run_root, 'compliance_data', total_duration,
                     operator_id=operator, record_counts_map=per_operator_record_counts)
Helper function to process a compliance future and populate the results data structures.
Helper function to process a compliance future and populate the results data structures.
Helper function to process a compliance future and populate the results data structures .
def _process_per_operator_compliance_future(operator, condition_counts, per_operator_record_counts, statsd,
                                            metrics_run_root, tac_compliance_data, compliance_data, monthly_stats,
                                            debug_query_performance, f):
    logger = logging.getLogger('dirbs.report')
    per_tac_results, results, per_condition_counts, compliance_breakdown, \
        total_duration, component_durations = f.result()
    logger.info('Calculated compliance data for operator {0} (duration {1:.3f}s)'
                .format(operator, total_duration / 1000))
    _print_component_query_perfomance(component_durations, debug_query_performance)
    tac_compliance_data[operator] = per_tac_results
    compliance_data[operator] = results
    condition_counts[operator] = per_condition_counts
    monthly_stats[operator].update(compliance_breakdown)
    _log_perf_metric(statsd, metrics_run_root, 'compliance_data', total_duration,
                     operator_id=operator, record_counts_map=per_operator_record_counts)
def _process_per_operator_compliance_future ( operator , condition_counts , per_operator_record_counts , statsd , metrics_run_root , tac_compliance_data , compliance_data , monthly_stats , debug_query_performance , f ) : logger = logging . getLogger ( 'dirbs.report' ) per_tac_results , results , per_condition_counts , compliance_breakdown , total_duration , component_durations = f . result ( ) logger . info ( 'Calculated compliance data for operator {0} (duration {1:.3f}s)' . format ( operator , total_duration / 1000 ) ) _print_component_query_perfomance ( component_durations , debug_query_performance ) tac_compliance_data [ operator ] = per_tac_results compliance_data [ operator ] = results condition_counts [ operator ] = per_condition_counts monthly_stats [ operator ] . update ( compliance_breakdown ) _log_perf_metric ( statsd , metrics_run_root , 'compliance_data' , total_duration , operator_id = operator , record_counts_map = per_operator_record_counts )
Helper function to process a compliance future and populate the results data structures.
Helper function to process a compliance future and populate the results data structures .
"""Helper function to process a compliance future and populate the results data structures."""
operator
condition_counts
per_operator_record_counts
statsd
metrics_run_root
tac_compliance_data
compliance_data
monthly_stats
debug_query_performance
f