class_docstr: Check for the state of a previously submitted Dataproc job.
  
  :param dataproc_job_id: The Dataproc job ID to poll. (templated)
  :param region: Required. The Cloud Dataproc region in which to handle the request. (templated)
  :param project_id: The ID of the google cloud project in which
      to create the cluster. (templated)
  :param gcp_conn_id: The connection ID to use connecting to Google Cloud Platform.
  :param wait_timeout: How many seconds wait for job to be ready.
class_docstr_tok: ["Check","for","the","state","of","a","previously","submitted","Dataproc","job",".",":","param","dataproc_job_id",":","The","Dataproc","job","ID","to","poll",".","(","templated",")",":","param","region",":","Required",".","The","Cloud","Dataproc","region","in","which","to","handle","the","request",".","(","templated",")",":","param","project_id",":","The","ID","of","the","google","cloud","project","in","which","to","create","the","cluster",".","(","templated",")",":","param","gcp_conn_id",":","The","connection","ID","to","use","connecting","to","Google","Cloud","Platform",".",":","param","wait_timeout",":","How","many","seconds","wait","for","job","to","be","ready","."]
code: def execute(self, context: Context) -> None:
      self.start_sensor_time = time.monotonic()
      super().execute(context)
  
file_path: airflow/airflow/providers/google/cloud/sensors/dataproc.py
imports: from __future__ import annotations
  import time
  from typing import TYPE_CHECKING, Sequence
  from google.api_core.exceptions import ServerError
  from google.cloud.dataproc_v1.types import Batch, JobStatus
  from airflow.exceptions import AirflowException, AirflowSkipException
  from airflow.providers.google.cloud.hooks.dataproc import DataprocHook
  from airflow.sensors.base import BaseSensorOperator
label_desc: Use image node_id 2 for calling the DataprocJobSensor obj's underlying member method code with example usage: obj.execute(context) without return types