merlijn / kagera

A Discrete, colored Petri Net DSL & Executor

Version Matrix

Kagera. A Discrete, colored Petri Net DSL & Executor.

Build Status Maven Central


Example of a simple colored petrinet with functions acting on the data in the tokens.

val sum = {

    # This dsl is available on the kagera-dsl branch
    import io.kagera.dsl.experiment._

    // places
    val a = Place[Int](id = "a")
    val b = Place[Int](id = "b")
    val c = Place[Int](id = "c")

    // transitions
    val init = Transition { () ⇒ (5, 5) }
    val sum = Transition { (a: Int, b: Int) ⇒ a + b }

    // process topology
       |>(init) ~>> |>(a, b),
       |>(a, b) ~> sum ~>> |>(c))

Transition Model

Transition Model


  • M is the in-adjacent marking of the transition.
  • S is the type of state the transition closes over, Unit indicates no state.
  • I Is the type of input the transition requires (provided from outside the proces), Unit indicates case no input is required.


  • M' is the out-adjacent marking of the transition.
  • E Is the type of event or output the transition emits. Unit indicates no event / output.

The transition's behaviour is defined by 2 functions

  1. (M, I, S) => (M', E) A function producing the out-adjacent marking and event from in-adjancent marking, state and input.
  2. S => E => S An event sourcing function which updates the state using the emitted event / output object.


Short term:

  • Http API (using akka http)
  • Clustering & Sharding
  • Analysis (using apache Spark or apache Flink), some examples:
    • Path querying
    • Path prediction
    • Transition timing

Long term:

  • Hyarchical petri nets
  • Timed petri nets
  • Other execution models, such as:
  • Process migration
    • Providing tools to migrate process state when the petri net topology changes.
  • Visual process editor