src/dirbs/reports/stats_generator.py
def _process_monthly_future(type_string, per_operator_record_counts, statsd, metrics_run_root, monthly_stats,
                            debug_query_performance, f):
    """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 monthly {0} counts for all operators (duration {1:.3f}s)'
                .format(type_string, total_duration / 1000))
    _print_component_query_perfomance(component_durations, debug_query_performance)
    for operator, monthly_counts in results.items():
        monthly_stats[operator].update(monthly_counts)
    _log_perf_metric(statsd, metrics_run_root, type_string, total_duration,
                     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_monthly_future(type_string, per_operator_record_counts, statsd, metrics_run_root, monthly_stats,
                            debug_query_performance, f):
    logger = logging.getLogger('dirbs.report')
    results, total_duration, component_durations = f.result()
    logger.info('Calculated monthly {0} counts for all operators (duration {1:.3f}s)'
                .format(type_string, total_duration / 1000))
    _print_component_query_perfomance(component_durations, debug_query_performance)
    for operator, monthly_counts in results.items():
        monthly_stats[operator].update(monthly_counts)
    _log_perf_metric(statsd, metrics_run_root, type_string, total_duration,
                     record_counts_map=per_operator_record_counts)
def _process_monthly_future ( type_string , per_operator_record_counts , statsd , metrics_run_root , monthly_stats , debug_query_performance , f ) : logger = logging . getLogger ( 'dirbs.report' ) results , total_duration , component_durations = f . result ( ) logger . info ( 'Calculated monthly {0} counts for all operators (duration {1:.3f}s)' . format ( type_string , total_duration / 1000 ) ) _print_component_query_perfomance ( component_durations , debug_query_performance ) for operator , monthly_counts in results . items ( ) : monthly_stats [ operator ] . update ( monthly_counts ) _log_perf_metric ( statsd , metrics_run_root , type_string , total_duration , 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."""
type_string
per_operator_record_counts
statsd
metrics_run_root
monthly_stats
debug_query_performance
f