:py:mod:`astronomer.providers.google.cloud.hooks.dataproc` ========================================================== .. py:module:: astronomer.providers.google.cloud.hooks.dataproc Module Contents --------------- Classes ~~~~~~~ .. autoapisummary:: astronomer.providers.google.cloud.hooks.dataproc.DataprocHookAsync Attributes ~~~~~~~~~~ .. autoapisummary:: astronomer.providers.google.cloud.hooks.dataproc.JobType .. py:data:: JobType .. py:class:: DataprocHookAsync(gcp_conn_id = 'google_cloud_default', delegate_to = None, impersonation_chain = None) Bases: :py:obj:`airflow.providers.google.cloud.hooks.dataproc.DataprocHook` Async Hook for Google Cloud Dataproc APIs. All the methods in the hook where project_id is used must be called with keyword arguments rather than positional. .. py:method:: get_job(self, job_id, project_id, region = None, location = None, retry = None, timeout = None, metadata = ()) :async: Gets the resource representation for a job in a project. :param job_id: Id of the Dataproc job :param project_id: Required. The ID of the Google Cloud project the cluster belongs to. :param region: Required. The Cloud Dataproc region in which to handle the request. :param location: (To be deprecated). The Cloud Dataproc region in which to handle the request. :param retry: A retry object used to retry requests. If ``None`` is specified, requests will not be retried. :param timeout: The amount of time, in seconds, to wait for the request to complete. Note that if ``retry`` is specified, the timeout applies to each individual attempt. :param metadata: Additional metadata that is provided to the method.