polymer/Polymer.py
def log_message(self):
        """Build a log message and reset the stats"""
        time_delta = deepcopy(self.time_delta)
        total_work_time = self.worker_count * time_delta
        time_worked = sum(self.exec_times)
        pct_busy = time_worked / total_work_time * 100.0

        min_task_time = min(self.exec_times)
        avg_task_time = sum(self.exec_times) / len(self.exec_times)
        max_task_time = max(self.exec_times)

        min_queue_time = min(self.queue_times)
        avg_queue_time = sum(self.queue_times) / len(self.queue_times)
        max_queue_time = max(self.queue_times)

        time_delta = self.time_delta
        total_tasks = len(self.exec_times)
        avg_task_rate = total_tasks / time_delta

        self.reset()

        task_msg = """Ran {0} tasks, {1} tasks/s; {2} workers {3}% busy""".format(
            total_tasks, round(avg_task_rate, 1), self.worker_count, round(pct_busy, 1)
        )
        task_mam = """     Task run times: {0}/{1}/{2} (min/avg/max)""".format(
            round(min_task_time, 3), round(avg_task_time, 3), round(max_task_time, 3)
        )
        queue_mam = """     Time in queue: {0}/{1}/{2} (min/avg/max)""".format(
            round(min_queue_time, 6), round(avg_queue_time, 6), round(max_queue_time, 6)
        )

        return """{0}\n{1}\n{2}""".format(task_msg, task_mam, queue_mam)
def log_message(self):
        """Build a log message and reset the stats"""
        time_delta = deepcopy(self.time_delta)
        total_work_time = self.worker_count * time_delta
        time_worked = sum(self.exec_times)
        pct_busy = time_worked / total_work_time * 100.0

        min_task_time = min(self.exec_times)
        avg_task_time = sum(self.exec_times) / len(self.exec_times)
        max_task_time = max(self.exec_times)

        min_queue_time = min(self.queue_times)
        avg_queue_time = sum(self.queue_times) / len(self.queue_times)
        max_queue_time = max(self.queue_times)

        time_delta = self.time_delta
        total_tasks = len(self.exec_times)
        avg_task_rate = total_tasks / time_delta

        self.reset()

        task_msg = """Ran {0} tasks, {1} tasks/s; {2} workers {3}% busy""".format(
            total_tasks, round(avg_task_rate, 1), self.worker_count, round(pct_busy, 1)
        )
        task_mam = """     Task run times: {0}/{1}/{2} (min/avg/max)""".format(
            round(min_task_time, 3), round(avg_task_time, 3), round(max_task_time, 3)
        )
        queue_mam = """     Time in queue: {0}/{1}/{2} (min/avg/max)""".format(
            round(min_queue_time, 6), round(avg_queue_time, 6), round(max_queue_time, 6)
        )

        return """{0}\n{1}\n{2}""".format(task_msg, task_mam, queue_mam)
def log_message ( self ) : time_delta = deepcopy ( self . time_delta ) total_work_time = self . worker_count * time_delta time_worked = sum ( self . exec_times ) pct_busy = time_worked / total_work_time * 100.0 min_task_time = min ( self . exec_times ) avg_task_time = sum ( self . exec_times ) / len ( self . exec_times ) max_task_time = max ( self . exec_times ) min_queue_time = min ( self . queue_times ) avg_queue_time = sum ( self . queue_times ) / len ( self . queue_times ) max_queue_time = max ( self . queue_times ) time_delta = self . time_delta total_tasks = len ( self . exec_times ) avg_task_rate = total_tasks / time_delta self . reset ( ) task_msg = """Ran {0} tasks, {1} tasks/s; {2} workers {3}% busy""" . format ( total_tasks , round ( avg_task_rate , 1 ) , self . worker_count , round ( pct_busy , 1 ) ) task_mam = """     Task run times: {0}/{1}/{2} (min/avg/max)""" . format ( round ( min_task_time , 3 ) , round ( avg_task_time , 3 ) , round ( max_task_time , 3 ) ) queue_mam = """     Time in queue: {0}/{1}/{2} (min/avg/max)""" . format ( round ( min_queue_time , 6 ) , round ( avg_queue_time , 6 ) , round ( max_queue_time , 6 ) ) return """{0}\n{1}\n{2}""" . format ( task_msg , task_mam , queue_mam )
Build a log message and reset the stats
Build a log message and reset the stats