lt.pipelines

lt.pipelines reads the execution history of YAML pipelines (entities, jobs and full execution timelines) and interrupts running jobs. lt.mcpRuns is a deprecated alias that exposes listEntities, listJobs and getExecution.

listEntities

const result = await lt.pipelines.listEntities({ app_id: 'longtail' });

List the distinct entity types in a namespace.

Parameters

Field	Type	Required	Description
app_id	string	Yes	Namespace

Returns: LTApiResult<{ entities: string[] }>. 400 without app_id.

Auth: Not required.

listJobs

const result = await lt.pipelines.listJobs({
  app_id: 'longtail',
  entity: 'mcp_query',
  limit: 25,
});

List jobs (pipeline runs) in a namespace.

Parameters

Field	Type	Required	Description
app_id	string	Yes	Namespace
limit	number	No	Max results
offset	number	No	Pagination offset
entity	string	No	Filter by entity type
search	string	No	Full-text search
status	string	No	Filter by job status
sort_by	string	No	Field to sort by
order	string	No	asc or desc

Returns: LTApiResult<{ jobs: any[], total: number }>. 400 without app_id.

Auth: Not required.

getExecution

const result = await lt.pipelines.getExecution({ jobId: 'job-123', app_id: 'longtail' });

Get the full execution history of one job.

Parameters

Field	Type	Required	Description
jobId	string	Yes	Job (workflow) ID
app_id	string	Yes	Namespace

Returns: LTApiResult<ExecutionTimeline>

Auth: Not required.

interrupt

const result = await lt.pipelines.interrupt({
  jobId: 'job-123',
  topic: 'screenshot_analyze',
  app_id: 'longtail',
});

Interrupt a running pipeline job. This is the pipeline counterpart of lt.workflows.terminate: pipelines run as YAML DAGs, so the call needs the namespace and topic to reach the right engine.

Parameters

Field	Type	Required	Description
jobId	string	Yes	Job (workflow) ID
topic	string	Yes	The workflow’s entity (topic) name
app_id	string	Yes	Namespace

Returns: LTApiResult<{ interrupted: true, jobId }>. 400 without app_id or topic.

Auth: Not required.