workflows.json

workflows.js

{
  example:
  {
    name: 'example workflow',
    chain: [
        {
            name: 'Print foo + bar',
            timeout: 1,
            retry: 1,
            body: function (job, cb) {
                job.result = {message:(job.foo +"-----"+ job.bar)};
                cb(null,"task 1 done");
            },
            fallback: function (err, job, cb) {
                job.result="Error in task 1";
                cb("Error");
            }
        },
        {
            name: 'Add some other info',
            timeout: 1,
            retry: 1,
            body: function (job, cb) {
                job.result.status=200;
                cb(null,"task 2 done");
            },
            fallback: function (err, job, cb) {
                cb("Error in task 2");
            }
        }
    ],
    timeout: 3,
    onerror: [
        {
            name: 'Rollback',
            body: function (job, cb) {
                cb("Error");
            }
        }
    ]
  }
}