code: def scale_up(self, n, pods=None, **kwargs):
          
          maximum = dask.config.get('kubernetes.count.max')
          if maximum is not None and maximum < n:
              logger.info("Tried to scale beyond maximum number of workers %d > %d",
                          n, maximum)
              n = maximum
          pods = pods or self._cleanup_terminated_pods(self.pods())
          to_create = n - len(pods)
          new_pods = []
          for i in range(3):
              try:
                  for _ in range(to_create):
                      new_pods.append(self.core_api.create_namespaced_pod(
                          self.namespace, self.pod_template))
                      to_create -= 1
                  break
              except kubernetes.client.rest.ApiException as e:
                  if e.status == 500 and 'ServerTimeout' in e.body:
                      logger.info("Server timeout, retry #%d", i + 1)
                      time.sleep(1)
                      last_exception = e
                      continue
                  else:
                      raise
          else:
              raise last_exception
  
          return new_pods
docs: Make sure we have n dask-workers available for this cluster
  
          Examples
          --------
          >>> cluster.scale_up(20)  # ask for twenty workers