PSrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSK J r SS K J r SS K Jr SS KJ r SS KJr SS Kr"S S\R(5r"SS\5rg )z.Database Migration Service migration jobs API.)encoding) list_pager)api_util)conversion_workspaces)filter_rewrite) storage_util)base) exceptions) labels_util)resource_propertyNc\rSrSrSrSrg)Error z.Class for errors raised by container commands.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r?lib/googlecloudsdk/api_lib/database_migration/migration_jobs.pyrr s6rrcX\rSrSrSr/SQr/SQrSrSrSr Sr S r S r S r S rS rSrSrSrSrSrSrSrSrSrSrSrSrSrSrSrSrSr Sr!S r"S!r#S"r$S#r%S$r&S%r'S&r(S'r)S(r*S)r+S*r,S+r-S,r.S5S.jr/S6S/jr0S6S0jr1S6S1jr2S2r3S3r4S4r5g-)7MigrationJobsClient$z-Client for migration jobs service in the API.) display_nametype dump_pathsource destination dump_flags)vm_ipvm_portvmvpccj[R"U5Ul[R"U5UlURR UlU[RR:XaURRUl OSUl [R"U5Ul XlgN)rGetClientInstanceclientGetMessagesModulemessages projects_locations_migrationJobs_servicer ReleaseTrackGA(projects_locations_migrationJobs_objects_service_objectsGetResourceParserresource_parser release_track)selfr4s r__init__MigrationJobsClient.__init__2s,,];DK..}=DMKK@@DM)),,, ++ > > #d#55mDD&rc&URU5 gr')_ValidateDumpPathr5argss r _ValidateArgs!MigrationJobsClient._ValidateArgs?s4 rcURcg[RRURSS9 g![a0n[ R "S[R"U55eSnAff=f)NF)allow_empty_objectz dump-path) rrObjectReference FromArgument Exceptionr InvalidArgumentExceptionsix text_type)r5r;es rr9%MigrationJobsClient._ValidateDumpPathBsg ~~ O""// ..U0 O  / / S]]1=M NNOs(9 A3+A..A3cUc[URS5(a[R"SS5eURS5(a[R"SS5egg)aCValidate flags for conversion workspace. Args: conversion_workspace_ref: str, the reference of the conversion workspace. args: argparse.Namespace, The arguments that this command was invoked with. Raises: BadArgumentException: commit-id or filter field is provided without specifying the conversion workspace N commit_id commit-idoConversion workspace commit-id can only be specified for migration jobs associated with a conversion workspace.filterWFilter can only be specified for migration jobs associated with a conversion workspace.)IsKnownAndSpecifiedr BadArgumentException)r5conversion_workspace_refr;s r _ValidateConversionWorkspaceArgs4MigrationJobsClient._ValidateConversionWorkspaceArgsLso ' ! !+ . .-- J    ! !( + +-- 0   ,(rcURc[URS5(a[R"SS5eURS5(a[R"SS5egg)aQValidate flags for conversion workspace. Args: conversion_workspace: str, the internal migration job conversion workspace message. args: argparse.Namespace, The arguments that this command was invoked with. Raises: BadArgumentException: commit-id or filter field is provided without specifying the conversion workspace NrIrJrKrLrM)namerNr rO)r5conversion_workspacer;s r'_ValidateConversionWorkspaceMessageArgs;MigrationJobsClient._ValidateConversionWorkspaceMessageArgsjsu  ( ! !+ . .-- J    ! !( + +-- 0   ,)rc8URRU5$r')TypeValueValuesEnumlookup_by_name)r5mj_type type_values r_GetTypeMigrationJobsClient._GetTypes  & & 5 5j AArc8URRU5$r')DumpTypeValueValuesEnumrZ)r5 dump_typedump_type_values r _GetDumpType MigrationJobsClient._GetDumpTypes  , , ; ;O LLrcHURRURS9$)N)r%)r+VpcPeeringConnectivitypeer_vpcr:s r_GetVpcPeeringConnectivity.MigrationJobsClient._GetVpcPeeringConnectivitys == / /DMM / BBrcURRURURURUR S9$)N)r$vmIpvmPortr%)r+ReverseSshConnectivityr$r"r#r%r:s r_GetReverseSshConnectivity.MigrationJobsClient._GetReverseSshConnectivitys7 == / / 77DLLdhh 0 rc6URR5$r')r+StaticIpConnectivityr5s r_GetStaticIpConnectivity,MigrationJobsClient._GetStaticIpConnectivitys == - - //rcb[R"U5n[R"U5nURRR n[R "UUURS9RU5nUR(a#URUl URS5 gg)z$Updates labels of the migration job.) additions subtractionsclearlabelsN) r GetUpdateLabelsDictFromArgsGetRemoveLabelsListFromArgsr+ MigrationJob LabelsValueDiff clear_labelsApply needs_updateryappend)r5r; migration_job update_fields add_labels remove_labels value_type update_results r _UpdateLabels!MigrationJobsClient._UpdateLabelss88>J;;DAM++77J$$" eJ  !!*11m8$"rc[R"URS9nURR US9nUR c[ R"SS5eU$)zReturns the conversion workspace. Args: conversion_workspace_name: str, the reference of the conversion workspace. Raises: BadArgumentException: Unable to fetch latest commit for the specified conversion workspace. r4rTconversion-workspacerUnable to fetch latest commit for the specified conversion workspace. Conversion Workspace might not be committed.)rConversionWorkspacesClientr4crudReadlatestCommitIdr rO)r5conversion_workspace_name cw_clientrUs r_GetConversionWorkspace+MigrationJobsClient._GetConversionWorkspacesn&@@((I%>>.. &/**2  + + I  rcURRUR5S9nURbURUlU$UR UR55nUR UlU$)a5Returns the conversion workspace info. Args: conversion_workspace_ref: str, the reference of the conversion workspace. args: argparse.Namespace, The arguments that this command was invoked with. Raises: BadArgumentException: Unable to fetch latest commit for the specified conversion workspace. r)r+ConversionWorkspaceInfo RelativeNamerIcommitIdrr)r5rPr;conversion_workspace_objrUs r_GetConversionWorkspaceInfo/MigrationJobsClient._GetConversionWorkspaceInfos $}}DD % 2 2 4 E  ~~!*...' $# "99 " / / 1+?*M*M' ##rczURc[R"SS5eURbURUlU$[ R "URS9nURRURS9nURc[R"SS5eURUlU$)aReturns the conversion workspace info with the supplied or the latest commit id. Args: conversion_workspace: the internal migration job conversion workspace message. args: argparse.Namespace, The arguments that this command was invoked with. Raises: BadArgumentException: Unable to fetch latest commit for the specified conversion workspace. InvalidArgumentException: Invalid conversion workspace message on the migration job. rzTThe supplied migration job does not have a valid conversion workspace attached to itrrr) rTr rCrIrrrr4rrrrO)r5rUr;rcst_conversion_workspaces r"_ComplementConversionWorkspaceInfo6MigrationJobsClient._ComplementConversionWorkspaceInfos  (  / / *  ~~!&*nn# !!%@@((I )~~22 ! & & 3  ..6  + + I %=$K$K! rcURRnU"URRUR5S9$)zReturns the performance config with dump parallel level. Args: args: argparse.Namespace, the arguments that this command was invoked with. )dumpParallelLevel)r+PerformanceConfig DumpParallelLevelValueValuesEnumrZdump_parallel_level)r5r;performance_config_objs r_GetPerformanceConfig)MigrationJobsClient._GetPerformanceConfigs>"]]<< !0QQ``  $ $  rc/n/nU(aUHnUc [S5eUSU;a[SRUSS95e[R"URR U5nURUS5 URU5 M UH2nXT;aM URURR US95 M4 U$![ an[U5eSnAff=f)aiReturns the sqlserver database backups list. Args: sqlserver_databases: The list of databases to be migrated. sqlserver_encrypted_databases: JSON/YAML file for encryption settings for encrypted databases. Raises: Error: Empty list item in JSON/YAML file. Error: Encrypted Database name not found in database list. Error: Invalid JSON/YAML file. Nz"Empty list item in JSON/YAML file.databasezMigrationJobsClient._GetSqlserverHomogeneousMigrationJobConfigCs  <<>3  9::==33//774jBL>& :9!  , ,5F  ! !"9 : :  & & 7D  ! !"@ A A  - - 7G  ! !"7 8 8  - -(($*L*L  7F :9rcURRURRRRS9$)"Returns the source objects config.objectsSelectionType)r+SourceObjectsConfig#ObjectsSelectionTypeValueValuesEnum ALL_OBJECTSrrs r&_GetSourceObjectsConfigForAllDatabases:MigrationJobsClient._GetSourceObjectsConfigForAllDatabasesgs7 == , ,!]]>>bbnn - rcURRURRRRS9n/nUHrnURR UURRR R S5S9nURURRUS95 Mt X2l U$)rrDATABASE)rrobjectIdentifier) r+rrSPECIFIED_OBJECTSSourceObjectIdentifierrYrZrSourceObjectConfig objectConfigs)r5databases_filtersource_objects_conifgsource_object_configsrsource_object_identifiers r,_GetSourceObjectsConfigForSpecifiedDatabases@MigrationJobsClient._GetSourceObjectsConfigForSpecifiedDatabasesms MM==!]]>>bbtt>$!%!E!E}}33GGVV "F" "" -- * *7 + %+@'  rcURRURRRRS9nUHnUSnUSnURR UUURRR R S5S9nURc/UlURRURRUS95 M U$)rrschematableTABLE)rrrr) r+rrrrrYrZrrr)r5object_filterssource_objects_config object_filter schema_name table_namers r)_GetSourceObjectsConfigForSpecifiedTables=MigrationJobsClient._GetSourceObjectsConfigForSpecifiedTabless MM==!]]>>bbtt>( !(+k )j!%!E!E}}33GGVV "F"  , , 4.0+))00 -- * *7 + (" ! rc|URR5nURS5(aUR5nOcURS5(aUR UR 5nO1URS5(aUR UR5nURRUS9$)zReturns the migration job objects config. Args: args: argparse.Namespace, The arguments that this command was invoked with. all_databasesrr)sourceObjectsConfig) r+rrNrrrrrMigrationJobObjectsConfig)r5r;rs r_GetMigrationJobObjectsConfig1MigrationJobsClient._GetMigrationJobObjectsConfigs!MM==? 00"IIK ! !"4 5 5"OO     ! !/ 2 2"LL    == 2 21 3 rcDURS5=(d URS5=(dq URS5=(dY URS5=(dA URS5=(d) URS5=(d URS5$)zChecks if at least one heterogeneous config flag is specified. Args: args: argparse.Namespace, The arguments that this command was invoked with. Returns: True if at least one of the heterogeneous config's flags is known and specified. $max_concurrent_full_dump_connectionsmax_concurrent_cdc_connectionsskip_full_dumporacle_cdc_start_positionsqlserver_cdc_start_position&max_concurrent_destination_connectionstransaction_timeout)rNr:s r'_IsHeterogeneousConfigKnownAndSpecified;MigrationJobsClient._IsHeterogeneousConfigKnownAndSpecifieds   !GH ;  # #$D E ;  # #$4 5 ;  # #$? @ ;  # #$B C  ;  # #$L M  ;  # #$9 :rcURR5nURS5(aURUlURS5(a[ UR 5S-UlU$)zReturns the postgres destination config. Args: args: argparse.Namespace, the arguments that this command was invoked with. Returns: PostgresDestinationConfig: The postgres destination config. rrs)r+PostgresDestinationConfigrNrmaxConcurrentConnectionsstrrtransactionTimeout)r5r;postgres_destination_configs r_GetPostgresDestinationConfig1MigrationJobsClient._GetPostgresDestinationConfigsq#'--"I"I"K  HII  5 5":  566 d&& '# -"4 '&rcURR5nURS5(aURUlU$)zReturns the postgres source config. Args: args: argparse.Namespace, the arguments that this command was invoked with. Returns: The postgres source config. r)r+PostgresSourceConfigrNr skipFullDump)r5r;postgres_source_configs r_GetPostgresSourceConfig,MigrationJobsClient._GetPostgresSourceConfigs>"]]??A  011,0,?,?) !!rcURR5nURS5(aURUlURS5(aUR UlURS5(a[URUlURS5(a[UR5nX2l U$[R"SS5eU$)aReturns the oracle source config. Args: args: argparse.Namespace, the arguments that this command was invoked with. Returns: The oracle source config. Raises: RequiredArgumentException: The Oracle CDC start position should be specified when skipping full dump. rrrrzoracle-cdc-start-positionzJThe Oracle CDC start position should be specified when skipping full dump.)r+OracleSourceConfigrNr maxConcurrentFullDumpConnectionsrmaxConcurrentCdcConnectionsrrintrcdcStartPositionr RequiredArgumentException)r5r;oracle_source_configtemps r_GetOracleSourceConfig*MigrationJobsClient._GetOracleSourceConfigs ==;;=  FGG  3 3;  @AA  - -6  011*.*=*=' ! !"= > >411204- 22 ''   rcURR5nURS5(aURUlURS5(aUR UlURS5(aQURUlURS5(aURUl U$[R"SS5eU$)aReturns the sqlserver source config. Args: args: argparse.Namespace, the arguments that this command was invoked with. Returns: The sqlserver source config. Raises: RequiredArgumentException: The SQL Server CDC start position should be specified when skipping full dump. rrrrzsqlserver-cdc-start-positionzNThe SQL Server CDC start position should be specified when skipping full dump.) r+SqlServerSourceConfigrNrrrrrrrsqlserverCdcStartPositionr r)r5r;sqlserver_source_configs r_GetSqlServerSourceConfig-MigrationJobsClient._GetSqlServerSourceConfigs#mmAAC  FGG  3 3>  @AA  - -9  011-1-@-@* ! !"@ A A  - - 9 #"22 *'   #"rcURR5nURS5(aURUlURS5(a[ UR 5S-UlU$)zReturns the sqlserver destination config. Args: args: argparse.Namespace, the arguments that this command was invoked with. Returns: SqlServerDestinationConfig: The sqlserver destination config. rrr)r+SqlServerDestinationConfigrNrrrrr)r5r;sqlserver_destination_configs r_GetSqlServerDestinationConfig2MigrationJobsClient._GetSqlServerDestinationConfig8sq$(==#K#K#M   HII  5 5#;  566 d&& '# -#5 ('rchURU5(GaURU5nURRURR R R:XaURU5nO,[SRURRS95eURRURR R R:Xa-URRURU5US9nSU4$URRURR R R:Xa-URR!UR#U5US9nSU4$[SRURRS95eg) a\Returns the heterogeneous migration job config. Args: conversion_workspace_name: str, the name of the conversion workspace. args: argparse.Namespace, The arguments that this command was invoked with. Returns: A tuple containing the heterogeneous config key and the config object. Raises: Error: Invalid source or destination engine. zXCannot create heterogeneous migration job configuration for destination engine: {engine}engine)oracleSourceConfigpostgresDestinationConfigoracleToPostgresConfig)sqlserverSourceConfigr&sqlserverToPostgresConfigzTCannot create heterogeneous migration job configuration for source engine: {engine}NN)rrr r$r+DatabaseEngineInfoEngineValueValuesEnum POSTGRESQLrrrrORACLEOracleToPostgresConfigr SQLSERVERSqlServerToPostgresConfigr)r5rr;rUroracle_to_postgres_configsqlserver_to_postgres_configs r#_GetHeterogeneousMigrationJobConfig7MigrationJobsClient._GetHeterogeneousMigrationJobConfigMs  33D99!99 #  * * 1 1 ]] - - C C N N O'+&H&H ' # ++16+77>>,2,    % % , , ]] - - C C J J K%)MM$H$H#::4@&A%I%!()BBB  % % , , ]] - - C C M M N(,}}'N'N"&"@"@"F&A(O($+,HHH ''-v+2299(.(  rcURU5(GavURU5nURc[SR US95eUR URR 5nURRURRRR:XaURU5nO,[SR URRS95eURRURRRR:Xa-URR!UUR#U5S9nSU4$[SR URRS95eg) awReturns the heterogeneous migration job config for failback migration job. Args: original_migration_name: str, the name of the original migration job. args: argparse.Namespace, The arguments that this command was invoked with. Returns: A tuple containing the heterogeneous config key and the config object. Raises: Error: Invalid source or destination engine. zCannot create failback heterogeneous migration job configuration for original migration job: {original_migration_name} does not have conversion workspace.)original_migration_namezaCannot create failback heterogeneous migration job configuration for destination engine: {engine}r#)postgresSourceConfigsqlserverDestinationConfigpostgresToSqlserverConfigz]Cannot create failback heterogeneous migration job configuration for source engine: {engine}r*)r_GetExistingMigrationJobconversionWorkspacerrrrTr r$r+r+r,r-r rr0PostgresToSqlServerConfigr )r5r7r;original_migration_jobrUr postgres_to_sqlserver_configs r+_GetHeterogeneousFailbackMigrationJobConfig?MigrationJobsClient._GetHeterogeneousFailbackMigrationJobConfigs  33D99#<< !  3 3 ; **0&(?+1+  "99 4 4 9 9  * * 1 1 ]] - - C C N N O"&!>!>t!D 006+77>>171    % % , , ]] - - C C M M N(,}}'N'N!7'+'J'J((O( $ +,HHH ,,2F+2299-3-  rc ^URRn[R"X`RRR5nUR XvR 5n UR5n UR5n 0n URS5(aURU5U S'OTURS5(aURU5U S'O)URS5(aUR5U S'URS5(aURUR5U S'Ub>URX65U S 'URUR5U5upU bXU 'OaUb=UR5U S 'UR!UR5U5upU bXU 'O!UR#U5(a [%S 5eU"SUUR&UR(R*U UR,U U S .U D6nUbUR5UlUR1S 5(a=[2R4"5R7UR85uUlnUUlUR1S5(aUR;U5UlUR1S5(a5UR?URRUR@5Ul!UR1S5(dUR1S5(aUREU5Ul#[IUSS5(a URRKSS9nUUl&UR1S5(dUR1S5(aUROU5Ul(U$)aRReturns a migration job. Args: source_ref: a Resource reference to a datamigration.projects.locations.connectionProfiles resource. destination_ref: a Resource reference to a datamigration.projects.locations.connectionProfiles resource. conversion_workspace_ref: a Resource reference to a datamigration.projects.locations.conversionWorkspaces resource. original_migration_name_ref: a Resource reference to a datamigration.projects.locations.migrationJobs resource. cmek_key_ref: a Resource reference to a cloudkms.projects.locations.keyRings.cryptoKeys resource. args: argparse.Namespace, The arguments that this command was invoked with. Returns: MigrationJob: the migration job. Raises: Error: If neither conversion workspace nor original migration job name is specified for heterogeneous migration job. rgvpcPeeringConnectivityr"reverseSshConnectivity static_ipstaticIpConnectivityr! dumpFlagsr<originalMigrationNamez`Conversion workspace or original migration job name is required for heterogeneous migration job.)ry displayNamestaterdumpPathrr rLrrarruse_postgres_nativeFT)isNativeLogicalrrr))r+r|r ParseCreateArgsr}r]rr IsSpecifiedrhrnrs _GetDumpFlagsr!rr4r@rrrStateValueValuesEnumCREATINGr cmekKeyNamerNrRewriterRewriterLrperformanceConfigrcradumpTyper&sqlserverHomogeneousMigrationJobConfiggetattrPostgresHomogeneousConfigpostgresHomogeneousConfigr objectsConfig)r5 source_refdestination_refrPoriginal_migration_name_ref cmek_key_refr;migration_job_typeryr\rr paramsheterogeneous_config_keyheterogeneous_config_objmigration_job_obj server_filterpostgres_homogeneous_configs r_GetMigrationJob$MigrationJobsClient._GetMigrationJobs@33  ( ( mm((44F199=J  $ $ &F!..0K F  ##)-)H)H)Nf %&  ' " ")-)H)H)Nf %&  + & &'+'D'D'Ff #$  %% ..t?f[+&*&F&F "'f "#  2 2&335t 9 " -+C'( $ 0 % 2 2 4 $%  : :)668$ 9 " -+C'( 5 5d ; ; 8  + %% 55>>    &2&?&?&A# ))#1#:#:#<#D#D ++$ dk="/  566,0,F,Ft,L)  ,,#'#4#4 -- $ $dnn$   ! !"; < <  9 9$ ?>t*E22$(MM$K$K%L%!5P1  233t7O7O88)-(J(J4(P% rc8SRX4R55nSRXS5nSRXT5nURS5(a URSRU55 URS5(a URSRU55 URS5(a URS RU55 URS 5(a!URS RU55 g g ) z>0H- ==       ((.'?)/)  rcURS5(a$UR5UlSUlSUlgURS5(a%UR U5UlSUlSUlgUR H?nURU5(dMURU5UlSUlSUl g g)z1Update connectivity method for the migration job.rENrg)rOrsrFrCrDrh _REVERSE_MAPrn)r5rr;fields r_UpdateConnectivity'MigrationJobsClient._UpdateConnectivitys  $$+/+H+H+Jm(-1m*-1m*   ##-1-L-L .m*.2m*+/m( ""  % /3/N/N 0 ,04 ,-1 *#rcURc [S5eURnURS5(aURUlURS5(aUR UlURS5(aURUlURS5(dURS5(aURcURR5Ul URS5(aURURl URS5(aURURlURS5(a,UR!UR"UR$5UlgURS 5(a[(R*"S S 5eg) zLUpdate the sqlserver homogeneous migration job config for the migration job.NzrCannot update sqlserver homogeneous migration job config when it was not set during creation of the migration job.rrrrrrrz--sqlserver-encrypted-databasesz^--sqlserver-encrypted-databases can only be specified when --sqlserver-databases is specified.)rXrrNrrrrrrrr+rrrrrrrrrr rC)r5r;rrs r-_UpdateSqlserverHomogeneousMigrationJobConfigAMigrationJobsClient._UpdateSqlserverHomogeneousMigrationJobConfigs;;C  ;  <<3  ?@@  , ,5F  788  $ $5B  >??  + +5E ! ! !"? @ @ 7 A A I MM , , . 7@  ! !"; < <  ( ( 7@@I  ! !"? @ @  , , ; D D Q  566  + +&&(J(J 5D  ! !"A B B  / / + 1  CrcURS5(dURS5(aURU5Ulgg)z>Update the migration job objects config for the migration job.rrN)rNrr\)r5r;rs r _UpdateMigrationJobObjectsConfig4MigrationJobsClient._UpdateMigrationJobObjectsConfigsE  233t7O7O88%)$F$Ft$Lm!8rc [UR5Vs/sH1nURU5(dM[R"U5PM3 nnUR [UR 5Vs/sH@nURU5(dMSR[R"U55PMB sn5 URS5(aURS5 URS5(aURS5 URS5(aURS5 URS5(aURS5 URS 5(dURS5(aURS 5 URS 5(aURS 5 URS 5(aURS5 URS5(aURS5 URS5(aURS5 URS5(aURS5 URS5(dURS5(aURS5 URS5(dURS5(aURS5 U$s snfs snf)z)Returns update mask for specified fields.zreverseSshConnectivity.{0}rgzvpcPeeringConnectivity.vpcrz#performanceConfig.dumpParallelLevelrarWrLrIzconversionWorkspace.commitIdrz8sqlserverHomogeneousMigrationJobConfig.backupFilePatternrz4sqlserverHomogeneousMigrationJobConfig.useDiffBackuprz7sqlserverHomogeneousMigrationJobConfig.promoteWhenReadyrz9sqlserverHomogeneousMigrationJobConfig.dagConfig.sourceAgrz=sqlserverHomogeneousMigrationJobConfig.dagConfig.linkedServerrrz6sqlserverHomogeneousMigrationJobConfig.databaseBackupsrrz!objectsConfig.sourceObjectsConfig) sorted _FIELDS_MAPrOr ConvertToCamelCaseextendr~rrrN)r5r;rrs r_GetUpdateMask"MigrationJobsClient._GetUpdateMasksD,,--E   E " 4,,U3- D--. /E   E "  $++  0 0 7 /   ##78  566@A  ,,:& ))8$  ,,0H0H119:  ?@@ D  788 @  >?? C  9:: E  =>> I  ! !"A B B B  233t7O7O88>? o sKK4K)Kc/nUR5H.up4URURRUUS95 M0 URR US9$)z-Returns the dump flags for the migration job.)rTvalue)rG)itemsrr+DumpFlag DumpFlags)r5r!dump_flags_listrTrs rrP!MigrationJobsClient._GetDumpFlags2saO!'')  --  ! * == " "_ " ==rcXURU5nURS5(aURUlURS5(a5UR UR R UR5UlURS5(a5URUR R UR5Ul URS5(aURUl URS5(a URUR5UlURS5(aUR#5UlURS5(aUR#5UlURS5(aUR)U5UlURS 5(a<[,R."5R1UR25uUlnXalUR5X5 UR7XAU5 URS 5(dURS 5(dnURS 5(dXURS 5(dBURS5(d,URS5(dURS5(aUR9XA5 UR;XA5 UR=U5(a4UR>cURAXAU5 X4$URCXAU5 X4$)z9Returns updated migration job and list of updated fields.rrrarr!rr rrLrrrrrrr)"rrOrrIr]r+r|rrNrcrarWrrKrPr!rGrrr rrVrrTrUrLrrrrrrHrxr{)r5rr]r^r;rrfs r_GetUpdatedMigrationJob+MigrationJobsClient._GetUpdatedMigrationJob>s''-M ''"&"3"3m ==)C)CTYYOm  ,,#00 -- $ $dnn m  $$#~~m  %% $ 2 24?? Cm !!'446m  &&"1">">"@m  566(,(B(B4(Hm% ))#1#:#:#<#D#D ++$ dk=+]1tM:   !@AA  # #$; < <  # #$B C C  # #$9 : :  # #$C D D  # #$= > >  # #$A B B 88M))$> 33D99  , , 4 33    '' ;;    ''rcjURRUS9nURRU5$)Nr)r+5DatamigrationProjectsLocationsMigrationJobsGetRequestr-Get)r5rTget_reqs rr;,MigrationJobsClient._GetExistingMigrationJobus9 KK L  ==  W %%rNc URU5 URXX5 URUUUUUU5n [R"5n UR R n U "U UUU S9n URRU 5$)aCreates a migration job. Args: parent_ref: a Resource reference to a parent datamigration.projects.locations resource for this migration job. migration_job_id: str, the name of the resource to create. source_ref: a Resource reference to a datamigration.projects.locations.connectionProfiles resource. destination_ref: a Resource reference to a datamigration.projects.locations.connectionProfiles resource. conversion_workspace_ref: a Resource reference to a datamigration.projects.locations.conversionWorkspaces resource. original_migration_name_ref: a Resource reference to a datamigration.projects.locations.migrationJobs resource. cmek_key_ref: a Resource reference to a cloudkms.projects.locations.keyRings.cryptoKeys resource. args: argparse.Namespace, The arguments that this command was invoked with. Returns: Operation: the operation for creating the migration job. ) migrationJobmigrationJobIdparent requestId) r<rQrhrGenerateRequestIdr+8DatamigrationProjectsLocationsMigrationJobsCreateRequestr-Create) r5 parent_refmigration_job_idr]r^rPr_r`r;r request_idcreate_req_type create_reqs rrMigrationJobsClient.Create}sB t))*BI)) # M++-J NN!"' J ==   ++rcURU5 URU5n[US5(aJURb=UR URU5 UR URU5UlUR XRX45upg[R"5nURRn U "UUUSRU5S9n URRU 5$)aUpdates a migration job. Args: name: str, the reference of the migration job to update. source_ref: a Resource reference to a datamigration.projects.locations.connectionProfiles resource. destination_ref: a Resource reference to a datamigration.projects.locations.connectionProfiles resource. args: argparse.Namespace, The arguments that this command was invoked with. Returns: Operation: the operation for updating the migration job.678888888 r<,)rrTr updateMask)r<r;hasattrr<rVrrrrr+7DatamigrationProjectsLocationsMigrationJobsPatchRequestjoinr-Patch) r5rTr]r^r; current_mjrrrupdate_req_type update_reqs rUpdateMigrationJobsClient.Updates t..t4J  122  * * 6 22  ( ($(,'N'N  ( ($(j$$(#?#?$ M++-J MM!" 88M* J ==  z **rcURR5nURS5(aURU5UlURR UUS9nUR RU5$)zPromotes a migration job. Args: name: str, the name of the resource to promote. args: argparse.Namespace, The arguments that this command was invoked with. Returns: Operation: the operation for promoting the migration job. r)rTpromoteMigrationJobRequest)r+PromoteMigrationJobRequestrNr objectsFilter9DatamigrationProjectsLocationsMigrationJobsPromoteRequestr-Promote)r5rTr;promote_mj_req promote_reqs rrMigrationJobsClient.Promotesw]]==?N  233%)%G%G%Mn" OO'5 P  ==  --rcURR5nURS5(dURS5(aURU5UlURS5(aSUlURS5(aSUlURRUUS9nURRU5$)zRestarts a migration job. Args: name: str, the name of the resource to restart. args: argparse.Namespace, The arguments that this command was invoked with. Returns: Operation: the operation for promoting the migration job. rrskip_validationTrestart_failed_objects)rTrestartMigrationJobRequest) r+RestartMigrationJobRequestrNrrskipValidationrestartFailedObjects9DatamigrationProjectsLocationsMigrationJobsRestartRequestr-Restart)r5rTr;restart_mj_req restart_reqs rrMigrationJobsClient.Restarts]]==?N  233t7O7O88&*%G%G%Mn"  122&*n#  899,0n) OO'5 P  ==  --rcjURRUS9nURRU5$)zFetches source objects of a migration job. Args: name: str, the name of the resource to fetch source objects for. Returns: Operation: the operation for fetching source objects of the migration job. r)r+DDatamigrationProjectsLocationsMigrationJobsFetchSourceObjectsRequestr-FetchSourceObjects)r5rTfetch_source_objects_reqs rr&MigrationJobsClient.FetchSourceObjects&s: $}}qq  r  == + +,D EErc URRnU"UR5S9n[R"UR USSSSS9$)zGet the list of objects in a migration job. Args: migration_job_ref: The migration job for which to list objects. Returns: An iterator over all the matching migration job objects. )rNmigrationJobObjects)servicerequestlimit batch_sizerbatch_size_attribute)r+=DatamigrationProjectsLocationsMigrationJobsObjectsListRequestrr YieldFromListr1)r5migration_job_ref list_req_typelist_reqs r ListObjectsMigrationJobsClient.ListObjects8sW SS$5$B$B$DEH  # #%%#!  r)r-r1r)r+r4r3)NNNNr')6rrrrrrr~r6r<r9rQrVr]rcrhrnrsrrrrrrrrrrrrrr rrr r4r@rhrqrxr{rrrrrPrr;rrrrrrrrrrrr$s'5+3, '!O < >BMC 0 % 4$4* X +Z":H !*!00*'* "$ L%#N(*;z=~||5(n& $"& 8,t/+h .>  .DF$rr)rapitools.base.pyrr)googlecloudsdk.api_lib.database_migrationrrrgooglecloudsdk.api_lib.storagergooglecloudsdk.callioper r $googlecloudsdk.command_lib.util.argsr googlecloudsdk.corecore_exceptionsgooglecloudsdk.core.resourcer rDrobjectrrrrrsP5&'>KD7(.<=: 7O ! !7i&ir