o .&a4B@s2ddlZddlmZmZddlmZddlmZddlmZddl m Z ddl m Z ddl mZd Zd Zd Zd Zd ZGdddeZGdddeZddZddZddZddZddZddZd,ddZGd d!d!eZGd"d#d#eZ Gd$d%d%eZ!Gd&d'd'eZ"Gd(d)d)eZ#Gd*d+d+eZ$dS)-N)datetime timedelta) get_formatter)CustomArgument) BasicCommand) translator)CreateDefaultRoles)ListRunsFormatterzThe JSON pipeline definition. If the pipeline definition is in a file you can use the file:// syntax to specify a filename. aThe JSON parameter objects. If the parameter objects are in a file you can use the file:// syntax to specify a filename. You can optionally provide these in pipeline definition as well. Parameter objects provided on command line would replace the one in definition. aThe JSON parameter values. If the parameter values are in a file you can use the file:// syntax to specify a filename. You can optionally provide these in pipeline definition as well. Parameter values provided on command line would replace the one in definition. aThe JSON parameter values. You can specify these as key-value pairs in the key=value format. Multiple parameters are separated by a space. For list type parameter values you can use the same key name and specify each value as a key value pair. e.g. arrayValue=value1 arrayValue=value2 dc@s eZdZdS)DocSectionNotFoundErrorN)__name__ __module__ __qualname__rrM/usr/lib/python3/dist-packages/awscli/customizations/datapipeline/__init__.pyr 8sr cseZdZfddZZS)ParameterDefinitionErrorcs"d|}tt||||_dS)NzError in parameter: %s )superr__init__msg)selfrfull_msg __class__rrr=s z!ParameterDefinitionError.__init__)r r rr __classcell__rrrrr<srcCs@|dt|dt|dt|dt|dtdS)Nz`__)doc pop_write IndexErrorr write) help_commandr'r)currentrrrr Zs"   r cKsTtddtd|d<tddtd|d<tddtd|d<tdddtd |d<|d =dS) Nzpipeline-definitionTrequired help_textzparameter-objectsFparameter-values-uriparameter-values+r0nargsr1zpipeline-objects)PipelineDefinitionArgumentDEFINITION_HELP_TEXTParameterObjectsArgumentPARAMETER_OBJECTS_HELP_TEXTParameterValuesArgumentPARAMETER_VALUES_HELP_TEXTParameterValuesInlineArgument!INLINE_PARAMETER_VALUES_HELP_TEXTargument_tabler'rrrrrs(    rcKs*tddtd|d<tdddtd|d<dS)Nr2Fr/r3r4r5)r;r<r=r>r?rrrrs rcKst|dSN)rapi_to_definition)parsedr'rrrrsrcCsjg}|D]$}|d|dd}|dD]}|d|d||d<q||q|dur3|j|d|S) Nidname)z@idrEfields stringValuerefValuekey)rI)getappendsort)api_describe_objects sort_key_func convertedobj new_fieldsfieldrrrconvert_described_objectss   rSc@s2eZdZdZd ddZddZddZd d ZdS) QueryArgBuilderzG Convert CLI arguments to Query arguments used by QueryObject. NcCs|durt}||_dSrA)rutcnow current_time)rrVrrrrs zQueryArgBuilder.__init__cCsg}|jdur.|jdur.|j}|tdd}|d}|d}|dd||gddn||||jdur?|||d|i}|S) N)daysz%Y-%m-%dT%H:%M:%S@actualStartTimeBETWEENtypevalues fieldNameoperator selectors) start_intervalschedule_intervalrVrstrftimerK_build_schedule_timesstatus _build_status)r parsed_argsra end_datetimestart_datetimestart_time_str end_time_strqueryrrr build_querys$       zQueryArgBuilder.build_querycCsx|jdur|jd}|jd}|dd||gdd|jdur:|jd}|jd}|dd||gdddSdS)NrrYrZr[r^@scheduledStartTime)rbrKrc)rrarhrkrlrrrres&       z%QueryArgBuilder._build_schedule_timescCs&|dddd|jDdddS)Nz@statusEQcSg|]}|qSr)upper).0rfrrr sz1QueryArgBuilder._build_status..r[r^)rKrf)rrarhrrrrgs  zQueryArgBuilder._build_statusrA)r r r__doc__rrnrergrrrrrTs   rTc@eZdZddZdS)r7cCsx|durdSt|}t|}t|}t|}||d<d|vr*|dur*||d<d|vr8|dur:||d<dSdSdS)NpipelineObjectsparameterObjectsparameterValues)jsonloadsrdefinition_to_api_objectsdefinition_to_api_parametersdefinition_to_parameter_values)r parametersvaluerC api_objectsparameter_objectsparameter_valuesrrr add_to_paramss     z(PipelineDefinitionArgument.add_to_paramsNr r rrrrrrr7 r7c@rw)r9cCs,|durdSt|}t|}||d<dS)Nry)r{r|rr~)rrrrCrrrrr s    z&ParameterObjectsArgument.add_to_paramsNrrrrrr9 rr9c@rw)r;cCsD|durdS|dddurtdt|}t|}||d<dS)Nrz8Only parameter-values or parameter-values-uri is allowed)rJ Exceptionr{r|rr)rrrrCrrrrrs   z%ParameterValuesArgument.add_to_paramsNrrrrrr;rr;c@rw)r=c Cs|durdS|dddurtdi}|D]?}z0|dd}|d}|d}||vrCt||tr:|||n |||g||<n|||<WqtyUtd|wd|i}t |}||d<dS)Nrzr=rorz#Invalid inline parameter format: %sr]) rJrsplit isinstancelistrKr+rrr) rrrparameter_objectargumentargument_componentsrIrCrrrrr#s4    z+ParameterValuesInlineArgument.add_to_paramsNrrrrrr="rr=c @seZdZdZdZddddddd d dd d d ddddddddddgZgdZddZddZddZ ddZ ddZ ddZ ddZ d d!Zd"S)#r$r#zLists the times the specified pipeline has run. You can optionally filter the complete list of results to include only the runs you are interested in.z pipeline-idzThe identifier of the pipeline.storeTstring)rEr1actionr0 cli_type_namerfzFilters the list to include only runs in the specified statuses. The valid statuses are as follows: waiting, pending, cancelled, running, finished, failed, waiting_for_runner, and waiting_on_dependencies.)rEr1rzstart-intervalzQFilters the list to include only runs that started within the specified interval.Fzschedule-intervalz`Filters the list to include only runs that are scheduled to start within the specified interval.) waitingpending cancelledrunningfinishedfailedwaiting_for_runnerwaiting_on_dependencies shutting_downcKs$|||||||dSrA) _set_client_parse_type_args _list_runs)rrhparsed_globalsr'rrr _run_mainds  zListRunsCommand._run_maincCs |jjd|j|j|jd|_dS)N datapipeline) region_name endpoint_urlverify)_session create_clientregionr verify_sslclient)rrrrrris  zListRunsCommand._set_clientcCsz|jdurdd|jdD|_|jdur"dd|jdD|_|jdur;dd|jdD|_||jdSdS)NcSrrrstriprtargrrrruwz4ListRunsCommand._parse_type_args..,cSrrrrrrrrru{rcSrrrrrrrrrur)rbrrcrf_validate_status_choices)rrhrrrrrs      z ListRunsCommand._parse_type_argscCs0|D]}||jvrtd|d|jfqdS)Nz&Invalid status: %s, must be one of: %sz, ) VALID_STATUS ValueErrorjoin)rstatusesrfrrrrs z(ListRunsCommand._validate_status_choicescCsRt|}||j|}||j|}t|ddd}||}||j|dS)NcSs|d|dfS)NrprE)rJ)xrrrsz,ListRunsCommand._list_runs..)rN)rTrn_query_objects pipeline_id_describe_objectsrS_get_formatterNAME)rrhrrm object_idsobjectsrO formatterrrrrs  zListRunsCommand._list_runscCsLg}tdt|tD]}|||t}|jj||d}||dq |S)Nr) pipelineId objectIdsrx)rangelenMAX_ITEMS_PER_DESCRIBErdescribe_objectsextend)rrrricurrent_object_idsresultrrrrsz!ListRunsCommand._describe_objectscCs(|jdj|d|d}|}|dS)N query_objectsINSTANCE)rspherermids)r get_paginatorpaginatebuild_full_result)rrrm paginatorrCrrrrs zListRunsCommand._query_objectscCs |j}|dur t|St||SrA)outputr r)rrrrrrrs zListRunsCommand._get_formatterN)r r rr DESCRIPTION ARG_TABLErrrrrrrrrrrrrr$Ds:   r$rA)%r{rrawscli.formatterrawscli.argumentsrawscli.customizations.commandsr"awscli.customizations.datapipeliner5awscli.customizations.datapipeline.createdefaultrolesr4awscli.customizations.datapipeline.listrunsformatterr r8r:r<r>rrr rr"rr rrrrSobjectrTr7r9r;r=r$rrrrs8        B "