src/dirbs/reports/stats_generator.py
def _process_per_operator_monthly_future(operator, type_string, statsd,
                                         metrics_run_root, monthly_stats, debug_query_performance, f,
                                         per_operator_record_counts=None):
    """Helper function to process a monthly stat future and populate the results data structure."""
    logger = logging.getLogger('dirbs.report')
    results, total_duration, component_durations = f.result()
    logger.info('Calculated {0} for operator {1} (duration {2:.3f}s)'
                .format(type_string, operator, total_duration / 1000))
    _print_component_query_perfomance(component_durations, debug_query_performance)
    monthly_stats[operator] = results
    _log_perf_metric(statsd, metrics_run_root, type_string, total_duration,
                     operator_id=operator, record_counts_map=per_operator_record_counts)
Helper function to process a monthly stat future and populate the results data structure.
Helper function to process a monthly stat future and populate the results data structure.
Helper function to process a monthly stat future and populate the results data structure .
def _process_per_operator_monthly_future(operator, type_string, statsd,
                                         metrics_run_root, monthly_stats, debug_query_performance, f,
                                         per_operator_record_counts=None):
    logger = logging.getLogger('dirbs.report')
    results, total_duration, component_durations = f.result()
    logger.info('Calculated {0} for operator {1} (duration {2:.3f}s)'
                .format(type_string, operator, total_duration / 1000))
    _print_component_query_perfomance(component_durations, debug_query_performance)
    monthly_stats[operator] = results
    _log_perf_metric(statsd, metrics_run_root, type_string, total_duration,
                     operator_id=operator, record_counts_map=per_operator_record_counts)
def _process_per_operator_monthly_future ( operator , type_string , statsd , metrics_run_root , monthly_stats , debug_query_performance , f , per_operator_record_counts = None ) : logger = logging . getLogger ( 'dirbs.report' ) results , total_duration , component_durations = f . result ( ) logger . info ( 'Calculated {0} for operator {1} (duration {2:.3f}s)' . format ( type_string , operator , total_duration / 1000 ) ) _print_component_query_perfomance ( component_durations , debug_query_performance ) monthly_stats [ operator ] = results _log_perf_metric ( statsd , metrics_run_root , type_string , total_duration , operator_id = operator , record_counts_map = per_operator_record_counts )
Helper function to process a monthly stat future and populate the results data structure.
Helper function to process a monthly stat future and populate the results data structure .
"""Helper function to process a monthly stat future and populate the results data structure."""
operator
type_string
statsd
metrics_run_root
monthly_stats
debug_query_performance
f
per_operator_record_counts