openapi: 3.2.0 info: title: Boomi Data Integration Activities API description: '# Boomi Data Integration API documentation Welcome to the Boomi Data Integration API Documentation.' contact: name: Boomi Data Integration Documentation url: https://community.boomi.com/s/support email: support@boomi.com version: 1.0.0 x-logo: url: https://rivery.io/wp-content/uploads/2021/08/logo.png servers: - url: https://api.rivery.io description: US - url: https://api.eu-west-1.rivery.io description: EU tags: - name: Activities description: Get the Boomi Data Integration activities data with various of GET operations paths: /v1/accounts/{account_id}/environments/{environment_id}/activities_statistics: get: tags: - Activities summary: Get Activities Statistic description: '**Authorization scope:** `activity:list` **Get environment''s activity statistics.** **** **The statistics include how many units(RPU) were consumed, and how** **many runs ended with each status.**' operationId: get_activities_statistic security: - HTTPBearer: [] parameters: - name: account_id in: path required: true schema: type: string title: Account Id - name: environment_id in: path required: true schema: type: string title: Environment Id - name: start_time in: query required: true schema: type: string format: date-time description: The start UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm examples: - '2020-01-01T12:00:00' title: Start Time description: The start UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm - name: end_time in: query required: true schema: type: string format: date-time description: The end UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm examples: - '2020-01-01T12:00:00' title: End Time description: The end UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm - name: status in: query required: false schema: anyOf: - type: array items: $ref: '#/components/schemas/ActivityStatusEnum' - type: 'null' description: A list of statuses to filter title: Status description: A list of statuses to filter - name: group_id in: query required: false schema: anyOf: - type: array items: type: string - type: 'null' description: The ID of the group to filter title: Group Id description: The ID of the group to filter - name: is_scheduled in: query required: false schema: allOf: - $ref: '#/components/schemas/ScheduleEnum' description: A flag that indicates whether the river is scheduled. If not set then activities of all rivers will be returned title: Is Scheduled description: A flag that indicates whether the river is scheduled. If not set then activities of all rivers will be returned - name: search in: query required: false schema: type: string description: Get statistics for rivers that has the search query in their name title: Search description: Get statistics for rivers that has the search query in their name - name: river_type in: query required: false schema: anyOf: - type: array items: anyOf: - $ref: '#/components/schemas/RiverTypeInternalEnum' - $ref: '#/components/schemas/RiverTypeEnum' - type: 'null' description: The river type title: River Type description: The river type responses: '200': description: Successful Response content: application/json: schema: $ref: '#/components/schemas/ActivityStatisticResponse' '422': description: Validation Error content: application/json: schema: $ref: '#/components/schemas/HTTPValidationError' /v1/accounts/{account_id}/environments/{environment_id}/rivers/{river_cross_id}/activities_statistics: get: tags: - Activities summary: Get Data Flow Activities Statistic description: '**Authorization scope:** `activity:list` **Get data flow''s activity statistics (summary).** **** **The statistics include how many units(RPU) were consumed, and how** **many runs ended with each status**' operationId: get_river_activities_statistic security: - HTTPBearer: [] parameters: - name: account_id in: path required: true schema: type: string title: Account Id - name: environment_id in: path required: true schema: type: string title: Environment Id - name: river_cross_id in: path required: true schema: type: string title: River Cross Id - name: start_time in: query required: true schema: type: string format: date-time description: The start UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm examples: - '2020-01-01T12:00:00' title: Start Time description: The start UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm - name: end_time in: query required: true schema: type: string format: date-time description: The end UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm examples: - '2020-01-01T12:00:00' title: End Time description: The end UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm - name: status in: query required: false schema: anyOf: - type: array items: $ref: '#/components/schemas/ActivityStatusEnum' - type: 'null' title: Status responses: '200': description: Successful Response content: application/json: schema: $ref: '#/components/schemas/RiverActivityStatisticResponse' '422': description: Validation Error content: application/json: schema: $ref: '#/components/schemas/HTTPValidationError' /v1/accounts/{account_id}/environments/{environment_id}/rivers/{river_cross_id}/activities_targets: get: tags: - Activities summary: Get Data Flow Activities Targets description: '**Authorization scope:** `activity:list` **Get data flow''s activity targets (table names) in a specific time frame for** **specific data flow and their status.** **** **This endpoint should be used for multi table data flows.**' operationId: get_river_activities_targets security: - HTTPBearer: [] parameters: - name: account_id in: path required: true schema: type: string title: Account Id - name: environment_id in: path required: true schema: type: string title: Environment Id - name: river_cross_id in: path required: true schema: type: string title: River Cross Id - name: start_time in: query required: true schema: type: string format: date-time description: The start UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm examples: - '2020-01-01T12:00:00' title: Start Time description: The start UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm - name: end_time in: query required: true schema: type: string format: date-time description: The end UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm examples: - '2020-01-01T12:00:00' title: End Time description: The end UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm - name: run_group_id in: query required: false schema: anyOf: - type: string - type: 'null' description: Filter by the run group ID title: Run Group Id description: Filter by the run group ID - name: sub_river_id in: query required: false schema: anyOf: - type: string - type: 'null' description: Filter by the sub river ID title: Sub River Id description: Filter by the sub river ID - name: status in: query required: false schema: anyOf: - type: array items: $ref: '#/components/schemas/ActivityStatusEnum' - type: 'null' description: A list of statuses. Only targets with those statuses will be returned title: Status description: A list of statuses. Only targets with those statuses will be returned - name: sort_by in: query required: false schema: allOf: - $ref: '#/components/schemas/TargetsSortByEnum' description: Indicates by which parameter to sort the targets default: last_run title: Sort By description: Indicates by which parameter to sort the targets - name: sort_order in: query required: false schema: allOf: - $ref: '#/components/schemas/SortOrderEnum' default: desc title: Sort Order responses: '200': description: Successful Response content: application/json: schema: $ref: '#/components/schemas/RiverActivityTargetResponse' '422': description: Validation Error content: application/json: schema: $ref: '#/components/schemas/HTTPValidationError' /v1/accounts/{account_id}/environments/{environment_id}/rivers/{river_cross_id}/activities_run_groups: get: tags: - Activities summary: List Data Flow Activities Run Groups description: '**Authorization scope:** `activity:list` **Get list of run groups that occurred in a specific time** **frame for specific data flow and their status.**' operationId: list_river_activities_run_groups security: - HTTPBearer: [] parameters: - name: account_id in: path required: true schema: type: string title: Account Id - name: environment_id in: path required: true schema: type: string title: Environment Id - name: river_cross_id in: path required: true schema: type: string title: River Cross Id - name: start_time in: query required: true schema: type: string format: date-time description: The start UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm examples: - '2020-01-01T12:00:00' title: Start Time description: The start UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm - name: end_time in: query required: true schema: type: string format: date-time description: The end UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm examples: - '2020-01-01T12:00:00' title: End Time description: The end UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm - name: target_name in: query required: false schema: anyOf: - type: string - type: 'null' description: Filter by the target table name title: Target Name description: Filter by the target table name - name: sub_river_id in: query required: false schema: anyOf: - type: string - type: 'null' description: Filter by the sub river ID title: Sub River Id description: Filter by the sub river ID - name: status in: query required: false schema: type: array items: $ref: '#/components/schemas/RunGroupStatusEnum' description: A list of statuses. Only run groups with this statuses will be returned. title: Status description: A list of statuses. Only run groups with this statuses will be returned. - name: cache_context_id in: query required: false schema: type: string description: Cache context id is an internal query parameter for cache purposes title: Cache Context Id description: Cache context id is an internal query parameter for cache purposes - name: page in: query required: false schema: type: integer minimum: 1 default: 1 title: Page - name: sort_by in: query required: false schema: allOf: - $ref: '#/components/schemas/RunGroupSortByEnum' default: last_run title: Sort By - name: sort_order in: query required: false schema: allOf: - $ref: '#/components/schemas/SortOrderEnum' default: desc title: Sort Order - name: items_per_page in: query required: false schema: type: integer maximum: 200 minimum: 1 default: 50 title: Items Per Page responses: '200': description: Successful Response content: application/json: schema: $ref: '#/components/schemas/RiverActivityRunGroupResponse' '422': description: Validation Error content: application/json: schema: $ref: '#/components/schemas/HTTPValidationError' /v1/accounts/{account_id}/environments/{environment_id}/rivers/{river_cross_id}/activities_run_groups/{run_group_id}: get: tags: - Activities summary: Get Data Flow Activities Run Groups description: Get a specific run group id operationId: get_river_activities_run_groups parameters: - name: account_id in: path required: true schema: type: string title: Account Id - name: environment_id in: path required: true schema: type: string title: Environment Id - name: river_cross_id in: path required: true schema: type: string title: River Cross Id - name: run_group_id in: path required: true schema: type: string title: Run Group Id responses: '200': description: Successful Response content: application/json: schema: $ref: '#/components/schemas/RiverActivityRunGroupWithStatistics' '422': description: Validation Error content: application/json: schema: $ref: '#/components/schemas/HTTPValidationError' /v1/accounts/{account_id}/environments/{environment_id}/rivers/{river_cross_id}/activities_sub_rivers: get: tags: - Activities summary: Get Data Flow Activities Sub Data Flows description: '**Authorization scope:** `activity:list` **Get list of sub data flows that ran in a specific time frame.** **** **Additional filters can be added such as target name or run group id.**' operationId: get_river_activities_sub_rivers security: - HTTPBearer: [] parameters: - name: account_id in: path required: true schema: type: string title: Account Id - name: environment_id in: path required: true schema: type: string title: Environment Id - name: river_cross_id in: path required: true schema: type: string title: River Cross Id - name: start_time in: query required: true schema: type: string format: date-time description: The start UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm examples: - '2020-01-01T12:00:00' title: Start Time description: The start UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm - name: end_time in: query required: true schema: type: string format: date-time description: The end UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm examples: - '2020-01-01T12:00:00' title: End Time description: The end UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm - name: target_name in: query required: false schema: type: string description: Filter by the target table name title: Target Name description: Filter by the target table name - name: run_group_id in: query required: false schema: type: string description: Filter by the run group ID title: Run Group Id description: Filter by the run group ID responses: '200': description: Successful Response content: application/json: schema: $ref: '#/components/schemas/RiverActivitySubRiverResponse' '422': description: Validation Error content: application/json: schema: $ref: '#/components/schemas/HTTPValidationError' /v1/accounts/{account_id}/environments/{environment_id}/rivers/{river_cross_id}/runs: get: tags: - Activities summary: Get Data Flow Activities Runs description: '**Authorization scope:** `activity:list` **Get list of runs for a specific data flow in a specific time frame.** **** **This endpoint return information about the runs.** --- ### 📖 Instructions for usage `list_runs` ``` List data runs for a data flow within a time range. start_time and end_time must be ISO 8601 format, e.g. "2026-05-25T00:00:00". Each item includes run_id, status, start_date_utc, end_date_utc, error_description. ```' operationId: list_river_activities_runs security: - HTTPBearer: [] parameters: - name: account_id in: path required: true schema: type: string title: Account Id - name: environment_id in: path required: true schema: type: string title: Environment Id - name: river_cross_id in: path required: true schema: type: string title: River Cross Id - name: start_time in: query required: true schema: type: string format: date-time description: The start UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm examples: - '2020-01-01T12:00:00' title: Start Time description: The start UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm - name: end_time in: query required: true schema: type: string format: date-time description: The end UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm examples: - '2020-01-01T12:00:00' title: End Time description: The end UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm - name: target_name in: query required: false schema: anyOf: - type: string - type: 'null' description: Filter by the target table name title: Target Name description: Filter by the target table name - name: run_group_id in: query required: false schema: anyOf: - type: string - type: 'null' description: Filter by the run group ID title: Run Group Id description: Filter by the run group ID - name: sub_river_id in: query required: false schema: anyOf: - type: string - type: 'null' description: Filter by the sub river ID title: Sub River Id description: Filter by the sub river ID - name: page in: query required: false schema: type: integer minimum: 1 default: 1 title: Page - name: items_per_page in: query required: false schema: type: integer maximum: 200 minimum: 1 default: 20 title: Items Per Page - name: sort_by in: query required: false schema: allOf: - $ref: '#/components/schemas/RunsSortByEnum' description: Indicates by which parameter to sort the runs default: start_time title: Sort By description: Indicates by which parameter to sort the runs - name: sort_order in: query required: false schema: allOf: - $ref: '#/components/schemas/SortOrderEnum' default: desc title: Sort Order - name: cache_context_id in: query required: false schema: type: string description: Cache context id is an internal query parameter for cache purposes title: Cache Context Id description: Cache context id is an internal query parameter for cache purposes responses: '200': description: Successful Response content: application/json: schema: $ref: '#/components/schemas/RiverActivityRunsResponse' '422': description: Validation Error content: application/json: schema: $ref: '#/components/schemas/HTTPValidationError' x-mcp-tool: - list_runs /v1/accounts/{account_id}/environments/{environment_id}/rivers/{river_cross_id}/runs/{run_id}: get: tags: - Activities summary: Get Data Flow Activities Run description: '**Authorization scope:** `activity:list` **Get a specific run details.** --- ### 📖 Instructions for usage `run_data_flow`, `get_run` **`run_data_flow`** ``` Trigger an immediate run of a data flow. By default returns instantly with the run_id (do NOT poll). Set wait=True to block until the run reaches a terminal state (success/failed/cancelled) and return the final run object — useful for tests/automation so you don''t sleep blindly. Before calling this, make sure ALL source tables are configured in a single set_data_flow_source_tables call — one data flow syncs multiple tables in one run. Common 400 causes: - Data flow not yet activated: call activate_data_flow(wait=True) first. - No source tables configured: call set_data_flow_source_tables first. ``` **`get_run`** ``` Get the status and result of a data flow run by its run_id. Use the run_group_id returned by run_data_flow as the run_id here. Status is returned as a plain string: pending, running, success, failed. Check error_description for failure details. ```' operationId: get_river_activities_run security: - HTTPBearer: [] parameters: - name: account_id in: path required: true schema: type: string title: Account Id - name: environment_id in: path required: true schema: type: string title: Environment Id - name: river_cross_id in: path required: true schema: type: string title: River Cross Id - name: run_id in: path required: true schema: type: string title: Run Id responses: '200': description: Successful Response content: application/json: schema: $ref: '#/components/schemas/RiverActivityRun' '422': description: Validation Error content: application/json: schema: $ref: '#/components/schemas/HTTPValidationError' x-mcp-tool: - run_data_flow - get_run /v1/accounts/{account_id}/environments/{environment_id}/rivers/{river_cross_id}/runs/{run_id}/tasks: get: tags: - Activities summary: Get Data Flow Activities Run Tasks description: '**Authorization scope:** `activity:list` **Get data flow''s activity specific run tasks.** **** **Each run may have multiple tasks. This endpoint returns those tasks** **details.**' operationId: get_river_activities_run_tasks security: - HTTPBearer: [] parameters: - name: account_id in: path required: true schema: type: string title: Account Id - name: environment_id in: path required: true schema: type: string title: Environment Id - name: river_cross_id in: path required: true schema: type: string title: River Cross Id - name: run_id in: path required: true schema: type: string title: Run Id responses: '200': description: Successful Response content: application/json: schema: $ref: '#/components/schemas/RiverActivityRunTasksResponse' '422': description: Validation Error content: application/json: schema: $ref: '#/components/schemas/HTTPValidationError' /v1/accounts/{account_id}/environments/{environment_id}/rivers/{river_cross_id}/runs/{run_id}/logic_steps: get: tags: - Activities summary: Get Data Flow Activities Run Logic Steps description: '**Authorization scope:** `activity:list` **Get the status of each logic step for a specific run.**' operationId: get_river_activities_run_logic_steps security: - HTTPBearer: [] parameters: - name: account_id in: path required: true schema: type: string title: Account Id - name: environment_id in: path required: true schema: type: string title: Environment Id - name: river_cross_id in: path required: true schema: type: string title: River Cross Id - name: run_id in: path required: true schema: type: string title: Run Id responses: '200': description: Successful Response content: application/json: schema: $ref: '#/components/schemas/RiverActivityRunLogicStepsResponse' '422': description: Validation Error content: application/json: schema: $ref: '#/components/schemas/HTTPValidationError' /v1/accounts/{account_id}/environments/{environment_id}/rivers/{river_cross_id}/runs/{run_id}/variables: get: tags: - Activities summary: Get Activities Logic Variables description: '**Authorization scope:** `activity:list` **This endpoint retrieves the values of the logic variables in a specific run.** **The values are stored for a short period of time and will expire after that time.** **If the values have expired, an error message will be returned.**' operationId: get_activities_logic_variables security: - HTTPBearer: [] parameters: - name: account_id in: path required: true schema: type: string title: Account Id - name: environment_id in: path required: true schema: type: string title: Environment Id - name: river_cross_id in: path required: true schema: type: string title: River Cross Id - name: run_id in: path required: true schema: type: string title: Run Id responses: '200': description: Successful Response content: application/json: schema: $ref: '#/components/schemas/ActivityLogicVariableResponse' '422': description: Validation Error content: application/json: schema: $ref: '#/components/schemas/HTTPValidationError' /v1/accounts/{account_id}/environments/{environment_id}/rivers/{river_cross_id}/runs/{run_id}/logic_steps/{step_id}/logs: get: tags: - Activities summary: Get Activities Logic Step Log description: '**Authorization scope:** `activity:list` **Get the logs of a python logic step.**' operationId: get_activities_logic_step_log security: - HTTPBearer: [] parameters: - name: account_id in: path required: true schema: type: string title: Account Id - name: environment_id in: path required: true schema: type: string title: Environment Id - name: river_cross_id in: path required: true schema: type: string title: River Cross Id - name: run_id in: path required: true schema: type: string title: Run Id - name: step_id in: path required: true schema: type: string title: Step Id - name: iteration_number in: query required: false schema: type: integer minimum: 0 description: The step iteration number default: 0 title: Iteration Number description: The step iteration number responses: '200': description: Successful Response content: application/json: schema: $ref: '#/components/schemas/RiverActivityRunLogicStepsLogsResponse' '422': description: Validation Error content: application/json: schema: $ref: '#/components/schemas/HTTPValidationError' /v1/accounts/{account_id}/environments/{environment_id}/activities: get: tags: - Activities summary: Get Activities description: '**Authorization scope:** `activity:list` **Get summary of activities for the account and environment summarized by** **data flow.**' operationId: get_activities security: - HTTPBearer: [] parameters: - name: account_id in: path required: true schema: type: string title: Account Id - name: environment_id in: path required: true schema: type: string title: Environment Id - name: start_time in: query required: true schema: type: string format: date-time description: The start UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm examples: - '2020-01-01T12:00:00' title: Start Time description: The start UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm - name: end_time in: query required: true schema: type: string format: date-time description: The end UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm examples: - '2020-01-01T12:00:00' title: End Time description: The end UTC date time. Time format YYYY-MM-DDTHH:MM:SS or YYYY-MM-DDTHH:MM:SS.mmmmmm - name: status in: query required: false schema: anyOf: - type: array items: $ref: '#/components/schemas/ActivityStatusEnum' - type: 'null' title: Status - name: group_id in: query required: false schema: anyOf: - type: array items: type: string - type: 'null' description: The ID of the group to filter title: Group Id description: The ID of the group to filter - name: is_scheduled in: query required: false schema: allOf: - $ref: '#/components/schemas/ScheduleEnum' description: A flag that indicates whether the river is scheduled. If not set then activities of all rivers will be returned title: Is Scheduled description: A flag that indicates whether the river is scheduled. If not set then activities of all rivers will be returned - name: page in: query required: false schema: type: integer minimum: 1 default: 1 title: Page - name: items_per_page in: query required: false schema: type: integer maximum: 200 minimum: 1 default: 20 title: Items Per Page - name: cache_context_id in: query required: false schema: anyOf: - type: string - type: 'null' description: Cache context id is an internal query parameter for cache purposes title: Cache Context Id description: Cache context id is an internal query parameter for cache purposes - name: search in: query required: false schema: type: string description: Search for a specific river by river name title: Search description: Search for a specific river by river name - name: sort_by in: query required: false schema: allOf: - $ref: '#/components/schemas/ActivitySortByEnum' default: last_run title: Sort By - name: sort_order in: query required: false schema: allOf: - $ref: '#/components/schemas/SortOrderEnum' default: desc title: Sort Order - name: river_type in: query required: false schema: anyOf: - type: array items: anyOf: - $ref: '#/components/schemas/RiverTypeInternalEnum' - $ref: '#/components/schemas/RiverTypeEnum' - type: 'null' description: The river type title: River Type description: The river type responses: '200': description: Successful Response content: application/json: schema: $ref: '#/components/schemas/ActivitiesResponse' '422': description: Validation Error content: application/json: schema: $ref: '#/components/schemas/HTTPValidationError' /v1/accounts/{account_id}/environments/{environment_id}/rivers/{river_cross_id}/runs/{run_id}/logs: get: tags: - Activities summary: Get Run Logs description: '**Authorization scope:** `activity:list` **This method fetches the logs for a given run id of a data flow.** --- ### 📖 Instructions for usage `get_run_logs` ``` Download the logs for a specific data flow run as CSV text. Returns raw CSV content with all log lines for the run. Logs are only available for runs within the last 2 weeks. If the response is empty, the data source may not support logs. Use get_run first to confirm the run exists, then call this to fetch its logs. ```' operationId: get_run_logs security: - HTTPBearer: [] parameters: - name: account_id in: path required: true schema: type: string title: Account Id - name: environment_id in: path required: true schema: type: string title: Environment Id - name: river_cross_id in: path required: true schema: type: string title: River Cross Id - name: run_id in: path required: true schema: type: string title: Run Id - name: additional_services in: query required: false schema: anyOf: - type: array items: $ref: '#/components/schemas/NewRelicServicesEnum' - type: 'null' description: Additional services to query title: Additional Services description: Additional services to query responses: '200': description: Successful Response content: text/html: schema: type: string '422': description: Validation Error content: application/json: schema: $ref: '#/components/schemas/HTTPValidationError' x-mcp-tool: - get_run_logs components: schemas: RiverActivitySubRiver: properties: sub_river_id: type: string title: Sub River Id sub_river_name: type: string title: Sub River Name type: object required: - sub_river_id - sub_river_name title: RiverActivitySubRiver description: Activity's sub river RiverActivityRunGroupResponse: properties: next_page: anyOf: - type: string - type: 'null' title: Next Page description: The next page URL previous_page: anyOf: - type: string - type: 'null' title: Previous Page description: The previous page URL page: type: integer title: Page description: The page number default: 1 current_page_size: type: integer title: Current Page Size description: The current page size total_items: type: integer title: Total Items description: The total number of entities fetched default: 0 account_id: type: string title: Account Id description: The account id environment_id: type: string title: Environment Id description: The environment id items: items: $ref: '#/components/schemas/RiverActivityRunGroup' type: array title: Items river_cross_id: type: string title: River Cross Id type: object required: - current_page_size - account_id - environment_id - items - river_cross_id title: RiverActivityRunGroupResponse description: The response for the activity run groups ActivityStatusEnum: type: string enum: - pending - canceled - succeeded - failed - running - skipped title: ActivityStatusEnum description: The external status of a run (being used in the api) ValidationError: properties: loc: items: anyOf: - type: string - type: integer type: array title: Location msg: type: string title: Message type: type: string title: Error Type type: object required: - loc - msg - type title: ValidationError ActivitiesResponse: properties: next_page: anyOf: - type: string - type: 'null' title: Next Page description: The next page URL previous_page: anyOf: - type: string - type: 'null' title: Previous Page description: The previous page URL page: type: integer title: Page description: The page number default: 1 current_page_size: type: integer title: Current Page Size description: The current page size total_items: type: integer title: Total Items description: The total number of entities fetched default: 0 account_id: type: string title: Account Id description: The account id environment_id: type: string title: Environment Id description: The environment id items: items: $ref: '#/components/schemas/Activity' type: array title: Items cache_context_id: anyOf: - type: string - type: 'null' title: Cache Context Id type: object required: - current_page_size - account_id - environment_id - items - cache_context_id title: ActivitiesResponse description: General activities response TriggerName: type: string enum: - ui - api - scheduled - rescheduled - logic title: TriggerName description: The mechanism that started a river run InputParameters: properties: name: type: string title: Name value: anyOf: - type: string - type: string format: date-time - type: number - type: integer title: Value type: object required: - name - value title: InputParameters description: Input params of activity RiverActivityRun: properties: run_id: type: string title: Run Id description: The run ID examples: - 5658a1c9ea724ee59f048cbb5a6f734a river_cross_id: type: string title: River Cross Id description: The river cross ID examples: - 507f191e810c19729de860ea datasource_id: type: string title: Datasource Id description: The datasource ID examples: - mysql error_description: anyOf: - type: string - type: 'null' title: Error Description description: The error description if any examples: - error units: type: number title: Units description: Total RPU (units) examples: - 2.1 rpu: type: number title: Rpu description: Total RPU examples: - 2.1 run_group_id: type: string title: Run Group Id description: The run group id examples: - 201dcf8182ad4a59868cb41b957fdc8d status: $ref: '#/components/schemas/ActivityStatusEnum' source_name: type: string title: Source Name description: The name of the source examples: - mysql target_name: anyOf: - type: string - type: 'null' title: Target Name description: The target table name examples: - table start_date_utc: type: string format: date-time title: Start Date Utc description: The start date time in UTC timezone.Time format YYYY-MM-DDThh:mm:ss.ms examples: - '2022-07-25T18:38:55.640Z' start_date_in_milliseconds: type: integer title: Start Date In Milliseconds description: The start epoch in milliseconds. examples: - 1658774335000 end_date_utc: anyOf: - type: string format: date-time - type: 'null' title: End Date Utc description: The end date time in UTC timezone.Time format YYYY-MM-DDThh:mm:ss.ms examples: - '2022-07-25T18:38:55.640Z' end_date_in_milliseconds: anyOf: - type: integer - type: 'null' title: End Date In Milliseconds description: The end epoch in milliseconds. examples: - 1658774335000 sub_river_id: anyOf: - type: string - type: 'null' title: Sub River Id description: The sub river id examples: - 507f191e810c19729de860ea is_sub_river_run: type: boolean title: Is Sub River Run description: A flag that indicates whether this run is of a sub river or not examples: - false is_high_frequency: anyOf: - type: boolean - type: 'null' title: Is High Frequency description: A flag that indicates whether this run is high frequency or not default: false examples: - false - true pricing_category: anyOf: - type: string - type: 'null' title: Pricing Category description: The RPU policy rule object for calculating an RPU trigger_name: anyOf: - $ref: '#/components/schemas/TriggerName' - type: 'null' description: The mechanism that started the run. Empty for runs of an account that does not track triggers examples: - ui triggered_by_run_id: anyOf: - type: string - type: 'null' title: Triggered By Run Id description: The run that triggered this one. Empty when the run is the root of its tree examples: - 5658a1c9ea724ee59f048cbb5a6f734a trigger_chain: anyOf: - $ref: '#/components/schemas/TriggerChain' - type: 'null' description: The trigger events leading back to the act that started the whole run tree, oldest first examples: - - trigger_name: scheduled - run_id: R1 trigger_name: logic type: object required: - run_id - river_cross_id - datasource_id - error_description - units - rpu - run_group_id - status - source_name - start_date_utc - start_date_in_milliseconds - end_date_utc - end_date_in_milliseconds - is_sub_river_run title: RiverActivityRun description: A run RiverActivitySubRiverResponse: properties: items: items: $ref: '#/components/schemas/RiverActivitySubRiver' type: array title: Items account_id: type: string title: Account Id environment_id: type: string title: Environment Id river_cross_id: type: string title: River Cross Id type: object required: - items - account_id - environment_id - river_cross_id title: RiverActivitySubRiverResponse description: The response of the sub river RiverTypeEnum: type: string enum: - source_to_target - actions - logic - connector_executor title: RiverTypeEnum description: All of the EXTERNAL river types RiverActivityRunGroupWithStatistics: properties: run_group_id: type: string title: Run Group Id description: The run group id examples: - 201dcf8182ad4a59868cb41b957fdc8d status: type: string title: Status units: anyOf: - type: number - type: 'null' title: Units description: Total RPU (units) examples: - 2.1 rpu: anyOf: - type: number - type: 'null' title: Rpu description: Total RPU examples: - 2.1 max_duration_in_milliseconds: anyOf: - type: integer - type: 'null' title: Max Duration In Milliseconds run_date_epoch_milliseconds: type: integer title: Run Date Epoch Milliseconds run_date_utc: type: string format: date-time title: Run Date Utc run_end_date_epoch_milliseconds: anyOf: - type: integer - type: 'null' title: Run End Date Epoch Milliseconds description: The end epoch in milliseconds. examples: - 1658774335000 run_end_date_utc: anyOf: - type: string format: date-time - type: 'null' title: Run End Date Utc description: The end date time in UTC timezone.Time format YYYY-MM-DDThh:mm:ss.ms examples: - '2022-07-25T18:38:55.640Z' trigger_name: anyOf: - $ref: '#/components/schemas/TriggerName' - type: 'null' description: The mechanism that started the run. Empty for runs of an account that does not track triggers examples: - ui trigger_chain: anyOf: - $ref: '#/components/schemas/TriggerChain' - type: 'null' description: The trigger events leading back to the act that started the whole run tree, oldest first examples: - - trigger_name: scheduled - run_id: R1 trigger_name: logic running: type: integer title: Running canceled: type: integer title: Canceled pending: type: integer title: Pending failed: type: integer title: Failed succeeded: type: integer title: Succeeded skipped: type: integer title: Skipped type: object required: - run_group_id - status - units - rpu - run_date_epoch_milliseconds - run_date_utc - run_end_date_epoch_milliseconds - run_end_date_utc - running - canceled - pending - failed - succeeded - skipped title: RiverActivityRunGroupWithStatistics description: The run group details with statistics Activity: properties: account_id: type: string title: Account Id environment_id: type: string title: Environment Id cross_id: type: string title: Cross Id river_id: type: string title: River Id master_river_id: type: string title: Master River Id river_name: type: string title: River Name is_sub_river: type: boolean title: Is Sub River is_master_river: type: boolean title: Is Master River is_multi: type: boolean title: Is Multi is_deleted: type: boolean title: Is Deleted group_id: anyOf: - type: string - type: 'null' title: Group Id is_scheduled: type: boolean title: Is Scheduled total_files: type: integer title: Total Files units: type: number title: Units description: Total RPU (units) examples: - 2.1 rpu: type: number title: Rpu description: Total RPU examples: - 2.1 total_size: type: integer title: Total Size last_run: type: integer title: Last Run pending: type: integer title: Pending failed: type: integer title: Failed running: type: integer title: Running succeeded: type: integer title: Succeeded canceled: type: integer title: Canceled datasource_id: type: string title: Datasource Id type: object required: - account_id - environment_id - cross_id - river_id - master_river_id - river_name - is_sub_river - is_master_river - is_multi - is_deleted - is_scheduled - total_files - units - rpu - total_size - last_run - pending - failed - running - succeeded - canceled - datasource_id title: Activity description: Activity properties to return. RiverVariablesFields: properties: account: type: string title: Account description: The account of the river examples: - 55fr7d4270fdca16cac18261 env_id: type: string title: Env Id description: The environment of the river examples: - 55fr7d4270fdca16cac18261 river_id: type: string title: River Id description: The ID of the river examples: - 55fr7d4270fdca16cac18261 name: type: string title: Name description: The name of the variable examples: - credentials settings: type: object title: Settings description: variable settings examples: - clear_value_on_start: true is_encrypted: false is_multi_value: false is_private: false value: anyOf: - type: string - items: {} type: array - type: 'null' title: Value description: value of variable examples: - '1234' type: object required: - account - env_id - river_id - name - settings title: RiverVariablesFields description: "River variable properties to return.\n " SourceToTargetTaskProperties: properties: duration: type: integer title: Duration description: The duration of the task in milliseconds examples: - 2000 error_description: anyOf: - type: string - type: 'null' title: Error Description description: The error description if any examples: - error start_date_utc: type: string format: date-time title: Start Date Utc description: The start date time in UTC timezone.Time format YYYY-MM-DDThh:mm:ss.ms examples: - '2022-07-25T18:38:55.640Z' start_date_in_milliseconds: type: integer title: Start Date In Milliseconds description: The start epoch in milliseconds. examples: - 1658774335000 end_date_utc: anyOf: - type: string format: date-time - type: 'null' title: End Date Utc description: The end date time in UTC timezone.Time format YYYY-MM-DDThh:mm:ss.ms examples: - '2022-07-25T18:38:55.640Z' end_date_in_milliseconds: anyOf: - type: integer - type: 'null' title: End Date In Milliseconds description: The end epoch in milliseconds. examples: - 1658774335000 source: anyOf: - type: string - type: 'null' title: Source description: The name of the source. examples: - Google Ads task_id: type: string title: Task Id description: The ID of the task examples: - 6a23130732304020886bf5f8bfcecfbc task_name: type: string title: Task Name description: The name of the task examples: - Google Ads To Amazon S3 task_status: allOf: - $ref: '#/components/schemas/ActivityStatusEnum' description: The status of the task examples: - succeeded task_type: const: source_to_target title: Task Type input_parameters: anyOf: - items: $ref: '#/components/schemas/InputParameters' type: array - type: 'null' title: Input Parameters description: A list of input parameters target: anyOf: - type: string - type: 'null' title: Target description: The name of the target examples: - Snowflake target_table: anyOf: - type: string - type: 'null' title: Target Table description: The name of target table (if exist in the task) examples: - table size: anyOf: - type: number - type: 'null' title: Size description: Total transferred size in bytes examples: - 2048.3 size_formatted: anyOf: - $ref: '#/components/schemas/SizeFormatted' - type: 'null' description: Total transferred size with units target_records_loaded: anyOf: - type: integer - type: 'null' title: Target Records Loaded description: Target loaded record type: object required: - duration - error_description - start_date_utc - start_date_in_milliseconds - end_date_utc - end_date_in_milliseconds - task_id - task_name - task_status - task_type title: SourceToTargetTaskProperties description: SourceToTarget properties ActivitySortByEnum: type: string enum: - river_name - last_run - units title: ActivitySortByEnum description: Activities sort properties in the UI. TriggerChain: items: $ref: '#/components/schemas/TriggerEvent' type: array title: TriggerChain description: 'The trigger events leading back to the act that started the whole run tree, oldest first. Serializes as a bare list. Whoever triggers a run appends its own event and ships the whole chain, so every run''s row is self contained and the tree reconstructs without joins.' LogicTaskProperties: properties: duration: type: integer title: Duration description: The duration of the task in milliseconds examples: - 2000 error_description: anyOf: - type: string - type: 'null' title: Error Description description: The error description if any examples: - error start_date_utc: type: string format: date-time title: Start Date Utc description: The start date time in UTC timezone.Time format YYYY-MM-DDThh:mm:ss.ms examples: - '2022-07-25T18:38:55.640Z' start_date_in_milliseconds: type: integer title: Start Date In Milliseconds description: The start epoch in milliseconds. examples: - 1658774335000 end_date_utc: anyOf: - type: string format: date-time - type: 'null' title: End Date Utc description: The end date time in UTC timezone.Time format YYYY-MM-DDThh:mm:ss.ms examples: - '2022-07-25T18:38:55.640Z' end_date_in_milliseconds: anyOf: - type: integer - type: 'null' title: End Date In Milliseconds description: The end epoch in milliseconds. examples: - 1658774335000 source: anyOf: - type: string - type: 'null' title: Source description: The name of the source. examples: - Google Ads task_id: type: string title: Task Id description: The ID of the task examples: - 6a23130732304020886bf5f8bfcecfbc task_name: type: string title: Task Name description: The name of the task examples: - Google Ads To Amazon S3 task_status: allOf: - $ref: '#/components/schemas/ActivityStatusEnum' description: The status of the task examples: - succeeded task_type: const: logic title: Task Type type: object required: - duration - error_description - start_date_utc - start_date_in_milliseconds - end_date_utc - end_date_in_milliseconds - task_id - task_name - task_status - task_type title: LogicTaskProperties description: Logic task properties RunGroupSortByEnum: type: string enum: - units - last_run - max_duration title: RunGroupSortByEnum description: Activities sort properties in the UI. ScheduleEnum: type: string enum: - 'true' - 'false' title: ScheduleEnum description: Schedule can be either True or False (enabled or disabled) LogicodeStatistics: properties: logicode_rpu: type: number title: Logicode Rpu description: The total RPUs that were consumed during this step run logicode_network_mb: type: number title: Logicode Network Mb description: The total network (in and out) consumption of this step run logicode_duration_seconds: type: number title: Logicode Duration Seconds description: The duration of this step type: object required: - logicode_rpu - logicode_network_mb - logicode_duration_seconds title: LogicodeStatistics description: Logicode (python) statistics LogicStep: properties: is_container: type: boolean title: Is Container description: A flag that indicates whether this step is a container or not examples: - true container_type: anyOf: - $ref: '#/components/schemas/LogicContainerTypeEnum' - type: 'null' description: The container type - if any examples: - run_once start_date_utc: type: string format: date-time title: Start Date Utc description: The start date time in UTC timezone.Time format YYYY-MM-DDThh:mm:ss.ms examples: - '2022-07-25T18:38:55.640Z' start_date_in_milliseconds: type: integer title: Start Date In Milliseconds description: The start epoch in milliseconds. examples: - 1658774335000 end_date_utc: anyOf: - type: string format: date-time - type: 'null' title: End Date Utc description: The end date time in UTC timezone.Time format YYYY-MM-DDThh:mm:ss.ms examples: - '2022-07-25T18:38:55.640Z' end_date_in_milliseconds: anyOf: - type: integer - type: 'null' title: End Date In Milliseconds description: The end epoch in milliseconds. examples: - 1658774335000 step_status: allOf: - $ref: '#/components/schemas/ActivityStatusEnum' description: The step status examples: - succeeded loop_iteration_number: type: integer title: Loop Iteration Number description: If loop exist, it will contain the loop iteration number, otherwise 0 duration: type: string title: Duration description: Step duration. Format h:mm:ss.ms. If step failed or canceled the duration will be 'None' examples: - '0:01:23.275006' step_execution_id: type: string title: Step Execution Id step_id: type: string title: Step Id step_index: type: string title: Step Index error_description: anyOf: - type: string - type: 'null' title: Error Description description: The error description if any examples: - error logicode_statistics: anyOf: - $ref: '#/components/schemas/LogicodeStatistics' - type: 'null' description: The logicode statistics of RPU, duration and network block_type: anyOf: - $ref: '#/components/schemas/LogicBlockTypeEnum' - type: 'null' description: The logic block type examples: - action type: object required: - is_container - start_date_utc - start_date_in_milliseconds - end_date_utc - end_date_in_milliseconds - step_status - loop_iteration_number - duration - step_execution_id - step_id - step_index - error_description title: LogicStep description: Logic step configuration RiverActivityTargetResponse: properties: items: items: $ref: '#/components/schemas/RiverActivityTarget' type: array title: Items account_id: type: string title: Account Id environment_id: type: string title: Environment Id river_cross_id: type: string title: River Cross Id type: object required: - items - account_id - environment_id - river_cross_id title: RiverActivityTargetResponse description: Target response LogicBlockTypeEnum: type: string enum: - big_query_sql - river - redshift - action - azure_datalake - azure_sql - azure_datalake_job - snowflake - logicode - azure_sql_dwh - postgres - databricks - firebolt - athena title: LogicBlockTypeEnum description: Logic step can have block types - this enum enumerate the different block types ActionTaskProperties: properties: duration: type: integer title: Duration description: The duration of the task in milliseconds examples: - 2000 error_description: anyOf: - type: string - type: 'null' title: Error Description description: The error description if any examples: - error start_date_utc: type: string format: date-time title: Start Date Utc description: The start date time in UTC timezone.Time format YYYY-MM-DDThh:mm:ss.ms examples: - '2022-07-25T18:38:55.640Z' start_date_in_milliseconds: type: integer title: Start Date In Milliseconds description: The start epoch in milliseconds. examples: - 1658774335000 end_date_utc: anyOf: - type: string format: date-time - type: 'null' title: End Date Utc description: The end date time in UTC timezone.Time format YYYY-MM-DDThh:mm:ss.ms examples: - '2022-07-25T18:38:55.640Z' end_date_in_milliseconds: anyOf: - type: integer - type: 'null' title: End Date In Milliseconds description: The end epoch in milliseconds. examples: - 1658774335000 source: anyOf: - type: string - type: 'null' title: Source description: The name of the source. examples: - Google Ads task_id: type: string title: Task Id description: The ID of the task examples: - 6a23130732304020886bf5f8bfcecfbc task_name: type: string title: Task Name description: The name of the task examples: - Google Ads To Amazon S3 task_status: allOf: - $ref: '#/components/schemas/ActivityStatusEnum' description: The status of the task examples: - succeeded task_type: const: actions title: Task Type response_details: anyOf: - items: {} type: array - type: object - type: 'null' title: Response Details description: Response details for action/rest rivers type: object required: - duration - error_description - start_date_utc - start_date_in_milliseconds - end_date_utc - end_date_in_milliseconds - task_id - task_name - task_status - task_type title: ActionTaskProperties description: Action river properties RiverActivityRunLogicStepsLogsResponse: properties: logs_url: type: string title: Logs Url type: object required: - logs_url title: RiverActivityRunLogicStepsLogsResponse description: run's logic step logs LogicContainerTypeEnum: type: string enum: - run_once - loop_over - condition title: LogicContainerTypeEnum description: ALl of the logic container options TargetsSortByEnum: type: string enum: - units - last_run - table_name title: TargetsSortByEnum description: Activities sort properties in the UI. HTTPValidationError: properties: detail: items: $ref: '#/components/schemas/ValidationError' type: array title: Detail type: object title: HTTPValidationError RiverActivityRunTasksResponse: properties: account_id: type: string title: Account Id environment_id: type: string title: Environment Id river_cross_id: type: string title: River Cross Id run_id: type: string title: Run Id items: items: oneOf: - $ref: '#/components/schemas/ActionTaskProperties' - $ref: '#/components/schemas/SourceToTargetTaskProperties' - $ref: '#/components/schemas/LogicTaskProperties' discriminator: propertyName: task_type mapping: actions: '#/components/schemas/ActionTaskProperties' logic: '#/components/schemas/LogicTaskProperties' source_to_target: '#/components/schemas/SourceToTargetTaskProperties' type: array title: Items pricing_category: anyOf: - type: string - type: 'null' title: Pricing Category description: The RPU policy rule object for calculating an RPU units: type: number title: Units description: Total RPU (units) examples: - 2.1 rpu: type: number title: Rpu description: Total RPU examples: - 2.1 type: object required: - account_id - environment_id - river_cross_id - run_id - items - units - rpu title: RiverActivityRunTasksResponse description: Run's task response RunGroupStatusEnum: type: string enum: - partially succeeded - pending - canceled - succeeded - failed - running - skipped title: RunGroupStatusEnum description: The run group enum provide all the status that run group can have. FileSizeUnits: type: string enum: - B - KB - MB - GB - TB title: FileSizeUnits description: This enum contains all the size units RiverActivityTarget: properties: target_name: type: string title: Target Name status: $ref: '#/components/schemas/ActivityStatusEnum' units: type: number title: Units description: Total RPU (units) examples: - 2.1 rpu: type: number title: Rpu description: Total RPU examples: - 2.1 last_run: type: string format: date-time title: Last Run type: object required: - target_name - status - units - rpu - last_run title: RiverActivityTarget description: The activity target SizeFormatted: properties: size: type: number title: Size units: $ref: '#/components/schemas/FileSizeUnits' type: object required: - size - units title: SizeFormatted description: The size formatted as size and units ActivityLogicVariableResponse: properties: items: items: $ref: '#/components/schemas/RiverVariablesFields' type: array title: Items type: object required: - items title: ActivityLogicVariableResponse description: The activities logic variables response NewRelicServicesEnum: type: string const: recipe-service title: NewRelicServicesEnum description: 'Additional New Relic service subsystems to include when querying run logs. Values map to the SUB_SYS attribute in New Relic worker logs.' ActivityStatisticResponse: properties: account_id: type: string title: Account Id environment_id: type: string title: Environment Id total_units: type: number title: Total Units description: Total RPU (units) examples: - 2.1 total_rpu: type: number title: Total Rpu description: Total RPU examples: - 2.1 running: type: integer title: Running canceled: type: integer title: Canceled pending: type: integer title: Pending failed: type: integer title: Failed succeeded: type: integer title: Succeeded skipped: type: integer title: Skipped type: object required: - account_id - environment_id - total_units - total_rpu - running - canceled - pending - failed - succeeded - skipped title: ActivityStatisticResponse description: Activity statistics response RiverActivityRunLogicStepsResponse: properties: account_id: type: string title: Account Id environment_id: type: string title: Environment Id river_cross_id: type: string title: River Cross Id run_id: type: string title: Run Id steps: additionalProperties: $ref: '#/components/schemas/LogicStep' type: object title: Steps type: object required: - account_id - environment_id - river_cross_id - run_id - steps title: RiverActivityRunLogicStepsResponse description: run's logic step RiverActivityRunsResponse: properties: next_page: anyOf: - type: string - type: 'null' title: Next Page description: The next page URL previous_page: anyOf: - type: string - type: 'null' title: Previous Page description: The previous page URL page: type: integer title: Page description: The page number default: 1 current_page_size: type: integer title: Current Page Size description: The current page size total_items: type: integer title: Total Items description: The total number of entities fetched default: 0 account_id: type: string title: Account Id description: The account id environment_id: type: string title: Environment Id description: The environment id items: items: $ref: '#/components/schemas/RiverActivityRun' type: array title: Items river_cross_id: type: string title: River Cross Id type: object required: - current_page_size - account_id - environment_id - items - river_cross_id title: RiverActivityRunsResponse description: The activity run response RunsSortByEnum: type: string enum: - units - start_time - table_name title: RunsSortByEnum description: Activities sort properties in the UI. RiverActivityRunGroup: properties: run_group_id: type: string title: Run Group Id description: The run group id examples: - 201dcf8182ad4a59868cb41b957fdc8d status: type: string title: Status units: anyOf: - type: number - type: 'null' title: Units description: Total RPU (units) examples: - 2.1 rpu: anyOf: - type: number - type: 'null' title: Rpu description: Total RPU examples: - 2.1 max_duration_in_milliseconds: anyOf: - type: integer - type: 'null' title: Max Duration In Milliseconds run_date_epoch_milliseconds: type: integer title: Run Date Epoch Milliseconds run_date_utc: type: string format: date-time title: Run Date Utc run_end_date_epoch_milliseconds: anyOf: - type: integer - type: 'null' title: Run End Date Epoch Milliseconds description: The end epoch in milliseconds. examples: - 1658774335000 run_end_date_utc: anyOf: - type: string format: date-time - type: 'null' title: Run End Date Utc description: The end date time in UTC timezone.Time format YYYY-MM-DDThh:mm:ss.ms examples: - '2022-07-25T18:38:55.640Z' trigger_name: anyOf: - $ref: '#/components/schemas/TriggerName' - type: 'null' description: The mechanism that started the run. Empty for runs of an account that does not track triggers examples: - ui trigger_chain: anyOf: - $ref: '#/components/schemas/TriggerChain' - type: 'null' description: The trigger events leading back to the act that started the whole run tree, oldest first examples: - - trigger_name: scheduled - run_id: R1 trigger_name: logic type: object required: - run_group_id - status - units - rpu - run_date_epoch_milliseconds - run_date_utc - run_end_date_epoch_milliseconds - run_end_date_utc title: RiverActivityRunGroup description: The run group details SortOrderEnum: type: string enum: - desc - asc title: SortOrderEnum description: Sorting can be either asc or desc, used in the api-service TriggerEvent: properties: trigger_name: allOf: - $ref: '#/components/schemas/TriggerName' description: The mechanism that performed this trigger run_id: anyOf: - type: string - type: 'null' title: Run Id description: The run that performed this trigger, empty at the root additionalProperties: false type: object required: - trigger_name title: TriggerEvent description: 'One act of triggering: the mechanism, and the run that performed it. ``run_id`` is empty for the first event of a chain, where a person, a cron or an API client performed the act and no upstream run exists.' RiverTypeInternalEnum: type: string enum: - src_to_trgt - src_to_fz - actions - logic title: RiverTypeInternalEnum description: 'All of the INTERNAL river types Customers only familiar with river_type src_to_trgt, actions and logic. Internally we have another river type called src_to_fz.' RiverActivityStatisticResponse: properties: account_id: type: string title: Account Id environment_id: type: string title: Environment Id total_units: type: number title: Total Units description: Total RPU (units) examples: - 2.1 total_rpu: type: number title: Total Rpu description: Total RPU examples: - 2.1 running: type: integer title: Running canceled: type: integer title: Canceled pending: type: integer title: Pending failed: type: integer title: Failed succeeded: type: integer title: Succeeded skipped: type: integer title: Skipped river_cross_id: type: string title: River Cross Id type: object required: - account_id - environment_id - total_units - total_rpu - running - canceled - pending - failed - succeeded - skipped - river_cross_id title: RiverActivityStatisticResponse description: Statistics response securitySchemes: HTTPBearer: type: http scheme: bearer externalDocs: description: Find out more about Data Integration url: https://help.boomi.com/docs/Atomsphere/Data_Integration/Data_Integration_Overview