An implementation of a workflow engine built with Python that allows us to build and publish a workflow by adding a trigger, tasks/actions and conditional nodes.
To build a workflow, we start by adding a trigger (we do not add any trigger after this) We continue by adding actions and conditional nodes to determine if the actions downstream should be executed.An action added immediately after a conditional node that returns false won't be executed
Below is a list of supported triggers, actions and conditional nodes(case sensitive!)
Actions:
- SendEmail
- AddToList
- WebinarAutoRegister
- RemoveFromList
- EjectfromJourney
- Adddelay
Conditionals:
- CampaignStatus(status)
- status_list = ['Not registered','Registered', 'Attended', 'did not attend']
- Is_OnList(status)
- status_list = ['Is on this list or segment', 'Is not on this list or segment']
- CheckField(status)
- Check_Purchasestatus(status)
- status_list = ['Has purchased', 'Has not purchased', 'Abandoned', 'cart checkout']
- Has_Visitedpage(status)
- Webinar_Status(status)
- status_list = ['Not registered','Registered', 'Attended', 'did not attend']
Triggers:
- optin
- time_trigger
- campaign_activity
- remove_from_list
- purchase_acitivity
- page_visited_trigger
- list_trigger
To test the workflow, clone this repository:
git clone https://github.com/harryportal/WorkflowEngine
To test with unit test:
python -m unittest test
Below is an example on how to build an publish the workflow
python -i builder.py
Workflow = BuildWorkflow()
workflow.add_trigger(optin)
workflow.add_action(SendEmail)
workflow.add_condition(Webinar_Status('Not registered')
workflow.add_action(AddToList)
workflow.add_action(Adddelay)
workflow.publish_workflow()
