code: def _create_job():
      runnable = batch_v1.Runnable()
      runnable.container = batch_v1.Runnable.Container()
      runnable.container.image_uri = "gcr.io/google-containers/busybox"
      runnable.container.entrypoint = "/bin/sh"
      runnable.container.commands = [
          "-c",
          "echo Hello world! This is task ${BATCH_TASK_INDEX}.\
            This job has a total of ${BATCH_TASK_COUNT} tasks.",
      ]
  
      task = batch_v1.TaskSpec()
      task.runnables = [runnable]
  
      resources = batch_v1.ComputeResource()
      resources.cpu_milli = 2000
      resources.memory_mib = 16
      task.compute_resource = resources
      task.max_retry_count = 2
  
      group = batch_v1.TaskGroup()
      group.task_count = 2
      group.task_spec = task
      policy = batch_v1.AllocationPolicy.InstancePolicy()
      policy.machine_type = "e2-standard-4"
      instances = batch_v1.AllocationPolicy.InstancePolicyOrTemplate()
      instances.policy = policy
      allocation_policy = batch_v1.AllocationPolicy()
      allocation_policy.instances = [instances]
  
      job = batch_v1.Job()
      job.task_groups = [group]
      job.allocation_policy = allocation_policy
      job.labels = {"env": "testing", "type": "container"}
  
      job.logs_policy = batch_v1.LogsPolicy()
      job.logs_policy.destination = (
          batch_v1.LogsPolicy.Destination.CLOUD_LOGGING
      )
  
      return job
  
file_path: airflow/tests/system/providers/google/cloud/cloud_batch/example_cloud_batch.py
imports: from __future__ import annotations
  import os
  from datetime import datetime
  from google.cloud import batch_v1
  from airflow.models.dag import DAG
  from airflow.operators.python import PythonOperator
  from airflow.providers.google.cloud.operators.cloud_batch import CloudBatchDeleteJobOperator, CloudBatchListJobsOperator, CloudBatchListTasksOperator, CloudBatchSubmitJobOperator
  from airflow.utils.trigger_rule import TriggerRule
  from tests.system.utils import get_test_run
label_desc: Use image node_id 3 for calling a global function with example usage: _create_job() and returns: job