Featured Engineering

export class WorkflowEngine {
  private queue: RedisQueue;
  private workers: WorkerPool;

  constructor(config: EngineConfig) {
    this.queue = new RedisQueue(config.redis);
    this.workers = new WorkerPool(config.maxWorkers);
  }

  async processTask(taskId: string): Promise<Result> {
    const task = await this.queue.dequeue(taskId);
    
    if (!task) {
      throw new Error('Task not found in queue');
    }

    try {
      this.metrics.recordStart(taskId);
      const worker = await this.workers.acquire();
      const result = await worker.execute(task);
      this.metrics.recordSuccess(taskId);
      
      return result;
    } catch (error) {
      this.handleFailure(task, error);
    }
  }
}