Skip to content

Extending Conductor

Backend

Conductor provides a pluggable backend. The current implementation uses Dynomite.

There are 4 interfaces that need to be implemented for each backend:

//Store for workflow and task definitions
com.netflix.conductor.dao.MetadataDAO

//Store for workflow executions
com.netflix.conductor.dao.ExecutionDAO

//Index for workflow executions
com.netflix.conductor.dao.IndexDAO

//Queue provider for tasks
com.netflix.conductor.dao.QueueDAO

It is possible to mix and match different implementations for each of these.
For example, SQS for queueing and a relational store for others.

System Tasks

To create system tasks follow the steps below:

  • Extend com.netflix.conductor.core.execution.tasks.WorkflowSystemTask
  • Instantiate the new class as part of the startup (eager singleton)
  • Implement the TaskMapper interface
  • Add this implementation to the map identified by TaskMappers

Workflow Status Listener

To provide a notification mechanism upon completion/termination of workflows:

  • Implement the WorkflowStatusListener interface
  • This can be configured to plugin custom notification/eventing upon workflows reaching a terminal state.

Event Handling

Provide the implementation of EventQueueProvider.

E.g. SQS Queue Provider: SQSEventQueueProvider.java