<dZddlmZddlmZddlmZddlmZddlmZddlm Z ddl m Z dd l m Z d d d Zejej j"Gd dej$Zy)zCreate Command for Job.)absolute_import)division)unicode_literals)jobs)base) exceptions)flags) resourcesz {description}z To create a Job with the id `my-job` experiment `my-experiment` and fault-targets `target1 and target2`, run: $ {command} my-job --experiment=my-experiment --fault-targets="target1", "target2" ) DESCRIPTIONEXAMPLESc:eZdZdZeZedZedZdZ y)Createz%Create a Fault injection testing job.c.tj|y)N)r AddCreateJobFlags)parsers *lib/surface/fault_injection/jobs/create.pyArgsz Create.Args-s F#c|jjj}tjj|j d|j |jd}|j |j k7rtjdd|j|jk7rtjdd||fS)zParse, validate and return the CA and KMS key version args from the CLI. Args: args: The parsed arguments from the command-line. Returns: Tuple containing the Resource objects for the KMS key version and CA, respectively. z4faultinjectiontesting.projects.locations.experiments) projectsId locationsId) collectionparams Experimentz9Experiment must be in the same project as the JOBversion.z:Experiment must be in the same location as the Jobversion.) CONCEPTSjobParser REGISTRY experimentrrrInvalidArgumentException)argsjob_refexp_refs rParseResourceArgszCreate.ParseResourceArgs1smm%%'G  && I!,,".. 'GW///  / /    g111  / /    W rctj}|j|\}}|j}|j st j dd|j st j dd|jst j dd|j|j |j|j|j|jS)zRun the create command.rzjob id must be non-empty.zexperiment must be non-empty.z fault targets must be non-empty.)job_id experiment_id fault_targetsdry_runparent) r JobsClientr$ParentNamerr r(r RelativeNamer))selfr!clientr"r# parent_refs rRunz Create.RunWs __ F--d3GW!J <<>  / / ,  <<>  / / 0      / / 3  ==||~**,(( &&(  rN) __name__ __module__ __qualname____doc___DETAILED_HELP detailed_help staticmethodrr$r2rrrr's6- -$$##JrrN)r6 __future__rrr&googlecloudsdk.api_lib.fault_injectionrgooglecloudsdk.callioperr*googlecloudsdk.command_lib.fault_injectionr googlecloudsdk.corer r7 ReleaseTracks ReleaseTrackALPHA CreateCommandrr:rrrDsp&'7(.<)# D%%++,IT  I-Ir