/** * Task Loader Service - Centralized task loading logic * * REFACTORED: Extracted from TaskManager.loadTaskForStateUpdate() for Phase 3. * Handles loading tasks from queue (preferred) or file (fallback). * Includes retry logic for timing issues. * * @internal * @requirement REFACTOR-EXTRACT-ORCHESTRATION-SERVICES - Phase 3: Extract orchestration services */ import { type WorkflowState } from '@shadel/workflow-core'; import { TaskQueueManager } from './task-queue.js'; /** * Task loading result */ export interface TaskLoadResult { activeQueueTask: any; fileTaskData: any; validationData: any; currentState: WorkflowState; taskId: string; taskData: any; } /** * Task Loader Service * * Centralizes task loading logic with retry and fallback mechanisms. */ export declare class TaskLoaderService { private queueManager; private taskFile; constructor(queueManager: TaskQueueManager, taskFile: string); /** * Load task data for state update operation * * Handles loading task from queue (preferred) or file (fallback). * Includes retry logic for timing issues. * * @returns Object containing activeQueueTask, fileTaskData, validationData, currentState, taskId, taskData * @throws Error if no active task found */ loadTaskForStateUpdate(): Promise; }