Method executeWorkflow

packages/ts-sdk/src/index.ts:201–281

* Execute a workflow with optional input data * @param workflowId - The ID of the workflow to execute * @param input - Input data to pass to the workflow (object, primitive, or array) * @param options - Execution options (timeout, stream, async, etc.)

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

   * @param options - Execution options (timeout, stream, async, etc.)
   */
  async executeWorkflow(
    workflowId: string,
    input?: any,
    options: ExecutionOptions = {}
  ): Promise<WorkflowExecutionResult | AsyncExecutionResult> {
    const url = `${this.baseUrl}/api/workflows/${workflowId}/execute`
    const { timeout = 30000, stream, selectedOutputs, async } = options

    try {
      const timeoutPromise = new Promise<never>((_, reject) => {
        setTimeout(() => reject(new Error('TIMEOUT')), timeout)
      })

      const headers: Record<string, string> = {
        'Content-Type': 'application/json',
        'X-API-Key': this.apiKey,
      }
      if (async) {
        headers['X-Execution-Mode'] = 'async'
      }

      let jsonBody: any = {}
      if (input !== undefined && input !== null) {
        if (typeof input === 'object' && input !== null && !Array.isArray(input)) {
          jsonBody = { ...input }
        } else {
          jsonBody = { input }
        }
      }

      jsonBody = await this.convertFilesToBase64(jsonBody)

      if (stream !== undefined) {
        jsonBody.stream = stream
      }
      if (selectedOutputs !== undefined) {
        jsonBody.selectedOutputs = selectedOutputs
      }

      const fetchPromise = fetch(url, {
        method: 'POST',
        headers,
        body: JSON.stringify(jsonBody),
      })

      const response = await Promise.race([fetchPromise, timeoutPromise])

      this.updateRateLimitInfo(response)

      if (response.status === 429) {
        const retryAfter = this.rateLimitInfo?.retryAfter || 1000
        throw new SimStudioError(
          `Rate limit exceeded. Retry after ${retryAfter}ms`,
          'RATE_LIMIT_EXCEEDED',
          429
        )
      }