Pipelines & AWPKG

Workflows are programs.
CorvinOS is the OS.

Describe what you want. CorvinOS builds the workflow. Export it as a portable AWPKG, share it with a partner, and it runs on their CorvinOS — with their data, under their rules. Every run is hash-chained and EU-compliant.

Think of it like software, not scripts

Pipelines in CorvinOS are not configuration files or cron jobs. They are first-class programs with names, versions, inputs, outputs, and logic — running on an operating system that provides the infrastructure.

⚙️

Workflows are programs

A workflow has a name, a version, defined inputs, and verifiable outputs. It can branch on conditions, loop over data, and call external services. CorvinOS runs it on demand or on schedule, tracks every execution, and keeps a full audit trail — just like an OS manages processes.

🖥️

CorvinOS is the runtime

Like an operating system runs applications, CorvinOS runs workflows. Different machines, same result. The workflow brings its own logic; CorvinOS provides agents, databases, secrets, compute, and compliance — the infrastructure every workflow needs to run.

📦

AWPKG — ship like software

Export any workflow as an Agentic Workflow Package (.awpkg). Send it to a partner organization. They install it on their CorvinOS. It runs with their data, their agents, and their secrets. Nothing from your side leaks. It works like software distribution — but for AI workflows.

Describe it. CorvinOS builds it.

You don't need to build pipelines step by step. Tell CorvinOS what you need — it generates the workflow, you review and confirm, and the program is ready to run.

1

You describe the goal

Tell your agent what you need in plain language — no YAML, no pipeline editor, no configuration UI.

"Every Monday at 7 am, pull open tickets from our PostgreSQL database, summarize them with the AI, and post a briefing to Discord."
2

CorvinOS generates the steps

The system creates a complete pipeline: steps, triggers, conditions, data source connections, and notification targets — wired together automatically.

