\SrSSKJr SSKJr SSKJr SSKrSSKrSSKJr SSKJ r SSK J r SSK Jr SS K Jr SS K Jr SS K Jr \R""S 5r\ R&r\R""S 5rSrSR-\5rSrSSjrSSjrSSjrSrSrSrg)z(Utilities for building the dataflow CLI.)absolute_import)division)unicode_literalsN) exceptions) list_pager)apis)log) properties) resourcesz ^dataflowz^(.*)-windmill-(.*)-watermarkz dataflow.projects.locations.jobszDefaults to '{0}'.c[R"UR5nURS05RSS5$![a, [ R RUR5 gf=f)zExtract the error message from an HTTPError. Args: error: The error exceptions.HttpError thrown by the API client. Returns: A string describing the error. errormessagez Unknown error) jsonloadscontentget ValueErrorr errPrintresponse)r content_objs 8lib/googlecloudsdk/command_lib/dataflow/dataflow_util.pyGetErrorMessager2s]**U]]+K ??7B ' + +Ir :: GGMM%..! sAA3A:9A:cU(aSRU5nU(aSRU5nU(aSRU5nSRXU[U55$)aLCreate a standard error message across commands. Args: error: The error exceptions.HttpError thrown by the API client. job_id: The job ID that was used in the command. project_id: The project ID that was used in the command. region_id: The region ID that was used in the command. Returns: str, a standard error message. z with job ID [{0}]z in project [{0}]z in regional endpoint [{0}]zFailed operation{0}{1}{2}: {3})formatr)r job_id project_id region_ids rMakeErrorMessager Cs^ ! ( ( 0F$++J7J-44Y?I ) 0 0Y1@1G IIc ## UHnUv M g![Ra%n[R"[ XQX#55eSnAff=f7f)aWraps a generator to catch any exceptions. Args: generator: The error exceptions.HttpError thrown by the API client. job_id: The job ID that was used in the command. project_id: The project ID that was used in the command. region_id: The region ID that was used in the command. Yields: The generated object. Raises: dataflow_exceptions.ServiceException: An exception for errors raised by the service. N)r HttpErrordataflow_exceptionsServiceExceptionr ) generatorrrrxes rYieldExceptionWrapperr)YsK <  g   <  . .J: <<r?r rArBrCrDrErF)rrrHs r JobsUriFromIdrKsX    !((--55??! ! "# r!cURnU(d1[nSR[5n[R"U5 U$)zGet region to be used in Dataflow services. Args: args: Argument passed in when running gcloud dataflow command Returns: Region specified by user from --region flag in args, then fall back to 'us-central1'. z`--region` not set; defaulting to '{0}'. In an upcoming release, users must specify a region explicitly. See https://cloud.google.com/dataflow/docs/concepts/regional-endpoints for additional details.)regionDATAFLOW_API_DEFAULT_REGIONrr warning)argsrMmsgs r GetRegionrRs? ;;&  (F % F. /  KK -r!)rrr)Nditems maxResultsNrrr)__doc__ __future__rrrrreapitools.base.pyrrgooglecloudsdk.api_lib.dataflowrr$googlecloudsdk.corer r r compileDATAFLOW_METRICS_RErNWINDMILL_WATERMARK_RErErDEFAULT_REGION_MESSAGErr r)r5rIrKrRr!rras/&' ''0M#*) jj-">> #BC4/66!"I,<4 '3 0Ef(*r!