gigl.src.common.constants.get_dataflow_temp_gcs_path#

gigl.src.common.constants.gcs.get_dataflow_temp_gcs_path(applied_task_identifier: AppliedTaskIdentifier, job_name: str) GcsUri#

Returns the GCS path for the “tmp” directory used for Dataflow Jobs.

Args:

applied_task_identifier (AppliedTaskIdentifier): The job name. job_name (str): The name of the Dataflow job.

Returns:

GcsUri: The GCS path for the “tmp” directory used for Dataflow Jobs.