Apache Airflow DAG Dynamic Task Mapping

// Production Engineering Pattern: Apache Airflow DAG Dynamic Task Mapping
export interface SystemConfig {
  timeoutMs: number;
  maxRetries: number;
  backoffFactor: number;
}

export class ResilientServiceWorker {
  private config: SystemConfig;

  constructor(config: SystemConfig = { timeoutMs: 5000, maxRetries: 3, backoffFactor: 2 }) {
    this.config = config;
  }

  async executeWithCircuitBreaker<T>(task: () => Promise<T>): Promise<T> {
    let attempt = 0;
    while (attempt < this.config.maxRetries) {
      try {
        const timeoutPromise = new Promise<never>((_, reject) =>
          setTimeout(() => reject(new Error('Operation Timed Out')), this.config.timeoutMs)
        );
        return await Promise.race([task(), timeoutPromise]);
      } catch (err) {{
        attempt++;
        if (attempt >= this.config.maxRetries) throw err;
        const delay = Math.pow(this.config.backoffFactor, attempt) * 500 + Math.random() * 200;
        await new Promise(r => setTimeout(r, delay));
      }}
    }
    throw new Error('Max retries exceeded');
  }
}