0c8918b5e6ff63857f89c76468a5ec2d2aa005ae,distributed/deploy/adaptive.py,Adaptive,needs_cpu,#Adaptive#,131

Before Change

        than ``startup_cost``.
        
        total_occupancy = self.scheduler.total_occupancy
        total_cores = sum([ws.ncores for ws in self.scheduler.workers.values()])

        if total_occupancy / (total_cores + 1e-9) > self.startup_cost * 2:
            logger.info(
                "CPU limit exceeded [%d occupancy / %d cores]",

After Change

                total_cores,
            )

            tasks_processing = 0

            for w in self.scheduler.workers.values():
                tasks_processing += len(w.processing)

                if tasks_processing > total_cores:
                    logger.info(
                        "pending tasks exceed number of cores " "[%d tasks / %d cores]",

Instances