def create_job_request()

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

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

  def create_job_request(self):

    container1 = self._create_container()
    volumes1 = self._create_volumes()
    mounts1 = self._create_volume_mounts()
    container1.volume_mounts = mounts1
    pod_template1 = self._create_pod_template(container1, volumes1)

    # Create JobSpec
    parallelism = get_setting("parallelism", settings)
    suspend = get_setting("suspend", settings)
    job_spec=kubernetes.client.V1JobSpec(
      template=pod_template1, 
      suspend=suspend, 
      parallelism=parallelism
      )
    completion_mode = get_setting("completion_mode", settings)
    if completion_mode == "Indexed":
      completions = get_setting("completions", settings)
      job_spec.completion_mode = completion_mode
      job_spec.completions = completions

    # Create Job ObjectMetadata
    jobspec_metadata=kubernetes.client.V1ObjectMeta(
      generate_name=self.job_prefix,
    )
    # Create a V1Job object
    job_request = kubernetes.client.V1Job(
      api_version="batch/v1",
      kind="Job",
      spec=job_spec,
      metadata=jobspec_metadata,
    )
    return(job_request)