Skip to content

The simple, stupid workflow engine for Java, with Playbooks

Notifications You must be signed in to change notification settings

rajkowski/easy-flows-playbooks

 
 

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

86 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation


Easy Flows - Playbooks Edition
The simple, stupid workflow engine for Java™, with Playbooks

What is the Playbooks Edition?

In this version you can define the workflows in YAML similar to Ansible, or from other resources. Playbooks contain the rules and configuration for executing tasks. Supply your YAML, and your own map of task ids and classes. Emphasis is on configuration over code. Jackson/YAML is a required dependency.

These are the changes from Easy Flows:

  1. The functionality to use YAML to read in workflows has been added
  2. A 'Playbook Manager' assembles and caches workflows, as 'Playbooks' and executes them; once defined you can execute workflows repeatedly by id
  3. 'Task' items are your tasks which perform work; these can be instantiated once by the Playbook Manager, they are considered immutable, and can be re-used during workflows and with other workflows concurrently; Tasks have a unique id for reference
  4. YAML can include expressions evaluated using Jexl
  5. Some additional features as seen in the example workflows...

An example with parallel tasks within a sequence:

id: my-workflow
name: Does something...
workflow:
  - log: foo
    repeat: 3
  - parallel:
    timeout: 5
    threads: 2
    tasks:
      - log: hello
      - log: there
      - log: world
  - set: completed=true
  - log: ok
    when: completed==true
  - log: nok
    when: completed==false

An example with conditional blocks within a sequence; when a task fails within a block, the block fails but other blocks and tasks outside the block resume:

id: my-block-workflow
name: Does something...
workflow:
  - log: Repeat 3 times
    repeat: 3
  - set: condition1 = 1
  - block:
    when: condition1 == 1
    - log: Repeating 2 times
      repeat: 2
    - set: block1 = yes
  - block:
    when: condition1 == 0
    - log: This block will not be executed
    - log: This is not executed
    - set: block2 = yes
  - set: finished = yes
  - log: Finished

An example with expressions, an event object is provided to the work context:

- id: user-registered
  vars:
   user: '{{ event.user }}'
   ipAddress: '{{ event.ipAddress }}'
  workflow:
  - email:
    to-user: '{{ user.id }}'
    subject: 'Thank you for registering'
    template: 'cms/registration-confirmation'
  - email:
    to-role: 'community-manager'
    subject: 'User id {{ user.id }} registered'
    template: 'cms/admin-user-registered-notification'
  - history:
    message: '_{{ user.fullName }}_ **{{ verb }}** with the site'
    actor-id: '{{ user.id }}'
    verb: registered
    object: user
    object-id: '{{ user.id }}'

This workflow engine is modified from Easy Flows and is considered incompatible (and largely untested). For original information, and very good background details, see Easy Flows...

These are the previous notes:

What is Easy Flows?

Easy Flows is a workflow engine for Java. It provides simple APIs and building blocks to make it easy to create and run composable workflows.

A unit of work in Easy Flows is represented by the Work interface. A work flow is represented by the WorkFlow interface. Easy Flows provides 4 implementations of the WorkFlow interface:

Those are the only basic flows you need to know to start creating workflows with Easy Flows. You don't need to learn a complex notation or concepts, just a few natural APIs that are easy to think about.

How does it work?

First let's write some work:

class PrintMessageWork implements Work {

    private String message;

    public PrintMessageWork(String message) {
        this.message = message;
    }

    public String getName() {
        return "print message work";
    }

    public WorkReport execute(WorkContext workContext) {
        System.out.println(message);
        return new DefaultWorkReport(WorkStatus.COMPLETED, workContext);
    }
}

This unit of work prints a given message to the standard output. Now let's suppose we want to create the following workflow:

  1. print "foo" three times
  2. then print "hello" and "world" in parallel
  3. then if both "hello" and "world" have been successfully printed to the console, print "ok", otherwise print "nok"

This workflow can be illustrated as follows:

  • flow1 is a RepeatFlow of work1 which is printing "foo" three times
  • flow2 is a ParallelFlow of work2 and work3 which respectively print "hello" and "world" in parallel
  • flow3 is a ConditionalFlow. It first executes flow2 (a workflow is also a work), then if flow2 is completed, it executes work4, otherwise work5 which respectively print "ok" and "nok"
  • flow4 is a SequentialFlow. It executes flow1 then flow3 in sequence.

With Easy Flows, this workflow can be implemented with the following snippet:

PrintMessageWork work1 = new PrintMessageWork("foo");
PrintMessageWork work2 = new PrintMessageWork("hello");
PrintMessageWork work3 = new PrintMessageWork("world");
PrintMessageWork work4 = new PrintMessageWork("ok");
PrintMessageWork work5 = new PrintMessageWork("nok");

ExecutorService executorService = Executors.newFixedThreadPool(2);
WorkFlow workflow = aNewSequentialFlow() // flow 4
        .execute(aNewRepeatFlow() // flow 1
                    .named("print foo 3 times")
                    .repeat(work1)
                    .times(3)
                    .build())
        .then(aNewConditionalFlow() // flow 3
                .execute(aNewParallelFlow() // flow 2
                            .named("print 'hello' and 'world' in parallel")
                            .execute(work2, work3)
                            .with(executorService)
                            .build())
                .when(WorkReportPredicate.COMPLETED)
                .then(work4)
                .otherwise(work5)
                .build())
        .build();

WorkFlowEngine workFlowEngine = aNewWorkFlowEngine().build();
WorkContext workContext = new WorkContext();
WorkReport workReport = workFlowEngine.run(workflow, workContext);
executorService.shutdown();

This is not a very useful workflow, but just to give you an idea about how to write workflows with Easy Flows. You can find more details about all of this in the wiki.

Why Easy Flows?

Easy Flows was created due to the lack of a simple open source workflow engine that can orchestrate Callable/Runnable Java objects. Why every single workflow engine out there is trying to implement BPMN? There is nothing wrong with BPMN, but it is not easy ( 538 pages specification?? ). Same thing for BPEL..

There are currently good workflow engines, but since they try to implement BPMN, they are not easy to use and are often misused. Most of BPMN concepts are not essential to many applications, and building such applications on top of a heavy engine is not efficient.

Easy Flows tries to provide a simple alternative with natural APIs that are easy to think about along with basic flows that most small/medium sized applications would require. If your business process requires a A0 paper to be drawn down, Easy Flows is probably not the right choice for you.

Contribution

You are welcome to contribute to the project with pull requests on GitHub.

If you found a bug or want to request a feature, please use the issue tracker.

Awesome contributors

Thank you for your contributions!

License

Easy Flows is released under the terms of the MIT license:

The MIT License (MIT)

Copyright (c) 2020 Mahmoud Ben Hassine (mahmoud.benhassine@icloud.com)

Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"), to deal
in the Software without restriction, including without limitation the rights
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
copies of the Software, and to permit persons to whom the Software is
furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in
all copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
THE SOFTWARE.

About

The simple, stupid workflow engine for Java, with Playbooks

Resources

Stars

Watchers

Forks

Packages

No packages published

Languages

  • Java 100.0%