3dece408885064d14883eb38547da2729950c50c,api/data_refinery_api/views.py,Stats,_get_job_stats,#Stats#Any#Any#,1216

Before Change

        return total_size["size_in_bytes__sum"] if total_size["size_in_bytes__sum"] else 0

    def _get_job_stats(self, jobs, range_param):
        result = {
            "total": jobs.count(),
            "pending": jobs.filter(start_time__isnull=True).count(),
            "completed": jobs.filter(end_time__isnull=False).count(),
            "successful": jobs.filter(success=True).count(),
            "open": jobs.filter(start_time__isnull=False, end_time__isnull=True, success__isnull=True).count(),
            // via https://stackoverflow.com/questions/32520655/get-average-of-difference-of-datetime-fields-in-django
            "average_time": jobs.filter(start_time__isnull=False, end_time__isnull=False, success=True).aggregate(
                average_time=Avg(F("end_time") - F("start_time")))["average_time"]
        }

        if not result["average_time"]:
            result["average_time"] = 0
        else:

After Change

        return total_size["size_in_bytes__sum"] if total_size["size_in_bytes__sum"] else 0

    def _get_job_stats(self, jobs, range_param):
        result = jobs.aggregate(
            total=Count("id"), 
            pending=Count("id", filter=Q(start_time__isnull=True)),
            completed=Count("id", filter=Q(end_time__isnull=False)),
            successful=Count("id", filter=Q(success=True)),
            open=Count("id", filter=Q(start_time__isnull=False, end_time__isnull=True, success__isnull=True)),
        )
        // via https://stackoverflow.com/questions/32520655/get-average-of-difference-of-datetime-fields-in-django
        result["average_time"] = jobs.filter(start_time__isnull=False, end_time__isnull=False, success=True).aggregate(
                average_time=Avg(F("end_time") - F("start_time")))["average_time"]

Instances