Mara (https://github.com/mara/data-integration) is a task scheduler.. you define chain-able tasks to be scheduled for execution with support for sub-tasks. There's an Apache version called Airflow initially started at AirBnB.

Came across it on HackerNews (https://news.ycombinator.com/item?id=17030102)

Will be really useful to have something like this in D (scripted in D). Such a tool is used by several major enterprises per the Airflow docs (https://github.com/apache/airflow). A potential killer app that's actually needed for enterprise workflow.


Its like (Mara in Python):
from data_integration.commands.bash import RunBash
from data_integration.pipelines import Pipeline, Task
from data_integration.ui.cli import run_pipeline, run_interactively

pipeline = Pipeline(
    id='demo',
    description='A small pipeline that demonstrates the interplay between pipelines, tasks and commands')

pipeline.add(Task(id='ping_localhost', description='Pings localhost',
                  commands=[RunBash('ping -c 3 localhost')]))

sub_pipeline = Pipeline(id='sub_pipeline', description='Pings a number of hosts')

for host in ['google', 'amazon', 'facebook']:
    sub_pipeline.add(Task(id=f'ping_{host}', description=f'Pings {host}',
                          commands=[RunBash(f'ping -c 3 {host}.com')]))

sub_pipeline.add_dependency('ping_amazon', 'ping_facebook')
sub_pipeline.add(Task(id='ping_foo', description='Pings foo',
                      commands=[RunBash('ping foo')]), ['ping_amazon'])

pipeline.add(sub_pipeline, ['ping_localhost'])

pipeline.add(Task(id='sleep', description='Sleeps for 2 seconds',
                  commands=[RunBash('sleep 2')]), ['sub_pipeline'])

Another one in Node.JS is Agenda (https://github.com/agenda/agenda)


If you work in an enterprise with lots of scheduled cron jobs/task queues that sometimes depend on each other...and you need transparency and metrics, that's your tool.