> ## Documentation Index
> Fetch the complete documentation index at: https://docs.base39.com.br/llms.txt
> Use this file to discover all available pages before exploring further.

# Enqueue persisted dataset_queries into the dataset observation mapper flow

> Loads successful dataset_queries and enqueues the existing BullMQ dataset-query-observation Flow. The mapper worker remains the only executor of domain writes.



## OpenAPI

````yaml /api-reference/openapi.json post /v2/admin/replay-mapper
openapi: 3.1.0
info:
  title: Base39 API
  description: Base39 API
  version: 1.0.0
  contact:
    name: Base39 Team
    url: https://base39.com.br
    email: suporte@base39.com.br
  termsOfService: https://base39.com.br/termos
  license:
    name: Proprietary
    url: https://base39.com.br/termos
servers:
  - url: http://localhost:3000
    description: Local
  - url: https://api.dev.base39.cloud
    description: Development
  - url: https://api.base39.com.br
    description: Production
security:
  - OAuth2: []
tags:
  - name: pages
    description: Profiles and reports pages
  - name: pipelines
    description: Pipeline boards (kanban) of pages
  - name: blocks
    description: Blocks operations
  - name: search
    description: Search across content
  - name: targets
    description: Lookup targets via datasets
  - name: CognitoTriggers
    description: Cognito triggers
paths:
  /v2/admin/replay-mapper:
    post:
      tags:
        - admin
      summary: >-
        Enqueue persisted dataset_queries into the dataset observation mapper
        flow
      description: >-
        Loads successful dataset_queries and enqueues the existing BullMQ
        dataset-query-observation Flow. The mapper worker remains the only
        executor of domain writes.
      operationId: replay_mapper_replay
      parameters: []
      requestBody:
        required: true
        content:
          application/json:
            schema:
              $ref: '#/components/schemas/ReplayMapperInput'
      responses:
        '201':
          description: ''
          content:
            application/json:
              schema:
                $ref: '#/components/schemas/ReplayMapperOutput'
components:
  schemas:
    ReplayMapperInput:
      type: object
      properties:
        org_slug:
          type: string
          description: Organization slug that owns the dataset_queries
        dataset_query_id:
          description: Persisted dataset_query ids to replay
          type: array
          items:
            type: string
        domains:
          type: array
          description: >-
            Domains to enqueue. When omitted, the mapper resolves enabled
            domains from dataset rules.
          items:
            type: string
            enum:
              - graph
              - lawsuits
              - people
              - shareholders
        on_finish:
          description: >-
            Completion directives signalled when the enqueued Flow settles (all
            domain mappers done). Used to release a trigger.dev waitpoint token.
            Requires exactly one dataset_query_id.
          type: array
          items:
            $ref: '#/components/schemas/ReplayMapperOnFinishInput'
      required:
        - org_slug
        - dataset_query_id
    ReplayMapperOutput:
      type: object
      properties:
        results:
          type: array
          items:
            $ref: '#/components/schemas/ReplayMapperQueryResultOutput'
      required:
        - results
    ReplayMapperOnFinishInput:
      type: object
      properties:
        type:
          type: string
          enum:
            - trigger.dev
        token_id:
          type: string
          description: trigger.dev waitpoint token id to complete when the Flow settles
      required:
        - type
        - token_id
    ReplayMapperQueryResultOutput:
      type: object
      properties:
        queryId:
          type: string
        datasetSlug:
          type: string
        domainsExecuted:
          type: array
          items:
            type: string
        success:
          type: boolean
      required:
        - queryId
        - datasetSlug
        - domainsExecuted
        - success
  securitySchemes:
    OAuth2:
      type: oauth2
      flows:
        authorizationCode:
          authorizationUrl: https://id.local.base39.cloud/oauth2/authorize
          tokenUrl: https://id.local.base39.cloud/oauth2/token
          scopes:
            profile: Read user profile
            email: Read user email
            openid: OpenID authentication
      description: OAuth2 Authorization Code flow

````