Schedule · Mon 07:00 → Data Query (PostgreSQL, open tickets) → Agent Turn (summarize + highlight blockers) → Notification (Discord #standup)
3

You confirm, then own it

Review the generated workflow in the console. Edit any step. Save it. Export as AWPKG whenever you want to share it. The workflow is yours — permanently stored, versioned, and audited.

Saved as weekly-standup-briefing v1.0.0
Ready to run · ready to export as .awpkg

Export. Share. Install. Run.

An AWPKG is a signed, portable file that bundles a complete workflow definition. Transfer it like software. Install it on any CorvinOS instance anywhere in the world.

⚙️ Build workflow describe or compose 📦 Export .awpkg signed · versioned 🤝 Share freely partner · marketplace · team ⬇️ Install on any CorvinOS verified signature Runs locally their data · their rules
.awpkg

One file, complete workflow

An AWPKG bundles the entire workflow definition: steps, triggers, conditions, schema, and version metadata. Transfer it like you'd transfer a document — email, USB, SFTP, marketplace.

signed

Cryptographically verified

Every package is signed by the author's key. The installing CorvinOS verifies the signature before execution. A tampered package is rejected. You know exactly where the workflow came from and that it hasn't been modified in transit.

portable

Runs on any CorvinOS

Install on your own server, a partner's server, or a cloud instance. The workflow connects to local data sources, local agents, and local secrets — nothing from the original author is required at runtime.

shareable

Build a library, share with your team

Build a Monday briefing once. Export it. Every department installs their own copy, pointing at their own database. One workflow, dozens of installations, each running independently and audited separately.

Six types of steps to compose any workflow

Every pipeline is made of steps. Mix and match these six types to build workflows that think, query, compute, integrate, and communicate.

🤖

Agent Turn

The AI reasons about the input, produces text or structured JSON, and can call tools. Use for decisions, summaries, classifications, and drafts.

🗄️

Data Query

Query a connected PostgreSQL, MySQL, or SQLite database. Results flow as structured data to all downstream steps.

🔬

Background Compute

Kick off a heavy computation — statistical analysis, ML inference, grid search, or data transform — without blocking the conversation.

🌐

HTTP Call

Call any REST API with data from previous steps. Integrate with PagerDuty, Jira, Slack, GitHub, email gateways, or any webhook.

📨

A2A Task

Delegate a signed task to another organization's CorvinOS. Wait for their cryptographically verified response, then continue with the result.

📢

Notification

Post results to Discord, Slack, Telegram, email, or any webhook endpoint. Target specific channels, threads, or users.

Six ways to start a workflow

Workflows start on your terms — on a fixed schedule, when someone sends a message, when an external system pings you, or when another agent finishes a task.

🕐

Schedule

Run on a cron expression. Every weekday morning, once a week, every hour.

0 7 * * 1-5
💬

Message

A team member types a keyword or command in a connected channel — the workflow starts immediately.

pattern: "!report"
🔗

Webhook

HTTP POST from any external system — GitHub push, Jira update, Prometheus alert, payment event.

POST /hooks/pipeline-id
🤖

Agent Output

When another agent in your organization produces output that matches a condition you define.

on: agent.output.severity == "high"
📨

A2A Result

When a partner organization's agent finishes a delegated task and sends back a signed response.

on: a2a.response_received
▶️

Manual

Start from the console, via a chat command, or through the REST API whenever you need it.

POST /v1/pipelines/:id/run

Real programs, step by step

Four example workflows — all exportable as AWPKG. Install them as-is, or customize for your data sources and channels.

Daily Briefing ↓ .awpkg

Morning standup briefing

Trigger: Every weekday at 07:00

  • 1
    Data Query

    PostgreSQL: open tasks due today

    SELECT * FROM tasks WHERE due_date = today AND status = 'open'
  • 2
    Agent Turn

    Summarize tasks and highlight blockers

    input: rows from step 1 → markdown summary
  • 3
    Notification

    Post to Discord #morning-standup

    channel: discord → #morning-standup
Incident Response ↓ .awpkg

Automated incident triage

Trigger: Webhook — Prometheus alert fires

  • 1
    Agent Turn

    Classify alert: service, severity, likely cause

    input: alert payload → {service, severity, summary}
  • 2
    Condition

    If severity == HIGH → create PagerDuty incident

    branch: HIGH → step 3 · else → step 4
  • 3
    HTTP Call

    PagerDuty: create incident

    POST api.pagerduty.com/incidents
  • 4
    Agent Turn

    Draft incident summary with recent deployment context

  • 5
    Notification

    Post to #incidents with full context and Jira link

    channel: discord → #incidents
Research Report ↓ .awpkg

Weekly AI research digest

Trigger: Every Friday at 16:00

  • 1
    A2A Task

    Delegate to Research partner: top 5 AI papers this week

    target: research-partner → signed TaskEnvelope
  • 2
    Background Compute

    Statistical analysis of citation counts + trend scores

    strategy: bayesian · artifact: analysis.csv
  • 3
    Agent Turn

    Write a 3-paragraph executive summary

    input: A2A result + compute artifact → markdown
  • 4
    HTTP Call

    Send digest via email API

    POST api.mailgun.net/v3/.../messages
Support Automation ↓ .awpkg

Support ticket triage & response

Trigger: Message posted in #support channel

  • 1
    Agent Turn

    Classify: type (bug / question / feature) + sentiment

    input: message text → {type, sentiment, priority}
  • 2
    Data Query

    Knowledge base: similar resolved tickets

    FTS5 full-text search on title + resolution
  • 3
    Agent Turn

    Draft reply using knowledge base context

    input: original message + KB hits → response draft
  • 4
    Notification

    Reply in thread with draft + optional Jira ticket

    channel: discord → thread reply

Every run is audit-ready by design

EU compliance is not a checkbox you tick at the end. In CorvinOS, it is built into every pipeline step — automatically, without configuration.

🔐

Hash-chained audit log

Every pipeline step is recorded in a tamper-evident hash chain. A modified or missing entry breaks the chain and triggers a CRITICAL alert. You can prove exactly what ran, when, with what input, and what the output was.

📋

GDPR Art. 30 — records of processing

Full records of all processing activities are maintained automatically. No manual logging required. The audit log is on your server, under your control, readable offline, and verifiable without a third party.

👁️

EU AI Act Art. 14 — human oversight

Pipeline execution history, step-level traces, failure reasons, and intervention points are always visible in the console. You can inspect any run, re-trigger with corrections, or halt a workflow at any time.

🏠

Data stays where you put it

Workflows run on your infrastructure. No step sends data to any third party unless you explicitly configure an HTTP call. For maximum isolation, run AI inference locally with a local model — zero egress, zero cloud dependency.

AWPKG and compliance: When you share an AWPKG with a partner organization, each CorvinOS instance runs the workflow independently and maintains its own audit chain. The author's audit log and the installer's audit log are never merged — full separation of processing records, as required under GDPR cross-org data sharing rules.

Build your first AI program today

Open-source, self-hosted, EU AI Act enforced by design. Describe a workflow, export it as AWPKG, and run it anywhere.

Get started on GitHub → Connect organizations with A2A →