B Ÿ@`V ã@s²dddgZddlmZddlmZddlmZmZmZmZm Z Gdd„deƒZ ee ƒZ Gd d„deej ƒZ Gd d„deejƒZGd d „d e ƒZGd d„de ƒZGdd„deƒZdS)Ú TaskPluginÚ TaskFactoryÚWorkflowPluginé)Útask)Úworkflow)ÚPluginÚ implementsÚ InterfaceÚCreatePluginFactoryÚaliasc@s eZdZdS)Ú IWorkflowTaskN)Ú__name__Ú __module__Ú __qualname__©rrú;/tmp/pip-unpacked-wheel-bvjqrktv/pyutilib/workflow/tasks.pyr sr c@s$eZdZeeƒdd„Zdd„ZdS)rcOs*tj|f|ž|Žtjj|f|ž|ŽdS)N)rÚ__init__rÚTask)ÚselfÚargsÚkwdsrrrrszTaskPlugin.__init__cCs tj |¡S)N)rrÚ__repr__)rrrrr szTaskPlugin.__repr__N)r rrrr rrrrrrrsc@s$eZdZeeƒdd„Zdd„ZdS)rcOs*tj|f|ž|Žtjj|f|ž|ŽdS)N)rrrÚWorkflow)rrrrrrr(szWorkflowPlugin.__init__cCs tj |¡S)N)rrr)rrrrr,szWorkflowPlugin.__repr__N)r rrrr rrrrrrr$sc@s$eZdZedƒdd„Zdd„ZdS)ÚSelection_Taskzworkflow.selectioncOs:tj|f|ž|Ž|j d¡|j d¡|j d¡dS)NÚindexÚdataÚ selection)rrÚinputsÚdeclareÚoutputs)rrrrrrr4s  zSelection_Task.__init__cCs|j|j|_dS)N)rrr)rrrrÚexecute<szSelection_Task.executeN)r rrr rr rrrrr0src@s4eZdZedƒdd„Zdd„Zdd„Zdd „Zd S) Ú Switch_Taskzworkflow.switchcOs(tj|f|ž|Ži|_|j d¡dS)NÚvalue)rrÚ _branchesrr)rrrrrrrDszSwitch_Task.__init__cCsddt|jƒ|j|<|j |j|¡|j dt|jƒ¡t|jdt|jƒ|j|j|ƒdS)Nr)ÚstrÚidr#Úoutput_controlsrZinput_controlsÚsetattr)rr"rrrrÚ add_branchIs zSwitch_Task.add_branchcCstd}xF|jD]<}|j|kr4|j|j| ¡d}q |j|j| ¡q W|sptdt|jƒt|j ¡ƒfƒ‚dS)NFTzfBranch condition has value '%s' but no branch is indexed with that value. Valid branch indices: %s) r#r"r&Z set_readyÚresetÚ ValueErrorr$ÚsortedÚkeys)rÚflagÚkeyrrrr Qs  zSwitch_Task.executecCs t |¡S)N)rr)rrrrr^szSwitch_Task.__repr__N)r rrr rr(r rrrrrr!@s  r!c@s$eZdZedƒdd„Zdd„ZdS)Ú IfThen_Taskzworkflow.branchcOstj|f|ž|ŽdS)N)r!r)rrrrrrrfszIfThen_Task.__init__cCs t |¡S)N)r!r)rrrrriszIfThen_Task.__repr__N)r rrr rrrrrrr/bsr/N)Ú__all__Zpyutilib.workflowrrZpyutilib.component.corerrr r r r rrrrrrr!r/rrrrÚ s     "