Live Direct Marketing Pipeline Events API

The Pipeline Events API from Live Direct Marketing — 9 operation(s) for pipeline events.

Operations 9

Each operation below carries the questions people ask an LLM about it and the instructions they give an agent to run it. Generated by API Evangelist overlay

POST /api/pipeline/events Ingest a conveyor event from the orchestrator · Ingest a conveyor event from the orchestrator host (upsert task/step, append… #
Ask an LLM
“How does the orchestrator report task and step progress to the conveyor?”
“Can one event append a log line or upload a file snapshot?”
Tell an agent
Send a conveyor event of type {type}.
Post a {type} event for task {task} and step {step}.
GET /api/pipeline/summary Summarise conveyor tasks by status · Task counters by status + how many reached prod per hour/shift (issue #998) #
Ask an LLM
“How many conveyor tasks are in each status right now?”
“How many tasks reached production per hour or per shift?”
Tell an agent
Show the conveyor task summary.
Count conveyor tasks by status and production throughput.
GET /api/pipeline/speed Get conveyor lead time and throughput · "Speed" block: lead time 7/30d, per-stage breakdown, throughput, WIP (issue… #
Ask an LLM
“What's the 7-day and 30-day lead time for conveyor tasks?”
“Which conveyor stage is slowing work down?”
Tell an agent
Show the conveyor speed block, force refresh {force}.
Get conveyor lead time, throughput and WIP with force={force}.
GET /api/pipeline/speed/stage/{name}/tasks List tasks in one conveyor stage · Tasks in a specific stage, sorted by time spent in it (issue #1009, click on… #
Ask an LLM
“Which tasks are sitting longest in a particular conveyor stage?”
“What tasks are in the review stage right now?”
Tell an agent
List tasks in conveyor stage {name} by time spent.
Show which tasks are stuck in stage {name}.
GET /api/pipeline/tasks List conveyor tasks · List of conveyor tasks (status filter, pagination) #
Ask an LLM
“Which conveyor tasks are currently in progress?”
“Can I page through conveyor tasks filtered by status?”
Tell an agent
List conveyor tasks with status {status}, page {page} of size {pageSize}.
Show page {page} ({pageSize} per page) of {status} conveyor tasks.
GET /api/pipeline/tasks/{id} Get a conveyor task with its steps · A conveyor task together with its steps #
Ask an LLM
“What steps has a particular conveyor task gone through?”
“Can I see a conveyor task's details and steps together?”
Tell an agent
Show conveyor task {id} with its steps.
Open conveyor task {id}.
GET /api/pipeline/tasks/{id}/stage-timeline Show a task's per-stage timeline · Per-stage breakdown of one task (issue #998): queued→in_progress→review→…→prod #
Ask an LLM
“How long did one task spend in each stage from queued to prod?”
“Where did a specific conveyor task lose the most time?”
Tell an agent
Show the stage timeline of task {id}.
Break down time per stage for conveyor task {id}.
GET /api/pipeline/steps/{id}/logs Read a conveyor step's logs · Conveyor step logs (pagination, total is a separate count, without all row… #
Ask an LLM
“What did a particular conveyor step log while it ran?”
“Can I page through the logs of one step?”
Tell an agent
Show logs for step {id}, page {page} with {pageSize} rows.
Read page {page} of step {id}'s log, {pageSize} per page.
GET /api/pipeline/files/{name} Get a conveyor service file snapshot · Snapshot of a conveyor service file (GATES.md/questions.md/TEMPLATE.md) #
Ask an LLM
“What do the conveyor's GATES.md or questions.md files currently say?”
“Can I read the latest snapshot of a conveyor service file?”
Tell an agent
Show the conveyor file {name}.
Fetch the snapshot of service file {name}.

Work with this as data

Every API here is available over the APIs.io API and to AI agents over MCP.

MCP server

One button, every client — Claude, Cursor, VS Code and the rest.

https://apis.io/mcp

Tools for apis

7 MCP tools reach this
  • find_apisBrowse and filter every API in the catalog.
  • get_api_artifactsOne API's artifacts, grouped by type.
  • get_openapiThe primary OpenAPI for this API.
  • find_similar_apisAPIs that look like this one.
  • apis_io_searchSTART HERE — APIs, providers and tags for one query, each with its total.
  • resolveTurn a domain, URL or GitHub org into the provider it belongs to.
  • find_cohortsEvery scored population of providers in the catalog.
All 92 tools →

Call it yourself

curl for this page
This API
curl "https://apis.io/api/v1/apis/live-direct-marketing-online:live-direct-marketing-online-pipeline-events-api"
All apis
curl "https://apis.io/api/v1/apis?limit=25"

Discovery needs no key. Ratings and market analysis are Pro.

Get an API key

Free tier, no form to fill in. Signing in shares your email address with us — we store it to create your key and to recognise you if you sign in with another provider. See our Privacy Policy and Terms.

A second provider on the same verified email joins the account you already have.

OpenAPI Specification

live-direct-marketing-online-pipeline-events-api-openapi.yml Raw ↑
openapi: 3.2.0
info:
  title: LDM v3 Pipeline Events API
  description: 'Multi-tenant B2B outreach automation platform. Auth: JWT Bearer (15-min) or tenant API key (ldm_*) managed in CRM Settings → API Keys. All tenant-scoped endpoints require the X-Tenant-Id header.'
  version: 1.0.0
  contact: {}
servers:
- url: https://api.live-direct-marketing.online
  description: Production
- url: https://api.dev.live-direct-marketing.online
  description: Development
- url: http://127.0.0.1:3000
  description: Local
tags:
- name: Pipeline Events
paths:
  /api/pipeline/events:
    post:
      operationId: PipelineController_events
      parameters:
      - name: X-Tenant-Id
        in: header
        required: false
        schema:
          type: string
          format: uuid
        description: Tenant UUID — required for all tenant-scoped endpoints
      requestBody:
        required: true
        content:
          application/json:
            schema:
              $ref: '#/components/schemas/PipelineEventDto'
      responses:
        '202':
          description: ''
      summary: Ingest a conveyor event from the orchestrator host (upsert task/step, append…
      tags:
      - Pipeline Events
  /api/pipeline/summary:
    get:
      operationId: PipelineController_getSummary
      parameters:
      - name: X-Tenant-Id
        in: header
        required: false
        schema:
          type: string
          format: uuid
        description: Tenant UUID — required for all tenant-scoped endpoints
      responses:
        '200':
          description: ''
      security:
      - jwt: []
      summary: 'Task counters by status + how many reached prod per hour/shift (issue #998)'
      tags:
      - Pipeline Events
  /api/pipeline/speed:
    get:
      operationId: PipelineController_getSpeed
      parameters:
      - name: force
        required: true
        in: query
        schema:
          type: string
      - name: X-Tenant-Id
        in: header
        required: false
        schema:
          type: string
          format: uuid
        description: Tenant UUID — required for all tenant-scoped endpoints
      responses:
        '200':
          description: ''
      security:
      - jwt: []
      summary: '"Speed" block: lead time 7/30d, per-stage breakdown, throughput, WIP (issue…'
      tags:
      - Pipeline Events
  /api/pipeline/speed/stage/{name}/tasks:
    get:
      operationId: PipelineController_getStageTasks
      parameters:
      - name: name
        required: true
        in: path
        schema:
          type: string
      - name: X-Tenant-Id
        in: header
        required: false
        schema:
          type: string
          format: uuid
        description: Tenant UUID — required for all tenant-scoped endpoints
      responses:
        '200':
          description: ''
      security:
      - jwt: []
      summary: 'Tasks in a specific stage, sorted by time spent in it (issue #1009, click on…'
      tags:
      - Pipeline Events
  /api/pipeline/tasks:
    get:
      operationId: PipelineController_listTasks
      parameters:
      - name: status
        required: true
        in: query
        schema:
          type: string
      - name: page
        required: true
        in: query
        schema:
          type: string
      - name: pageSize
        required: true
        in: query
        schema:
          type: string
      - name: X-Tenant-Id
        in: header
        required: false
        schema:
          type: string
          format: uuid
        description: Tenant UUID — required for all tenant-scoped endpoints
      responses:
        '200':
          description: ''
      security:
      - jwt: []
      summary: List of conveyor tasks (status filter, pagination)
      tags:
      - Pipeline Events
  /api/pipeline/tasks/{id}:
    get:
      operationId: PipelineController_getTask
      parameters:
      - name: id
        required: true
        in: path
        schema:
          type: string
      - name: X-Tenant-Id
        in: header
        required: false
        schema:
          type: string
          format: uuid
        description: Tenant UUID — required for all tenant-scoped endpoints
      responses:
        '200':
          description: ''
      security:
      - jwt: []
      summary: A conveyor task together with its steps
      tags:
      - Pipeline Events
  /api/pipeline/tasks/{id}/stage-timeline:
    get:
      operationId: PipelineController_getStageTimeline
      parameters:
      - name: id
        required: true
        in: path
        schema:
          type: string
      - name: X-Tenant-Id
        in: header
        required: false
        schema:
          type: string
          format: uuid
        description: Tenant UUID — required for all tenant-scoped endpoints
      responses:
        '200':
          description: ''
      security:
      - jwt: []
      summary: 'Per-stage breakdown of one task (issue #998): queued→in_progress→review→…→prod'
      tags:
      - Pipeline Events
  /api/pipeline/steps/{id}/logs:
    get:
      operationId: PipelineController_getStepLogs
      parameters:
      - name: id
        required: true
        in: path
        schema:
          type: string
      - name: page
        required: true
        in: query
        schema:
          type: string
      - name: pageSize
        required: true
        in: query
        schema:
          type: string
      - name: X-Tenant-Id
        in: header
        required: false
        schema:
          type: string
          format: uuid
        description: Tenant UUID — required for all tenant-scoped endpoints
      responses:
        '200':
          description: ''
      security:
      - jwt: []
      summary: Conveyor step logs (pagination, total is a separate count, without all row…
      tags:
      - Pipeline Events
  /api/pipeline/files/{name}:
    get:
      operationId: PipelineController_getFile
      parameters:
      - name: name
        required: true
        in: path
        schema:
          type: string
      - name: X-Tenant-Id
        in: header
        required: false
        schema:
          type: string
          format: uuid
        description: Tenant UUID — required for all tenant-scoped endpoints
      responses:
        '200':
          description: ''
      security:
      - jwt: []
      summary: Snapshot of a conveyor service file (GATES.md/questions.md/TEMPLATE.md)
      tags:
      - Pipeline Events
components:
  schemas:
    PipelineFileEventDto:
      type: object
      properties:
        name:
          type: string
        content:
          type: string
      required:
      - name
      - content
    PipelineEventDto:
      type: object
      properties:
        type:
          type: object
        task:
          $ref: '#/components/schemas/PipelineTaskEventDto'
        step:
          $ref: '#/components/schemas/PipelineStepEventDto'
        log:
          $ref: '#/components/schemas/PipelineLogEventDto'
        file:
          $ref: '#/components/schemas/PipelineFileEventDto'
      required:
      - type
    PipelineStepEventDto:
      type: object
      properties:
        id:
          type: string
        taskId:
          type: string
        kind:
          type: string
        name:
          type: string
        status:
          type: string
        startedAt:
          type: string
        finishedAt:
          type: string
        exitCode:
          type: number
        meta:
          type: object
      required:
      - id
      - taskId
      - kind
      - name
      - status
    PipelineTaskEventDto:
      type: object
      properties:
        id:
          type: string
        slug:
          type: string
        title:
          type: string
        status:
          type: string
        priority:
          type: string
        tier:
          type: string
        round:
          type: number
        branch:
          type: string
        updatedAt:
          type: string
      required:
      - id
      - slug
      - title
      - status
    PipelineLogEventDto:
      type: object
      properties:
        stepId:
          type: string
        ts:
          type: string
        level:
          type: string
        message:
          type: string
      required:
      - stepId
      - level
      - message
  securitySchemes:
    jwt:
      scheme: bearer
      bearerFormat: JWT
      type: http
      description: JWT access token from /auth/login (Bearer <token>)
    tenant-api-key:
      scheme: bearer
      bearerFormat: JWT
      type: http
      description: Tenant API key (Bearer ldm_*) for MCP/A2A clients. Issued via CRM Settings → API Keys.
    rpa-service:
      scheme: bearer
      bearerFormat: JWT
      type: http
      description: Dedicated RPA service key. No tenant API-key or query-key authentication.