Snowflake Cortex Search to Airtable Records

arazzo: 1.0.1
info:
  title: Snowflake Cortex Search to Airtable Records
  summary: Query a Snowflake Cortex Search service, then write the matches into an Airtable table.
  description: >-
    A data and AI workflow that runs a query against a Snowflake Cortex Search service to
    retrieve semantically ranked results, then creates Airtable records from those matches
    so they can be reviewed and curated. Demonstrates pairing Snowflake's AI search with a
    collaborative no-code database.
  version: 1.0.0
sourceDescriptions:
  - name: snowflakeCortexSearchApi
    url: https://raw.githubusercontent.com/api-evangelist/snowflake/refs/heads/main/openapi/cortex-search-service.yaml
    type: openapi
  - name: airtableApi
    url: https://raw.githubusercontent.com/api-evangelist/airtable/refs/heads/main/openapi/airtable-airtable-api-openapi.yml
    type: openapi
workflows:
  - workflowId: cortex-search-to-airtable
    summary: Run a Cortex Search query, then store the matches in Airtable.
    description: >-
      Queries a Snowflake Cortex Search service and creates Airtable records from the
      ranked results for review.
    inputs:
      type: object
      properties:
        database:
          type: string
        schema:
          type: string
        serviceName:
          type: string
        query:
          type: string
        baseId:
          type: string
        tableIdOrName:
          type: string
        fields:
          type: object
    steps:
      - stepId: search
        description: Query the Snowflake Cortex Search service.
        operationId: $sourceDescriptions.snowflakeCortexSearchApi.queryCortexSearchService
        parameters:
          - name: database
            in: path
            value: $inputs.database
          - name: schema
            in: path
            value: $inputs.schema
          - name: service_name
            in: path
            value: $inputs.serviceName
        requestBody:
          contentType: application/json
          payload:
            query: $inputs.query
            limit: 10
        successCriteria:
          - condition: $statusCode == 200
        outputs:
          results: $response.body#/results
      - stepId: store-matches
        description: Create Airtable records from the search matches.
        operationId: $sourceDescriptions.airtableApi.createRecords
        parameters:
          - name: baseId
            in: path
            value: $inputs.baseId
          - name: tableIdOrName
            in: path
            value: $inputs.tableIdOrName
        requestBody:
          contentType: application/json
          payload:
            records:
              - fields: $inputs.fields
            typecast: true
        successCriteria:
          - condition: $statusCode == 200
        outputs:
          createdRecords: $response.body#/records
    outputs:
      results: $steps.search.outputs.results
      createdRecords: $steps.store-matches.outputs.createdRecords