parade.flowrunner package

Submodules

parade.flowrunner.default module

Module contents

class parade.flowrunner.FlowRunner

Bases: parade.core.Plugin

The executor to submit task flow

submit(flow, flow_id=0, **kwargs)

schedule the task-flow :param flow: the flow to run :return: