dZddlmZddlmZddlmZddlmZddlmZddlmZddl m Z dd l m Z d d d Z Gd dZe je j e j"j$Gdde j&Zy)z;Command to restart migration jobs for a database migration.)absolute_import)division)unicode_literals)api_util)migration_jobs) resource_args)base)logzk Fetch objects for a Database Migration Service migration job by connection to the source. zw To fetch source objects for a migration job: $ {command} MIGRATION_JOB --region=us-central1 ) DESCRIPTIONEXAMPLESceZdZdZdZy)_MigrationJobObjectInfoz>Container for migration job object data using in list display.c|j|_|j|_|j |jnd|_|j|_|j |_|j |_|j|_ y)N) name sourceObject source_objecterrorstatephase createTime create_time updateTime update_time)selfmessages Elib/surface/database_migration/migration_jobs/fetch_source_objects.py__init__z _MigrationJobObjectInfo.__init__*sc DI --D")--";DJDJDJ))D))DN)__name__ __module__ __qualname____doc__rrrrr's F*rrc&eZdZdZedZdZy)FetchSourceObjectszYFetch objects for a Database Migration Service migration job by connection to the source.cftj|d|jjdy)zArgs is called by calliope to gather arguments for this command. Args: parser: An argparse parser that you can use to add arguments that go on the command line after this command. Positional arguments are allowed. z to restartz table( source_object, state:label=STATE, phase:label=PHASE, error:label=ERROR ) N)rAddOnlyMigrationJobResourceArgs display_info AddFormat)parsers rArgszFetchSourceObjects.Args9s-11&,G !!#rc|jjj}tj|j }|j |j}tj|j }tjjdj|j|jtj |||j"dtjjdj|j|j|j%|}|Dcgc] }t'|c}Scc}w)a;Fetch source objects for a Database Migration Service migration job. Args: args: argparse.Namespace, The arguments that this command was invoked with. Returns: A dict object representing the operations resource describing the restart operation if the restart was successful. z@Waiting for migration job [{}] to fetch source objects with [{}]T) no_resourcez0Fetched source objects for migration job {} [{}])CONCEPTS migration_jobParserMigrationJobsClient ReleaseTrackr% RelativeNamerGetClientInstancer statusPrintformatmigrationJobsIdr HandleLRO projects_locations_migrationJobs ListObjectsr)rargsmigration_job_ref mj_clientresult_operationclientobjos rRunzFetchSourceObjects.RunKs$ 3399;2243D3D3FGI 33&&( ' '(9(9(; rNsB&'>DC(#    * *D%%(()=5=5*=5r