OpenMetadata Ingestion Pipelines API

APIs related pipelines/workflows created by the system to ingest metadata.

Operations 38

PUT /v1/services/ingestionPipelines/{id}/followers Add a follower #
GET /v1/services/ingestionPipelines/{fqn}/pipelineStatus List of pipeline status #
PUT /v1/services/ingestionPipelines/{fqn}/pipelineStatus Add pipeline status #
POST /v1/services/ingestionPipelines/bulk/deploy Bulk deploy a list of Ingestion Pipeline #
POST /v1/services/ingestionPipelines/logs/{fqn}/{runId}/close Close log stream for a pipeline run #
GET /v1/services/ingestionPipelines List ingestion pipelines for metadata operations #
PUT /v1/services/ingestionPipelines Create or update an ingestion pipeline #
POST /v1/services/ingestionPipelines Create an ingestion pipeline #
GET /v1/services/ingestionPipelines/name/{fqn} Get an ingestion pipeline by fully qualified name #
DELETE /v1/services/ingestionPipelines/name/{fqn} Delete an ingestion pipeline by fully qualified name #
PATCH /v1/services/ingestionPipelines/name/{fqn} Update an ingestion pipeline using name #
GET /v1/services/ingestionPipelines/{id} Get an ingestion pipeline by Id #
DELETE /v1/services/ingestionPipelines/{id} Delete an ingestion pipeline by Id #
PATCH /v1/services/ingestionPipelines/{id} Update an ingestion pipeline #
DELETE /v1/services/ingestionPipelines/async/{id} Asynchronously delete an ingestion pipeline by Id #
DELETE /v1/services/ingestionPipelines/{id}/followers/{userId} Remove a follower #
DELETE /v1/services/ingestionPipelines/{id}/pipelineStatus Delete Pipeline Status #
DELETE /v1/services/ingestionPipelines/{id}/pipelineStatus/{runId} Delete pipeline status by run ID #
POST /v1/services/ingestionPipelines/deploy/{id} Deploy an ingestion pipeline run #
GET /v1/services/ingestionPipelines/logs/{id}/last/download Download all logs from last ingestion pipeline run as a stream #
GET /v1/services/ingestionPipelines/ip Check the airflow REST host IP #
GET /v1/services/ingestionPipelines/logs/{id}/last Retrieve all logs from last ingestion pipeline run #
GET /v1/services/ingestionPipelines/logs/{fqn}/{runId} Get logs for a pipeline run #
POST /v1/services/ingestionPipelines/logs/{fqn}/{runId} Write logs for a pipeline run #
GET /v1/services/ingestionPipelines/{fqn}/pipelineStatus/{id} Get pipeline status #
GET /v1/services/ingestionPipelines/status Check the airflow REST status #
GET /v1/services/ingestionPipelines/{id}/versions/{version} Get a version of the ingestion pipeline #
POST /v1/services/ingestionPipelines/kill/{id} Mark as failed and kill any not-finished workflow or task for the ingestion… #
GET /v1/services/ingestionPipelines/history List all entity versions within a time range #
GET /v1/services/ingestionPipelines/logs/{fqn} List available runs for a pipeline #
GET /v1/services/ingestionPipelines/{id}/versions List ingestion workflow versions #
PUT /v1/services/ingestionPipelines/restore Restore a soft deleted ingestion pipeline #
GET /v1/services/ingestionPipelines/logs/{fqn}/stream/{runId} Stream logs for a pipeline run #
GET /v1/services/ingestionPipelines/progress/{fqn}/stream/{runId} Stream progress updates for a pipeline run #
POST /v1/services/ingestionPipelines/metrics/{fqn}/{runId} Submit operation metrics batch #
POST /v1/services/ingestionPipelines/toggleIngestion/{id} Set an ingestion pipeline either as enabled or disabled #
POST /v1/services/ingestionPipelines/trigger/{id} Trigger an ingestion pipeline run #
PUT /v1/services/ingestionPipelines/progress/{fqn}/{runId} Update pipeline progress #

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/openmetadata-ingestion-pipelines-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

openmetadata-ingestion-pipelines-api-openapi.yml Raw ↑
openapi: 3.2.0
info:
  title: OpenMetadata Ingestion Pipelines API
  description: Common types and API definition for OpenMetadata
  contact:
    name: OpenMetadata
    url: https://open-metadata.org
    email: openmetadata-dev@googlegroups.com
  license:
    name: Apache 2.0
    url: https://www.apache.org/licenses/LICENSE-2.0
  version: '1.13'
servers:
- url: /api
  description: Current Host
- url: http://localhost:8585/api
  description: Endpoint URL
security:
- BearerAuth: []
tags:


# --- truncated at 32 KB (57 KB total) ---
# Full source: https://raw.githubusercontent.com/api-evangelist/openmetadata/refs/heads/main/openapi/openmetadata-ingestion-pipelines-api-openapi.yml