Method executeWithRetry

packages/ts-sdk/src/index.ts:402–447

* Execute workflow with automatic retry on rate limit * @param workflowId - The ID of the workflow to execute * @param input - Input data to pass to the workflow * @param options - Execution options (timeout, stream, async, etc.) * @param retryOptions - Retry configuration (maxRetries, d

(
    workflowId: string,
    input?: any,
    options: ExecutionOptions = {},
    retryOptions: RetryOptions = {}
  )

   * @param retryOptions - Retry configuration (maxRetries, delays, etc.)
   */
  async executeWithRetry(
    workflowId: string,
    input?: any,
    options: ExecutionOptions = {},
    retryOptions: RetryOptions = {}
  ): Promise<WorkflowExecutionResult | AsyncExecutionResult> {
    const {
      maxRetries = 3,
      initialDelay = 1000,
      maxDelay = 30000,
      backoffMultiplier = 2,
    } = retryOptions

    let lastError: SimStudioError | null = null
    let delay = initialDelay

    for (let attempt = 0; attempt <= maxRetries; attempt++) {
      try {
        return await this.executeWorkflow(workflowId, input, options)
      } catch (error: any) {
        if (!(error instanceof SimStudioError) || error.code !== 'RATE_LIMIT_EXCEEDED') {
          throw error
        }

        lastError = error

        if (attempt === maxRetries) {
          break
        }

        const waitTime =
          error.status === 429 && this.rateLimitInfo?.retryAfter
            ? this.rateLimitInfo.retryAfter
            : Math.min(delay, maxDelay)

        // standalone package — cannot depend on @sim/utils
        const jitter = waitTime * (0.75 + Math.random() * 0.5)

        await new Promise((resolve) => setTimeout(resolve, jitter))

        delay *= backoffMultiplier
      }
    }

    throw lastError || new SimStudioError('Max retries exceeded', 'MAX_RETRIES_EXCEEDED')
  }

  /**
   * Get current rate limit information