jdZddlmZddlmZddlmZddlmZGddejZGdd eZGd d eZ Gd d e Z GddeZ Gdde Z GddeZ GddeZGddeZGddeZGddeZGddeZGddeZy )!z>Wrapper for user-visible error exceptions to raise in the CLI.)absolute_import)division)unicode_literals) exceptionsceZdZdZy)Errorz)Exceptions for Deployment Manager errors.N__name__ __module__ __qualname____doc__1lib/googlecloudsdk/api_lib/dataproc/exceptions.pyrrs1rrceZdZdZy) ArgumentErrorzCommand argument error.Nr rrrrrsrrceZdZdZy)JobErrorzJob encountered an error.Nr rrrrr s!rrceZdZdZy)JobTimeoutErrorzJob timed out.Nr rrrrr$srrceZdZdZy)OperationErrorzOperation encountered an error.Nr rrrrr(s'rrceZdZdZy)OperationTimeoutErrorzOperation timed out.Nr rrrrr,srrceZdZdZy) ParseErrorzFile parsing error.Nr rrrrr0srrceZdZdZy)FileUploadErrorzFile upload error.Nr rrrrr4srrceZdZdZy)ObjectReadErrorz Cloud Storage Object read error.Nr rrrr r 8s(rr ceZdZdZy)ValidationErrorz+Error while validating YAML against schema.Nr rrrr"r"<s3rr"ceZdZdZy)PersonalAuthErrorz1Error while establishing a personal auth session.Nr rrrr$r$@s9rr$c"eZdZdZfdZxZS)GkeClusterGetErrorz"Error while getting a GKE Cluster.cJtt| dj|y)Nz(Error while getting the GKE Cluster: {0})superr&__init__format)selfcause __class__s rr)zGkeClusterGetError.__init__Gs" d,299%@Br)r r r r r) __classcell__r-s@rr&r&Ds*BBrr&c(eZdZdZfdZdZxZS)&GkeClusterMissingWorkloadIdentityErrorz-GKE Cluster is not Workload Identity enabled.c8tt| ||_y)N)r(r1r)gke_cluster_ref)r+r3r-s rr)z/GkeClusterMissingWorkloadIdentityError.__init__Os 0$@B*DrcTdj|jjS)NzGKE Cluster "{0}" does not have Workload Identity enabled. Dataproc on GKE requires the GKE Cluster to have Workload Identity enabled. See https://cloud.google.com/kubernetes-engine/docs/how-to/workload-identity)r*r3 RelativeName)r+s r__str__z.GkeClusterMissingWorkloadIdentityError.__str__Ss( S fT ! ! . . 01 2r)r r r r r)r6r.r/s@rr1r1Ls5+2rr1N)r __future__rrrgooglecloudsdk.corerrrrrrrrrr r" Exceptionr$r&r1rrrr:sE&'*2J  2 E "u"h(U(Ne)e)4e4: :BB 2U 2r