Building Workflows

name: Customer Support Pipeline
version: "1.0"
trigger:
  type: webhook
  path: /support/incoming

steps:
  - id: classify
    agent: text-classifier
    input:
      text: "{{ trigger.body.message }}"
    output:
      category: "{{ result.category }}"

  - id: respond
    agent: support-agent
    depends_on: [classify]
    input:
      category: "{{ steps.classify.output.category }}"
      message: "{{ trigger.body.message }}"

  - id: notify
    agent: notification-agent
    depends_on: [respond]
    condition: "{{ steps.classify.output.category == 'urgent' }}"
    input:
      channel: "slack"
      message: "{{ steps.respond.output.response }}"

output:
  response: "{{ steps.respond.output.response }}"
  category: "{{ steps.classify.output.category }}"

from mindblix import Workflow, Step

wf = Workflow(
    name="Customer Support Pipeline",
    trigger="webhook:/support/incoming"
)

classify = Step(
    id="classify",
    agent="text-classifier",
    input={"text": "{{ trigger.body.message }}"}
)

respond = Step(
    id="respond",
    agent="support-agent",
    depends_on=["classify"],
    input={
        "category": "{{ steps.classify.output.category }}",
        "message": "{{ trigger.body.message }}"
    }
)

wf.add_steps([classify, respond])
wf.deploy()