Skip to content

Open-source workflow engine. Orchestrate and observe computational workflows defined in plain Python. Suitable for data pipelines, background tasks, etc.

License

Notifications You must be signed in to change notification settings

CofluxLabs/coflux

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Coflux

Coflux is an open-source workflow engine. Use it to orchestrate and observe computational workflows, defined in plain Python. Suitable for data pipelines, background tasks, chat bots.

from coflux import workflow, task
import requests

@task(retries=2)
def fetch_splines(url):
    return requests.get(url).json()

@task()
def reticulate(splines):
    return list(reversed(splines))

@workflow()
def my_workflow(url):
    reticulate(fetch_splines(url))

Refer to the docs for more details.