Noma flow
Scheduler & orchestration

The scheduler and orchestration engine bundled with Liberty Next. It runs inside the framework process — no separate worker, no broker, no companion daemon. Schedule cron jobs, run ETL pipelines, mirror LDAP, fan out HTTP calls, and let operators watch every run live from the same UI as the rest of the application.

Bundled with Liberty NextIn-process — no brokerCron · interval · manualSQL · Python · HTTP · LDAP stepsRetry · timeout · backoffLive log tail

What it solves

The background-work every internal app needs

Without Nomaflow this usually means cron tabs scattered across hosts, Python scripts in different repos, no shared retry logic and no single place to see “what just ran”. With it: one catalogue of jobs, one history of runs, one live log tail — in the same UI as the rest of the application.

Nightly database refresh

Pull data from an operational store into a reporting store, on a schedule.

Periodic API pull

Fetch from a third-party service every hour, with retry on failure.

LDAP / AD sync

Mirror users and groups from the directory into the application.

Cleanup job

Prune old records, archive PDFs, delete expired sessions.

Conditional flow

Run only when something happened — a file landed, a count crossed a threshold.

Manual one-off

An operator triggers it from a button after a release, with parameters.

How it works

From catalogue to run history

A job is a catalogue entry; the in-process scheduler fires it on cron, an interval or a manual trigger; the step engine runs SQL, Python and HTTP steps with retry and timeout; the run history surfaces every run with a live log tail.

Nomaflow flow — catalogue, scheduler, step engine, run history, and operator surfaces

Patterns

What you can build

Scheduled database sync

Cron at 02:00 → SQL Copy from source pool to target pool → success notification.

External API pull

Cron hourly → HTTP step with bearer auth → Python transforms the payload → SQL write.

LDAP / AD mirror

Cron every 4 hours → LDAP Sync step → upsert into the users table.

Conditional cleanup

Cron daily → SQL count of old rows → conditional Python step deletes past a threshold.

File watcher → batch

Cron every 5 minutes → Python lists a folder → per new file, SQL Copy + archive move.

Smoke test

Cron every 5 minutes → HTTP step against your healthz → email alert after 3 failures in a row.

The pieces are deliberately small — a step does one thing. The pipelines compose them; the run history surfaces what happened.

The right fit

When to reach for Nomaflow

Reach for Nomaflow when…

  • Workloads are install-scoped and don’t cross many systems.
  • The whole pipeline finishes in seconds to minutes.
  • Cron + linear steps + retry is enough.
  • You want one tool, one UI, one log stream.
  • You’d otherwise hand-write a Python script + a systemd timer.

Reach for something else when…

  • Workloads span a dozen services and need a global DAG view.
  • A single step takes hours and needs autoscaling.
  • You need dynamic task expansion or fan-out / fan-in DAGs.
  • You already run Airflow / Dagster / Prefect for everything else.
  • You’d otherwise write a Kubernetes CronJob with sidecars.

The design point is “the operational glue most internal apps need” — not “every orchestration use case”. For the 80% case, it removes a lot of pipe-laying.

No second stack

How it fits inside Liberty Next

Nomaflow reuses the framework’s connectors, permission model, encryption layer and Settings UI. There’s no “Nomaflow database” to install, no “Nomaflow user accounts” to manage — if a team already has Liberty Next, they already have Nomaflow.

Connectors (SQL / HTTP / LDAP)

Reach data sources and APIs through the same declared queries your screens use.

Pools

Database connections, shared with the rest of the framework.

Authentication + roles

job: permission gates per role; :session_user for audit on triggers.

Encryption

Connector credentials, webhook URLs and OAuth secrets — all encrypted at rest.

Settings UI

The Jobs builder and step editor live there — nothing extra to install.

Socket.IO

Live updates on run state, step transitions and the log tail.

One Tool for the Operational Glue

Nomaflow ships with Liberty Next. Install the framework, define a job, and watch your first scheduled run live.