def _create_job_request()

in python-batch/batch.py [0:0]

• 8 lines of code
• 2 McCabe index (conditional complexity)

  def _create_job_request(self):
      """Creates job after configuration is completed. 
      """

      self.job = batch_v1.Job()
      self.job.labels = self.config["labels"] if "labels" in self.config else {"env": "hpc", "type": "hpc"}

      self.job.task_groups = [self.group]
      self.job.allocation_policy = self.allocation_policy

      # We use Cloud Logging as it's an out of the box available option
      self.job.logs_policy = batch_v1.LogsPolicy()
      self.job.logs_policy.destination = batch_v1.LogsPolicy.Destination.CLOUD_LOGGING
      return(self.job)