SrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSKJ r SS KJ r SS K J r SS KJr SS KJr SS KJr SS KJr SSKJr SSKr"SS\R05r"SS\5rg)z.Database Migration Service migration jobs API.)absolute_import)division)unicode_literals)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)selfr7s r__init__MigrationJobsClient.__init__5s,,];DK..}=DMKK@@DM)),,, ++ > > #d#55mDD&rc&URU5 gr*)_ValidateDumpPathr8argss r _ValidateArgs!MigrationJobsClient._ValidateArgsBs4 rcURcg[RRURSS9 g![a0n[ R "S[R"U55eSnAff=f)NF)allow_empty_objectz dump-path) r!r ObjectReference FromArgument Exceptionr InvalidArgumentExceptionsix text_type)r8r>es rr<%MigrationJobsClient._ValidateDumpPathEsg ~~ 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)r8conversion_workspace_refr>s r _ValidateConversionWorkspaceArgs4MigrationJobsClient._ValidateConversionWorkspaceArgsOso ' ! !+ . .-- 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 NrLrMrNrOrP)namerQr rR)r8conversion_workspacer>s r'_ValidateConversionWorkspaceMessageArgs;MigrationJobsClient._ValidateConversionWorkspaceMessageArgsmsu  ( ! !+ . .-- J    ! !( + +-- 0   ,)rc8URRU5$r*)TypeValueValuesEnumlookup_by_name)r8mj_type type_values r_GetTypeMigrationJobsClient._GetTypes  & & 5 5j AArc8URRU5$r*)DumpTypeValueValuesEnumr])r8 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.StaticIpConnectivityr8s 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) rGetUpdateLabelsDictFromArgsGetRemoveLabelsListFromArgsr. MigrationJob LabelsValueDiff clear_labelsApply needs_updater|append)r8r> 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. r7rWconversion-workspacerUnable to fetch latest commit for the specified conversion workspace. Conversion Workspace might not be committed.)r ConversionWorkspacesClientr7crudReadlatestCommitIdr rR)r8conversion_workspace_name cw_clientrXs 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 RelativeNamerLcommitIdrr)r8rSr>conversion_workspace_objrXs 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) rWr rFrLrr rr7rrrrR)r8rXr>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 DumpParallelLevelValueValuesEnumr]dump_parallel_level)r8r>performance_config_objs r_GetPerformanceConfig)MigrationJobsClient._GetPerformanceConfig s>"]]<< !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.databasez.sqlserver_homogeneous_migration_job_config_obj dag_configs r*_GetSqlserverHomogeneousMigrationJobConfig>MigrationJobsClient._GetSqlserverHomogeneousMigrationJobConfigFs  <<>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_OBJECTSrus r&_GetSourceObjectsConfigForAllDatabases:MigrationJobsClient._GetSourceObjectsConfigForAllDatabasesjs7 == , ,!]]>>bbnn - rcURRURRRRS9n/nUHrnURR UURRR R S5S9nURURRUS95 Mt X2l U$)rrDATABASE)rr objectIdentifier) r.rrSPECIFIED_OBJECTSSourceObjectIdentifierr\r]rSourceObjectConfig objectConfigs)r8databases_filtersource_objects_conifgsource_object_configsrsource_object_identifiers r,_GetSourceObjectsConfigForSpecifiedDatabases@MigrationJobsClient._GetSourceObjectsConfigForSpecifiedDatabasesps MM==!]]>>bbtt>$!%!E!E}}33GGVV "F" "" -- * *7 + %+@'  rcURRURRRRS9nUHnUSnUSnURR UUURRR R S5S9nURc/UlURRURRUS95 M U$)rrschematableTABLE)rrr r) r.rrrrr\r]rrr)r8object_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.rrQrrrrrMigrationJobObjectsConfig)r8r>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)rQr=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.PostgresDestinationConfigrQrmaxConcurrentConnectionsstrrtransactionTimeout)r8r>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.PostgresSourceConfigrQr skipFullDump)r8r>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.OracleSourceConfigrQr maxConcurrentFullDumpConnectionsrmaxConcurrentCdcConnectionsrr intrcdcStartPositionr RequiredArgumentException)r8r>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.SqlServerSourceConfigrQrrrrrr rsqlserverCdcStartPositionr r)r8r>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.SqlServerDestinationConfigrQrrrrr)r8r>sqlserver_destination_configs r_GetSqlServerDestinationConfig2MigrationJobsClient._GetSqlServerDestinationConfig;sq$(==#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 POSTGRESQLrrrr"ORACLEOracleToPostgresConfigr SQLSERVERSqlServerToPostgresConfigr)r8rr>rXroracle_to_postgres_configsqlserver_to_postgres_configs r#_GetHeterogeneousMigrationJobConfig7MigrationJobsClient._GetHeterogeneousMigrationJobConfigPs  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_GetExistingMigrationJobconversionWorkspacerrrrWr#r'r.r.r/r0r r"r3PostgresToSqlServerConfigr#)r8r:r>original_migration_jobrXr 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#UR1S5(dUR1S5(aURIU5Ul%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. rjvpcPeeringConnectivityr%reverseSshConnectivity static_ipstaticIpConnectivityr$ dumpFlagsr?originalMigrationNamez`Conversion workspace or original migration job name is required for heterogeneous migration job.)r| displayNamestater dumpPathr"r#rOrrdrrrrr)&r.rrParseCreateArgsrr`r r IsSpecifiedrkrqrv _GetDumpFlagsr$rr7rCrrrStateValueValuesEnumCREATINGr! cmekKeyNamerQr RewriterRewriterOrperformanceConfigrfrddumpTyper&sqlserverHomogeneousMigrationJobConfigr objectsConfig)r8 source_refdestination_refrSoriginal_migration_name_ref cmek_key_refr>migration_job_typer|r_r"r#paramsheterogeneous_config_keyheterogeneous_config_objmigration_job_obj server_filters r_GetMigrationJob$MigrationJobsClient._GetMigrationJobsa@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$ ?>  233t7O7O88)-(J(J4(P% rc8SRX4R55nSRXS5nSRXT5nURS5(a URSRU55 URS5(a URSRU55 URS5(a URS RU55 URS 5(a!URS RU55 g g ) zr source_enginedestination_engine config_keysource_config_keydestination_config_keys r2_UpdateHeterogeneousMigrationJobConfigUpdateFieldsFMigrationJobsClient._UpdateHeterogeneousMigrationJobConfigUpdateFieldsDs &&//1J,22:M5<<  FGG / 6 67H I  @AA * 1 12C D  HII 2 9 9$    566 ! ( ()? @7rcURURRU5upEUS:XaXRlUR UUSS5 gUS:XaXRlUR UUSS5 g[ SRURRRURRRS95e) zDUpdate the heterogeneous migration job config for the migration job.r*oraclepostgresr, sqlserverzCannot update heterogeneous migration job configuration for source engine: {source_engine} and destination engine: {destination_engine})rirjN) r7r?rWr*rnr,rrr"r'r#r8r>rrrarbs r&_UpdateHeterogeneousMigrationJobConfig:MigrationJobsClient._UpdateHeterogeneousMigrationJobConfigbs 00  - - 2 2D 7  #;;-E* ==      "%@ @0H- ==       !!')==DDKK!.!B!B!N!N!U!U"("  rcURURU5upEUS:XaXRlURUUSS5 g[ SR US95e)zMUpdate the heterogeneous migration job config for the failback migration job.r=rrrszVUnknown heterogeneous failback migration job configuration: {heterogeneous_config_key})raN)rCrKr=rnrrrts r._UpdateHeterogeneousFailbackMigrationJobConfigBMigrationJobsClient._UpdateHeterogeneousFailbackMigrationJobConfigsv 88  / / 7  #>>0H- ==       ((.'?)/)  rcURS5(a$UR5UlSUlSUlgURS5(a%UR U5UlSUlSUlgUR H?nURU5(dMURU5UlSUlSUl g g)z1Update connectivity method for the migration job.rHNrj)rPrvrIrFrGrk _REVERSE_MAPrq)r8rr>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.)rYrrQrrrrrrrr.rrrrrrrrrr rF)r8r>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)rQrrZ)r8r>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}rjzvpcPeeringConnectivity.vpcrz#performanceConfig.dumpParallelLevelrdrXrOrLzconversionWorkspace.commitIdrz8sqlserverHomogeneousMigrationJobConfig.backupFilePatternrz4sqlserverHomogeneousMigrationJobConfig.useDiffBackuprz7sqlserverHomogeneousMigrationJobConfig.promoteWhenReadyrz9sqlserverHomogeneousMigrationJobConfig.dagConfig.sourceAgrz=sqlserverHomogeneousMigrationJobConfig.dagConfig.linkedServerrrz6sqlserverHomogeneousMigrationJobConfig.databaseBackupsrrz!objectsConfig.sourceObjectsConfig) sorted _FIELDS_MAPrPrConvertToCamelCaseextendr{rrrQ)r8r>r|rs 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.)rWvalue)rJ)itemsrr.DumpFlag DumpFlags)r8r$dump_flags_listrWrs rrQ!MigrationJobsClient._GetDumpFlags/saO!'')  --  ! * == " "_ " ==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.rr rdr!r$r"r#rrOrrrrrrr)"rrPrrLr`r.rr rQrfrdrXr!rNrQr$rJrr"r#rrWr rUrVrOr}rrrrrKrurx)r8rr[r\r>rrds 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.5DatamigrationProjectsLocationsMigrationJobsGetRequestr0Get)r8rWget_reqs rr>,MigrationJobsClient._GetExistingMigrationJobrs9 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?rTrerGenerateRequestIdr.8DatamigrationProjectsLocationsMigrationJobsCreateRequestr0Create) r8 parent_refmigration_job_idr[r\rSr]r^r>r request_idcreate_req_type create_reqs rrMigrationJobsClient.CreatezsB 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?,)rrWr updateMask)r?r>hasattrr?rYrrrrr.7DatamigrationProjectsLocationsMigrationJobsPatchRequestjoinr0Patch) r8rWr[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)rWpromoteMigrationJobRequest)r.PromoteMigrationJobRequestrQr objectsFilter9DatamigrationProjectsLocationsMigrationJobsPromoteRequestr0Promote)r8rWr>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)rWrestartMigrationJobRequest) r.RestartMigrationJobRequestrQrrskipValidationrestartFailedObjects9DatamigrationProjectsLocationsMigrationJobsRestartRequestr0Restart)r8rWr>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.DDatamigrationProjectsLocationsMigrationJobsFetchSourceObjectsRequestr0FetchSourceObjects)r8rWfetch_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_sizer|batch_size_attribute)r.=DatamigrationProjectsLocationsMigrationJobsObjectsListRequestrr YieldFromListr4)r8migration_job_ref list_req_typelist_reqs r ListObjectsMigrationJobsClient.ListObjects5sW SS$5$B$B$DEH  # #%%#!  r)r0r4r,r.r7r6)NNNNr*)6rrrrrrr{r9r?r<rTrYr`rfrkrqrvrrrrrrrrrrrrrr rrr#r7rCrernrurxr}rrrrQrr>rrrrrrrrrrrr's'5+3, '!O < >BMC 0 % 4$4* X +Z":H !*!00*'* "$ L%#N(*;z=~vp5(n& $"& 8,t/+h .>  .DF$rr)r __future__rrrapitools.base.pyrr)googlecloudsdk.api_lib.database_migrationrr r googlecloudsdk.api_lib.storager googlecloudsdk.callioper r $googlecloudsdk.command_lib.util.argsrgooglecloudsdk.corecore_exceptionsgooglecloudsdk.core.resourcerrGrobjectrrrrrsW5&'%'>KD7(.<=: 7O ! !7c&cr