import type OAuthTokenService from './oauth/token-service';
import type { ActivityLogPortFactory } from './ports/activity-log-port';
import type { AgentPort } from './ports/agent-port';
import type { AiModelPort } from './ports/ai-model-port';
import type { Logger } from './ports/logger-port';
import type { RunStore } from './ports/run-store';
import type { WorkflowPort } from './ports/workflow-port';
import type SchemaCache from './schema-cache';
import type { StepExecutionData } from './types/step-execution-data';
export type RunnerState = 'idle' | 'running' | 'draining' | 'stopped';
export interface RunnerConfig {
    agentPort: AgentPort;
    workflowPort: WorkflowPort;
    runStore: RunStore;
    schemaCache: SchemaCache;
    pollingIntervalS: number;
    aiModelPort: AiModelPort;
    activityLogPortFactory: ActivityLogPortFactory;
    envSecret: string;
    authSecret: string;
    logger?: Logger;
    stopTimeoutS?: number;
    stepTimeoutS?: number;
    aiInvokeTimeoutS?: number;
    maxChainDepth?: number;
    mcpOAuthTokenService: OAuthTokenService;
}
export default class Runner {
    private readonly config;
    private pollingTimer;
    private pollCycle;
    private readonly inFlightRuns;
    private readonly logger;
    private readonly remoteToolFetcher;
    private _state;
    constructor(config: RunnerConfig);
    get state(): RunnerState;
    start(): Promise<void>;
    stop(): Promise<void>;
    getRunStepExecutions(runId: string): Promise<StepExecutionData[]>;
    triggerPoll(runId: string, options?: {
        pendingData?: unknown;
        bearerUserId?: number;
    }): Promise<void>;
    private dispatchDetached;
    private assertRunNotInFlight;
    private schedulePoll;
    private runPollCycle;
    private reportMalformedRun;
    private executeStep;
    private doExecuteStep;
    private handBack;
    private get contextConfig();
    private static getPollingLogLevel;
    private pushMetadataToOrchestrator;
}
//# sourceMappingURL=runner.d.ts.map