Pipeline

import Reducto from 'reductoai';
import fs from 'fs';

const client = new Reducto();

// Upload
const upload = await client.upload({ 
  file: fs.createReadStream("invoice.pdf") 
});

// Run pipeline using a pipeline ID from Studio
const result = await client.pipeline.run({
  input: upload.file_id,
  pipeline_id: "your-pipeline-id-here"
});

// Access results (structure depends on pipeline configuration)
console.log("Pipeline result:", result);

pipeline.run(params: {
  input: string | Upload;
  pipeline_id: string;
}, options?: RequestOptions): Promise<PipelineResponse>

pipeline.runJob(params: {
  input: string | Upload;
  pipeline_id: string;
  async?: ConfigV3AsyncConfig;
}, options?: RequestOptions): Promise<PipelineRunJobResponse>