geomagilles

new OrderWorkflow({ item: “item_ref” }).dispatch();

geomagilles

var { Workflow } = require("zenaton");
var TaskA = require("./TaskA");
var TaskB = require("./TaskB");

module.exports = Workflow("SequentialWorkflow", function() {
  new TaskA().execute();
  new TaskB().execute();
});

geomagilles

var { Workflow } = require("zenaton");
var GetPriceFromProviderA = require("./GetPriceFromProviderA");
var GetPriceFromProviderB = require("./GetPriceFromProviderB");
var GetPriceFromProviderC = require("./GetPriceFromProviderC");
var OrderFromProviderA = require("./OrderFromProviderA");
var OrderFromProviderB = require("./OrderFromProviderB");
var OrderFromProviderC = require("./OrderFromProviderC");

module.exports = Workflow("OrderWorkflow", function() {
  

geomagilles

class OrderWorkflow(Workflow):

    def __init__(self, item, address):
        self.item = item
        self.address = address

    def handle(self):      
        self.execute(PrepareOrder(self.item))
        event = self.execute(Wait(OrderPreparedEvent))
        self.execute(SendOrder(event.id, self.item, self.address))