3 d@s0dZddlZddlmZmZGdddeZdS)z Debug plugin N) PluginBaseloggercs,eZdZdZdfdd Zd ddZZS) DebugPluginzExecute workflow in seriesNcsDtt|j|d|r8d|kr8t|ddr8|d|_ntddS)N) plugin_argscallable__call__z,plugin_args must contain a callable function)superr__init__hasattr _callable ValueError)selfr) __class__?/tmp/pip-build-7vycvbft/nipype/nipype/pipeline/plugins/debug.pyr s  zDebugPlugin.__init__FcCsBt|tjstdtjdxtj|D]}|j||q*WdS)zExecutes a pre-defined pipeline in a serial order. Parameters ---------- graph : networkx digraph defines order of execution z'Input must be a networkx digraph objectzExecuting debug pluginN) isinstancenxZDiGraphr rinfoZtopological_sortr )rgraphconfigZ updatehashnoderrrruns  zDebugPlugin.run)N)F)__name__ __module__ __qualname____doc__r r __classcell__rr)rrr s r)rZnetworkxrbaserrrrrrrs