h1 SrSSKrSSKrSSKJr SSKJr SSKJr SSKJ r SSK J r SSK J r SS K Jr SS KJr SS KJr SS KJr SSKJ r SS KJr SSKJr SSKJr 0r\R8R:R<\R>RASSSS5\R8RBR<S\R8RDR<S0r#\ RHRJS\ RHRLS\ RHRNS0r(Sr)Sr*"SS\RV5r,"SS\RV5r-Sr.S)S jr/S!r0S)S"jr1S#r2S*S$jr3S%r4S&r5"S'S(\Rl5r7g)+z9Flink command library functions for the Flink cli binary.N)parse)transfer) storage_api) storage_util)base) exceptions)requests)java)binary_operations)config) resources) transports) platformsz %APPDATA%googleflinkz config.yamlz.~/Library/Preferences/google/flink/config.yamlz"~/.config/google/flink/config.yamlv1alphav1betav1zCould not locate managed flink client executable [{binary}] on the system PATH. Please ensure gcloud managed-flink-client component is properly installed. See https://cloud.google.com/sdk/docs/components for more details.i0c\rSrSrSrSrg)FileUploadErrorBz*Exception raised when a file upload fails.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r=lib/googlecloudsdk/command_lib/managed_flink/flink_backend.pyrrBs2r rc\rSrSrSrSrg)FileDownloadErrorFz,Exception raised when a file download fails.rNrrr r!r#r#Fs4r r#c[RR[R"5R SSSS5$)zGet flink python jar location.platformmanaged-flink-clientlibzflink-python-1.19.0.jarospathjoinr Pathssdk_rootrr r!DummyJarr/Js2  lln   r c U=(d [R"5n[5nUHvn[RR U5n[RR X5n[RRU5nURXX5 XtU'Mx U$![Ra/n [SRSR U5X55eSn A ff=f)zDUploads a list of files passed as strings to a Cloud Storage bucket.z(Failed to upload file ["{}"] to "{}": {},N)r StorageClientdictr*r+basenamer,rObjectReferenceFromUrl CopyFileToGCSrBadFileExceptionrformat) files destinationstorage_clientclient destinationsfile_to_upload file_namedest_url dest_objectes r!UploadrDUs  8[668&,n  0Iww||K3H..66x@K >7%->"    & &  4 ; ;hhuo{  s B''C*;*C%%C*c [R"U5nUR R S5nUVs/sH o3(dM UPM nnUR(aUR/U-n[U5S:dUSRS5(d&[R"SSR U55eSRUSS5nURSS 5RS S 5RS S 5nU[RRSUSUSUSUS94$! [R"SSR U55e=fs snf)zCreates a registry from an artifact URI. Args: artifact_uri: ar://///. Returns: Jar file name, The registry resource. z JAR|PY|SQLz|Artifact URI [{0}] is invalid. Must be in the format of ar://///./z.jarNz%2F+z%2B^z%5Ez6artifactregistry.projects.locations.repositories.filesr) projectsId locationsIdrepositoriesIdfilesId)rurlparserInvalidArgumentExceptionr9r+splitnetloclenendswithr,replacer REGISTRYCreate) artifact_uri parsed_url split_pathr+cleaned_split_pathjar_filecleaned_jar_files r!CreateRegistryFromArtifactUriraisg -J$$S)*)3<t<$++,/AA q (:2(>(G(G(O(O  - - P     XX(, -(sE"**36>>sEJ 9%%,,>#A&$Q''* - /  - - P    =sD. EE.(EcU=(d [R"5n[R"5nURUS9n[R R US[S9n[R"SS9Ul URR XVS9 URR!5 g![an[SRU55eSnAff=f!URR!5 f=f)z3Downloads a JAR file from Google Artifact Registry.)nameT) chunksizeN)response_encoding)downloadz1Failed to download JAR from Artifact Registry: {})r GetClient GetMessagesAArtifactregistryProjectsLocationsRepositoriesFilesDownloadRequestrDownloadFromFileDEFAULT_CHUNK_SIZErGetApitoolsTransport bytes_http%projects_locations_repositories_files Exceptionr#r9streamclose) dest_pathartifact_jar_pathartifact_clientr=messagesrequestdrCs r!DownloadJarFromArtifactRegistryrys  2h002&  ! ! #(  V V  W '  D E$  - '' 4r c[R"[R5nUR [ 5 U(aUR U5 U(aUHnUR US5 M U$)zDHelper function to add our environment variables to the environment.N)copydeepcopyr*environupdateDEFAULT_ENV_ARGSpop) extra_vars exclude_varsenvvars r!GetEnvArgsForCommandrsP bjj!#** JJz ggc4 *r c[RR[R"5R SSSS5$)z%Get the platform executable location.r&r'binr)rr r!PlatformExecutablers2  lln   r cUS:XawU(a[R"SS5eU(d[R"SS5eU(d[R"SS5eX:a[R"SS5eg U(d[R"SS 5eU(a[R"SS 5eU(a[R"SS 5eg ) z#Validate autotuning configurations.elastic parallelismz8Parallelism must NOT be set for elastic autotuning mode.zmin-parallelismz8Min parallelism must be set for elastic autotuning mode.zmax-parallelismz8Max parallelism must be set for elastic autotuning mode.z>Min parallelism must be less than or equal to max parallelism.zMParallelism must be set to a value of 1 or greater for fixed autotuning mode.z:Min parallelism must NOT be set for fixed autotuning mode.z:Max parallelism must NOT be set for fixed autotuning mode.N)rrS)autotuning_modemin_parallelismmax_parallelismrs r!ValidateAutotuningrs !  / /  D    / /  D    / /  D (  / /  J )   / /      / /  F   / /  F r c |^\rSrSrSrSrU4SjrS\RRSSSSSSSSSSS4 Sjr Sr U=r $)FlinkClientWrapperz$Wrapper for the Flink client binary.Nc ^>S[RSS90n[[U]"SSUS.UD6 [ R "SS5Ul[RRUR5(d6[5n[RRU5(aX0l ggg)N MISSING_EXECr')binary)r custom_errorszManaged Flink Client r) MISSING_BINARYr9superr__init__r RequireJavaInstalled _java_pathr*r+exists _executabler)selfkwargsrcomponent_executable __class__s r!rFlinkClientWrapper.__init__s--5K-LM d,%]FL//0FKDO 77>>$** + +/1 , - -/ . ,r localc fUS:wa%[R"SRU55e[5nU (a UR SRU 55 U (a UR SRU 55 U(a UR SRU55 U (a UR SRU 55 U (a UR SRU 55 U(d/n[5nUH=nUR S5(aUR U5 M,UR U5 M? US :Xab/nU (a+U H%nUR S 5 UR U5 M' US S RU5S RU5SU/-U-U-$US:Xa/nU (a/UR SRSR U 555 URS5SnSRU5/nU(a+UH%nUR S5 UR U5 M' USU/U-S RU5S RU5SRU5SRU5SRU5/-U-U-SU/-U-$/nU(aSU/n/nU (a/UR SRSR U 555 USU/U-U-S RU5S RU5/-U-U/-U-$)z+Parses the arguments for the given command.runz%Invalid operation [{}] for Flink CLI.z-Dgcloud.network={0}z-Dgcloud.subnetwork={0}z-Dgcloud.region={0}z-Dgcloud.deployment={0}z-Dgcloud.job.display-name={0}z-Dsqlz--jarz-Dexecution.target=gcloudz-Dgcloud.output-path={0}z!-Dgcloud.api.staging-location={0}z--filepythonz-Dgcloud.pipeline.jars={0}r1rFrHz-Dpython.archives={0}z--targetz*-Dpython.client.executable={0}/bin/python3z#-Dpython.executable={0}/bin/python3z5-Dpython.pythonpath={0}/lib/python3.10/site-packages/z--pythonz--class)r InvalidOperationForBinaryr9listappend startswithr,rT)rcommandjob_typejarr~temp_dirtarget release_tracklocation deploymentnetwork subnetworkrc extra_jarsmanaged_kafka_clusters main_class extra_argsextra_archives python_venvrargsjob_argsargudfsj env_folderarchivesarchive class_args r!_ParseArgsForCommand'FlinkClientWrapper._ParseArgsForCommandsO0%  7 7 1 8 8 A  6D kk(//89 kk+22:>? kk'..x89 kk+22:>?  kk188>? jvH    C  5 d A ++g  ++a. )(//91889IJ         X  d  0778LMN$$S)"-j)00=>h %G //#  //' "&    )//91889IJ:AA*M3:::FELL      ! $ # * + 2i  + d  0778LMN J '    )//91889IJ         r )rr) rrrrrrrr ReleaseTrackALPHArr __classcell__)rs@r!rrsQ,*00%%++ !'FFr r)N)NN)8rrr*urllibrapitools.base.pyrgooglecloudsdk.api_lib.storagerrgooglecloudsdk.callioperr$googlecloudsdk.command_lib.artifactsr googlecloudsdk.command_lib.utilr &googlecloudsdk.command_lib.util.anthosr googlecloudsdk.corer core_exceptionsr googlecloudsdk.core.credentialsrgooglecloudsdk.core.utilrrOperatingSystemWINDOWSidr+r,MACOSXLINUXDEFAULT_CONFIG_LOCATIONrrBETAGA_RELEASE_TRACK_TO_VERSIONrrlErrorrr#r/rDraryrrrrBinaryBackedOperationrrr r!rsa@ %67(.90D&=)6.%%(("'',,Xw +$$''8 ##&&(L YH$%3o++35--5()Z3745  )X\*@@\r