V2 API¶

This API describes the ways of interacting with Mistral service via HTTP protocol using Representational State Transfer concept (ReST).

Basics¶

Media types¶

Currently this API relies on JSON to represent states of REST resources.

Error states¶

The common HTTP Response Status Codes (https://github.com/for-GET/know-your-http-well/blob/master/status-codes.md) are used.

Application root [/]¶

Application Root provides links to all possible API methods for Mistral. URLs for other resources described below are relative to Application Root.

API v2 root [/v2/]¶

All API v2 urls are relative to API v2 root.

Workbooks¶

type Workbook¶

Workbook resource.

Data samples:

Json

{
    "created_at": "1970-01-01T00:00:00.000000",
    "definition": "HERE GOESWORKBOOK DEFINITION IN MISTRAL DSL v2",
    "id": "123e4567-e89b-12d3-a456-426655440000",
    "name": "book",
    "scope": "private",
    "tags": [
        "large",
        "expensive"
    ],
    "updated_at": "1970-01-01T00:00:00.000000"
}

definition¶

Type:	unicode

workbook definition in Mistral v2 DSL

scope¶

Type:	Enum(private, public)

‘private’ or ‘public’

name is immutable. tags is a list of values associated with a workbook that a user can use to group workbooks by some criteria (deployment workbooks, Big Data processing workbooks etc.). Note that name and tags get inferred from workbook definition when Mistral service receives a POST request. So they can’t be changed in another way.

type Workbooks¶

A collection of Workbooks.

Data samples:

Json

{
    "workbooks": [
        {
            "created_at": "1970-01-01T00:00:00.000000",
            "definition": "HERE GOESWORKBOOK DEFINITION IN MISTRAL DSL v2",
            "id": "123e4567-e89b-12d3-a456-426655440000",
            "name": "book",
            "scope": "private",
            "tags": [
                "large",
                "expensive"
            ],
            "updated_at": "1970-01-01T00:00:00.000000"
        }
    ]
}

GET /v2/workbooks¶

Return a list of workbooks.

Parameters:

marker – Optional. Pagination marker for large data sets.
limit – Optional. Maximum number of resources to return in a single result. Default value is None for backward compatibility.
sort_keys – Optional. Columns to sort results by. Default: created_at.
sort_dirs – Optional. Directions to sort corresponding to sort_keys, “asc” or “desc” can be chosen. Default: asc.
fields – Optional. A specified list of fields of the resource to be returned. ‘id’ will be included automatically in fields if it’s provided, since it will be used when constructing ‘next’ link.
name – Optional. Keep only resources with a specific name.
definition – Optional. Keep only resources with a specific definition.
tags – Optional. Keep only resources containing specific tags.
scope – Optional. Keep only resources with a specific scope.
created_at – Optional. Keep only resources created at a specific time and date.
updated_at – Optional. Keep only resources with specific latest update time and date.

Where project_id is the same as the requester or project_id is different but the scope is public. :type marker: uuid :type limit: int :type sort_keys: uniquelist :type sort_dirs: list :type fields: uniquelist :type created_at: unicode :type definition: unicode :type name: unicode :type scope: Enum(private, public) :type tags: unicode :type updated_at: unicode

Return type:	`Workbooks`

GET /v2/workbooks¶

Return the named workbook. :type name: unicode

Return type:	`Workbook`

POST /v2/workbooks¶: Create a new workbook.

PUT /v2/workbooks¶: Update a workbook.

DELETE /v2/workbooks¶: Delete the named workbook. :type name: unicode

Workflows¶

type Workflow¶

Workflow resource.

Data samples:

Json

{
    "created_at": "1970-01-01T00:00:00.000000",
    "definition": "HERE GOESWORKFLOW DEFINITION IN MISTRAL DSL v2",
    "id": "123e4567-e89b-12d3-a456-426655440000",
    "input": "param1, param2",
    "name": "flow",
    "project_id": "a7eb669e9819420ea4bd1453e672c0a7",
    "scope": "private",
    "tags": [
        "large",
        "expensive"
    ],
    "updated_at": "1970-01-01T00:00:00.000000"
}

definition¶

Type:	unicode

Workflow definition in Mistral v2 DSL

scope¶

Type:	Enum(private, public)

‘private’ or ‘public’

name is immutable. tags is a list of values associated with a workflow that a user can use to group workflows by some criteria. Note that name and tags get inferred from workflow definition when Mistral service receives a POST request. So they can’t be changed in another way.

type Workflows¶

A collection of workflows.

Data samples:

Json

{
    "next": "http://localhost:8989/v2/workflows?sort_keys=id,name&sort_dirs=asc,desc&limit=10&marker=123e4567-e89b-12d3-a456-426655440000",
    "workflows": [
        {
            "created_at": "1970-01-01T00:00:00.000000",
            "definition": "HERE GOESWORKFLOW DEFINITION IN MISTRAL DSL v2",
            "id": "123e4567-e89b-12d3-a456-426655440000",
            "input": "param1, param2",
            "name": "flow",
            "project_id": "a7eb669e9819420ea4bd1453e672c0a7",
            "scope": "private",
            "tags": [
                "large",
                "expensive"
            ],
            "updated_at": "1970-01-01T00:00:00.000000"
        }
    ]
}

GET /v2/workflows¶

Return a list of workflows.

Parameters:

marker (uuid) – Optional. Pagination marker for large data sets.
limit (int) – Optional. Maximum number of resources to return in a single result. Default value is None for backward compatibility.
sort_keys (uniquelist) – Optional. Columns to sort results by. Default: created_at.
sort_dirs (list) – Optional. Directions to sort corresponding to sort_keys, “asc” or “desc” can be chosen. Default: asc.
fields (uniquelist) – Optional. A specified list of fields of the resource to be returned. ‘id’ will be included automatically in fields if it’s provided, since it will be used when constructing ‘next’ link.
name (unicode) – Optional. Keep only resources with a specific name.
input (unicode) – Optional. Keep only resources with a specific input.
definition (unicode) – Optional. Keep only resources with a specific definition.
tags (unicode) – Optional. Keep only resources containing specific tags.
scope (Enum(private, public)) – Optional. Keep only resources with a specific scope.
project_id (uuid) – Optional. The same as the requester project_id or different if the scope is public.
created_at (unicode) – Optional. Keep only resources created at a specific time and date.
updated_at (unicode) – Optional. Keep only resources with specific latest update time and date.
all_projects (bool) – Optional. Get resources of all projects.

Return type:

Workflows

GET /v2/workflows¶

Return the named workflow. :type identifier: unicode

Return type:	`Workflow`

POST /v2/workflows¶

Create a new workflow.

NOTE: The text is allowed to have definitions: of multiple workflows. In this case they all will be created.

PUT /v2/workflows¶

Update one or more workflows.

Parameters:	identifier – Optional. If provided, it’s UUID of a workflow. Only one workflow can be updated with identifier param.

The text is allowed to have definitions of multiple workflows. In this case they all will be updated.

DELETE /v2/workflows¶: Delete a workflow. :type identifier: unicode

Actions¶

type Action¶

Action resource.

NOTE: name is immutable. Note that name and description get inferred from action definition when Mistral service receives a POST request. So they can’t be changed in another way.

Data samples:

Json

{
    "created_at": "1970-01-01T00:00:00.000000",
    "definition": "HERE GOES ACTION DEFINITION IN MISTRAL DSL v2",
    "id": "123e4567-e89b-12d3-a456-426655440000",
    "name": "flow",
    "scope": "private",
    "tags": [
        "large",
        "expensive"
    ],
    "updated_at": "1970-01-01T00:00:00.000000"
}

type Actions¶

A collection of Actions.

Data samples:

Json

{
    "actions": [
        {
            "created_at": "1970-01-01T00:00:00.000000",
            "definition": "HERE GOES ACTION DEFINITION IN MISTRAL DSL v2",
            "id": "123e4567-e89b-12d3-a456-426655440000",
            "name": "flow",
            "scope": "private",
            "tags": [
                "large",
                "expensive"
            ],
            "updated_at": "1970-01-01T00:00:00.000000"
        }
    ],
    "next": "http://localhost:8989/v2/actions?sort_keys=id,name&sort_dirs=asc,desc&limit=10&marker=123e4567-e89b-12d3-a456-426655440000"
}

GET /v2/actions¶

Return all actions.

Parameters:

marker – Optional. Pagination marker for large data sets.
limit – Optional. Maximum number of resources to return in a single result. Default value is None for backward compatibility.
sort_keys – Optional. Columns to sort results by. Default: name.
sort_dirs – Optional. Directions to sort corresponding to sort_keys, “asc” or “desc” can be chosen. Default: asc.
fields – Optional. A specified list of fields of the resource to be returned. ‘id’ will be included automatically in fields if it’s provided, since it will be used when constructing ‘next’ link.
name – Optional. Keep only resources with a specific name.
scope – Optional. Keep only resources with a specific scope.
definition – Optional. Keep only resources with a specific definition.
is_system – Optional. Keep only system actions or ad-hoc actions (if False).
input – Optional. Keep only resources with a specific input.
description – Optional. Keep only resources with a specific description.
tags – Optional. Keep only resources containing specific tags.
created_at – Optional. Keep only resources created at a specific time and date.
updated_at – Optional. Keep only resources with specific latest update time and date.

Where project_id is the same as the requester or project_id is different but the scope is public. :type marker: uuid :type limit: int :type sort_keys: uniquelist :type sort_dirs: list :type fields: uniquelist :type created_at: unicode :type name: unicode :type scope: Enum(private, public) :type tags: unicode :type updated_at: unicode :type description: unicode :type definition: unicode :type is_system: unicode :type input: unicode

Return type:	`Actions`

GET /v2/actions¶

Return the named action.

Parameters:	identifier (`unicode`) – ID or name of the Action to get.
Return type:	`Action`

POST /v2/actions¶

Create a new action.

NOTE: This text is allowed to have definitions: of multiple actions. In this case they all will be created.

PUT /v2/actions¶

Update one or more actions.

NOTE: This text is allowed to have definitions: of multiple actions. In this case they all will be updated.

DELETE /v2/actions¶: Delete the named action. :type identifier: unicode

Executions¶

type Execution¶

Execution resource.

Data samples:

Json

{
    "created_at": "1970-01-01T00:00:00.000000",
    "description": "this is the first execution.",
    "id": "123e4567-e89b-12d3-a456-426655440000",
    "input": "{}",
    "output": "{}",
    "params": "{\"env\": {\"k2\": 123, \"k1\": \"abc\"}}",
    "state": "SUCCESS",
    "updated_at": "1970-01-01T00:00:00.000000",
    "workflow_id": "123e4567-e89b-12d3-a456-426655441111",
    "workflow_name": "flow"
}

description¶

Type:	unicode

description of workflow execution.

id¶

Type:	unicode

id is immutable and auto assigned.

input¶

Type:	json

input is a JSON structure containing workflow input values.

output¶

Type:	json

output is a workflow output.

state¶

Type:	unicode

state can be one of: IDLE, RUNNING, SUCCESS, ERROR, PAUSED

state_info¶

Type:	unicode

an optional state information string

task_execution_id¶

Type:	unicode

reference to the parent task execution

workflow_id¶

Type:	unicode

reference to workflow ID

workflow_name¶

Type:	unicode

reference to workflow definition

type Executions¶

A collection of Execution resources.

Data samples:

Json

{
    "executions": [
        {
            "created_at": "1970-01-01T00:00:00.000000",
            "description": "this is the first execution.",
            "id": "123e4567-e89b-12d3-a456-426655440000",
            "input": "{}",
            "output": "{}",
            "params": "{\"env\": {\"k2\": 123, \"k1\": \"abc\"}}",
            "state": "SUCCESS",
            "updated_at": "1970-01-01T00:00:00.000000",
            "workflow_id": "123e4567-e89b-12d3-a456-426655441111",
            "workflow_name": "flow"
        }
    ],
    "next": "http://localhost:8989/v2/executions?sort_keys=id,workflow_name&sort_dirs=asc,desc&limit=10&marker=123e4567-e89b-12d3-a456-426655440000"
}

GET /v2/executions¶

Return all Executions.

Parameters:

marker (uuid) – Optional. Pagination marker for large data sets.
limit (int) – Optional. Maximum number of resources to return in a single result. Default value is None for backward compatibility.
sort_keys (uniquelist) – Optional. Columns to sort results by. Default: created_at, which is backward compatible.
sort_dirs (list) – Optional. Directions to sort corresponding to sort_keys, “asc” or “desc” can be chosen. Default: desc. The length of sort_dirs can be equal or less than that of sort_keys.
fields (uniquelist) – Optional. A specified list of fields of the resource to be returned. ‘id’ will be included automatically in fields if it’s provided, since it will be used when constructing ‘next’ link.
workflow_name (unicode) – Optional. Keep only resources with a specific workflow name.
workflow_id (uuid) – Optional. Keep only resources with a specific workflow ID.
description (unicode) – Optional. Keep only resources with a specific description.
params (json) – Optional. Keep only resources with specific parameters.
task_execution_id (uuid) – Optional. Keep only resources with a specific task execution ID.
state (Enum(IDLE, RUNNING, SUCCESS, ERROR, PAUSED, CANCELLED)) – Optional. Keep only resources with a specific state.
state_info (unicode) – Optional. Keep only resources with specific state information.
input (json) – Optional. Keep only resources with a specific input.
output (json) – Optional. Keep only resources with a specific output.
created_at (unicode) – Optional. Keep only resources created at a specific time and date.
updated_at (unicode) – Optional. Keep only resources with specific latest update time and date.
include_output (bool) – Optional. Include the output for all executions in the list

Return type:

Executions

GET /v2/executions¶

Return the specified Execution. :type id: unicode

Return type:	`Execution`

POST /v2/executions¶

Create a new Execution.

Parameters:	wf_ex (`Execution`) – Execution object with input content.
Return type:	`Execution`

PUT /v2/executions¶

Update the specified workflow execution.

Parameters:	id (`unicode`) – execution ID. wf_ex (`Execution`) – Execution object.
Return type:	`Execution`

DELETE /v2/executions¶: Delete the specified Execution. :type id: unicode

Tasks¶

When a workflow starts Mistral creates an execution. It in turn consists of a set of tasks. So Task is an instance of a task described in a Workflow that belongs to a particular execution.

type Task¶

Task resource.

Data samples:

Json

{
    "created_at": "1970-01-01T00:00:00.000000",
    "id": "123e4567-e89b-12d3-a456-426655440000",
    "name": "task",
    "processed": true,
    "published": "{\"key\": \"value\"}",
    "reset": true,
    "result": "task result",
    "state": "SUCCESS",
    "updated_at": "1970-01-01T00:00:00.000000",
    "workflow_execution_id": "123e4567-e89b-12d3-a456-426655440000",
    "workflow_id": "123e4567-e89b-12d3-a456-426655441111",
    "workflow_name": "flow"
}

state_info¶

Type:	unicode

an optional state information string

type Tasks¶

A collection of tasks.

Data samples:

Json

{
    "tasks": [
        {
            "created_at": "1970-01-01T00:00:00.000000",
            "id": "123e4567-e89b-12d3-a456-426655440000",
            "name": "task",
            "processed": true,
            "published": "{\"key\": \"value\"}",
            "reset": true,
            "result": "task result",
            "state": "SUCCESS",
            "updated_at": "1970-01-01T00:00:00.000000",
            "workflow_execution_id": "123e4567-e89b-12d3-a456-426655440000",
            "workflow_id": "123e4567-e89b-12d3-a456-426655441111",
            "workflow_name": "flow"
        }
    ]
}

GET /v2/tasks¶

Return all tasks.

Where project_id is the same as the requester or project_id is different but the scope is public.

Parameters:

marker (uuid) – Optional. Pagination marker for large data sets.
limit (int) – Optional. Maximum number of resources to return in a single result. Default value is None for backward compatibility.
sort_keys (uniquelist) – Optional. Columns to sort results by. Default: created_at, which is backward compatible.
sort_dirs (list) – Optional. Directions to sort corresponding to sort_keys, “asc” or “desc” can be chosen. Default: desc. The length of sort_dirs can be equal or less than that of sort_keys.
fields (uniquelist) – Optional. A specified list of fields of the resource to be returned. ‘id’ will be included automatically in fields if it’s provided, since it will be used when constructing ‘next’ link.
name (unicode) – Optional. Keep only resources with a specific name.
workflow_name (unicode) – Optional. Keep only resources with a specific workflow name.
workflow_id (uuid) – Optional. Keep only resources with a specific workflow ID.
workflow_execution_id (uuid) – Optional. Keep only resources with a specific workflow execution ID.
state (Enum(IDLE, RUNNING, SUCCESS, ERROR, DELAYED)) – Optional. Keep only resources with a specific state.
state_info (unicode) – Optional. Keep only resources with specific state information.
result (unicode) – Optional. Keep only resources with a specific result.
published (json) – Optional. Keep only resources with specific published content.
processed (bool) – Optional. Keep only resources which have been processed or not.
reset (bool) – Optional. Keep only resources which have been reset or not.
env (json) – Optional. Keep only resources with a specific environment.
created_at (unicode) – Optional. Keep only resources created at a specific time and date.
updated_at (unicode) – Optional. Keep only resources with specific latest update time and date.

Return type:

Tasks

GET /v2/tasks¶

Return the specified task. :type id: unicode

Return type:	`Task`

PUT /v2/tasks¶

Update the specified task execution.

Parameters:	id (`unicode`) – Task execution ID. task (`Task`) – Task execution object.
Return type:	`Task`

GET /v2/executions¶

Return all tasks within the execution.

Where project_id is the same as the requester or project_id is different but the scope is public.

Parameters:

marker (uuid) – Optional. Pagination marker for large data sets.
limit (int) – Optional. Maximum number of resources to return in a single result. Default value is None for backward compatibility.
sort_keys (uniquelist) – Optional. Columns to sort results by. Default: created_at, which is backward compatible.
sort_dirs (list) – Optional. Directions to sort corresponding to sort_keys, “asc” or “desc” can be chosen. Default: desc. The length of sort_dirs can be equal or less than that of sort_keys.
fields (uniquelist) – Optional. A specified list of fields of the resource to be returned. ‘id’ will be included automatically in fields if it’s provided, since it will be used when constructing ‘next’ link.
name (unicode) – Optional. Keep only resources with a specific name.
workflow_name (unicode) – Optional. Keep only resources with a specific workflow name.
workflow_id (uuid) – Optional. Keep only resources with a specific workflow ID.
workflow_execution_id (uuid) – Optional. Keep only resources with a specific workflow execution ID.
state (Enum(IDLE, RUNNING, SUCCESS, ERROR, DELAYED)) – Optional. Keep only resources with a specific state.
state_info (unicode) – Optional. Keep only resources with specific state information.
result (unicode) – Optional. Keep only resources with a specific result.
published (json) – Optional. Keep only resources with specific published content.
processed (bool) – Optional. Keep only resources which have been processed or not.
reset (bool) – Optional. Keep only resources which have been reset or not.
env (json) – Optional. Keep only resources with a specific environment.
created_at (unicode) – Optional. Keep only resources created at a specific time and date.
updated_at (unicode) – Optional. Keep only resources with specific latest update time and date.

Return type:

Tasks

Action Executions¶

When a Task starts Mistral creates a set of Action Executions. So Action Execution is an instance of an action call described in a Workflow Task that belongs to a particular execution.

type ActionExecution¶

ActionExecution resource.

Data samples:

Json

{
    "accepted": true,
    "created_at": "1970-01-01T00:00:00.000000",
    "description": "My running action",
    "id": "123e4567-e89b-12d3-a456-426655440000",
    "input": "{\"first_name\": \"John\", \"last_name\": \"Doe\"}",
    "name": "std.echo",
    "output": "{\"some_output\": \"Hello, John Doe!\"}",
    "params": "{\"save_result\": true, \"run_sync\": false}",
    "state": "SUCCESS",
    "state_info": "SUCCESS",
    "tags": [
        "foo",
        "fee"
    ],
    "task_execution_id": "343e45623-e89b-12d3-a456-426655440090",
    "task_name": "task1",
    "updated_at": "1970-01-01T00:00:00.000000",
    "workflow_name": "flow"
}

type ActionExecutions¶

A collection of action_executions.

Data samples:

Json

{
    "action_executions": [
        {
            "accepted": true,
            "created_at": "1970-01-01T00:00:00.000000",
            "description": "My running action",
            "id": "123e4567-e89b-12d3-a456-426655440000",
            "input": "{\"first_name\": \"John\", \"last_name\": \"Doe\"}",
            "name": "std.echo",
            "output": "{\"some_output\": \"Hello, John Doe!\"}",
            "params": "{\"save_result\": true, \"run_sync\": false}",
            "state": "SUCCESS",
            "state_info": "SUCCESS",
            "tags": [
                "foo",
                "fee"
            ],
            "task_execution_id": "343e45623-e89b-12d3-a456-426655440090",
            "task_name": "task1",
            "updated_at": "1970-01-01T00:00:00.000000",
            "workflow_name": "flow"
        }
    ]
}

GET /v2/action_executions¶

Return all tasks within the execution.

Where project_id is the same as the requester or project_id is different but the scope is public.

Parameters:

marker (uuid) – Optional. Pagination marker for large data sets.
limit (int) – Optional. Maximum number of resources to return in a single result. Default value is None for backward compatibility.
sort_keys (uniquelist) – Optional. Columns to sort results by. Default: created_at, which is backward compatible.
sort_dirs (list) – Optional. Directions to sort corresponding to sort_keys, “asc” or “desc” can be chosen. Default: desc. The length of sort_dirs can be equal or less than that of sort_keys.
fields (uniquelist) – Optional. A specified list of fields of the resource to be returned. ‘id’ will be included automatically in fields if it’s provided, since it will be used when constructing ‘next’ link.
name (unicode) – Optional. Keep only resources with a specific name.
workflow_name (unicode) – Optional. Keep only resources with a specific workflow name.
task_name (unicode) – Optional. Keep only resources with a specific task name.
task_execution_id (uuid) – Optional. Keep only resources within a specific task execution.
state (unicode) – Optional. Keep only resources with a specific state.
state_info (unicode) – Optional. Keep only resources with specific state information.
accepted (bool) – Optional. Keep only resources which have been accepted or not.
input (json) – Optional. Keep only resources with a specific input.
output (json) – Optional. Keep only resources with a specific output.
params (json) – Optional. Keep only resources with specific parameters.
description (unicode) – Optional. Keep only resources with a specific description.
tags (unicode) – Optional. Keep only resources containing specific tags.
created_at (unicode) – Optional. Keep only resources created at a specific time and date.
updated_at (unicode) – Optional. Keep only resources with specific latest update time and date.

Return type:

ActionExecutions

GET /v2/action_executions¶

Return the specified action_execution. :type id: unicode

Return type:	`ActionExecution`

POST /v2/action_executions¶

Create new action_execution. :type action_ex: ActionExecution

Return type:	`ActionExecution`

PUT /v2/action_executions¶

Update the specified action_execution. :type id: unicode :type action_ex: ActionExecution

Return type:	`ActionExecution`

DELETE /v2/action_executions¶: Delete the specified action_execution. :type id: unicode

GET /v2/tasks¶

Return all tasks within the execution.

Where project_id is the same as the requester or project_id is different but the scope is public.

Parameters:

task_execution_id (uuid) – Keep only resources within a specific task execution.
marker (uuid) – Optional. Pagination marker for large data sets.
limit (int) – Optional. Maximum number of resources to return in a single result. Default value is None for backward compatibility.
sort_keys (uniquelist) – Optional. Columns to sort results by. Default: created_at, which is backward compatible.
sort_dirs (list) – Optional. Directions to sort corresponding to sort_keys, “asc” or “desc” can be chosen. Default: desc. The length of sort_dirs can be equal or less than that of sort_keys.
fields (uniquelist) – Optional. A specified list of fields of the resource to be returned. ‘id’ will be included automatically in fields if it’s provided, since it will be used when constructing ‘next’ link.
name (uniquelist) – Optional. Keep only resources with a specific name.
workflow_name (unicode) – Optional. Keep only resources with a specific workflow name.
task_name (unicode) – Optional. Keep only resources with a specific task name.
state (unicode) – Optional. Keep only resources with a specific state.
state_info (unicode) – Optional. Keep only resources with specific state information.
accepted (bool) – Optional. Keep only resources which have been accepted or not.
input (json) – Optional. Keep only resources with a specific input.
output (json) – Optional. Keep only resources with a specific output.
params (json) – Optional. Keep only resources with specific parameters.
description (unicode) – Optional. Keep only resources with a specific description.
tags (unicode) – Optional. Keep only resources containing specific tags.
created_at (unicode) – Optional. Keep only resources created at a specific time and date.
updated_at (unicode) – Optional. Keep only resources with specific latest update time and date.

Return type:

ActionExecutions

GET /v2/tasks¶

Return the specified action_execution. :type task_execution_id: unicode :type action_ex_id: unicode

Return type:	`ActionExecution`

Cron Triggers¶

Cron trigger is an object that allows to run Mistral workflows according to a time pattern (Unix crontab patterns format). Once a trigger is created it will run a specified workflow according to its properties: pattern, first_execution_time and remaining_executions.

type CronTrigger¶

CronTrigger resource.

Data samples:

Json

{
    "created_at": "1970-01-01T00:00:00.000000",
    "id": "123e4567-e89b-12d3-a456-426655440000",
    "name": "my_trigger",
    "pattern": "* * * * *",
    "remaining_executions": 42,
    "scope": "private",
    "updated_at": "1970-01-01T00:00:00.000000",
    "workflow_id": "123e4567-e89b-12d3-a456-426655441111",
    "workflow_input": "{}",
    "workflow_name": "my_wf",
    "workflow_params": "{}"
}

type CronTriggers¶

A collection of cron triggers.

Data samples:

Json

{
    "cron_triggers": [
        {
            "created_at": "1970-01-01T00:00:00.000000",
            "id": "123e4567-e89b-12d3-a456-426655440000",
            "name": "my_trigger",
            "pattern": "* * * * *",
            "remaining_executions": 42,
            "scope": "private",
            "updated_at": "1970-01-01T00:00:00.000000",
            "workflow_id": "123e4567-e89b-12d3-a456-426655441111",
            "workflow_input": "{}",
            "workflow_name": "my_wf",
            "workflow_params": "{}"
        }
    ]
}

GET /v2/cron_triggers¶

Return all cron triggers.

Parameters:

marker (uuid) – Optional. Pagination marker for large data sets.
limit (int) – Optional. Maximum number of resources to return in a single result. Default value is None for backward compatibility.
sort_keys (uniquelist) – Optional. Columns to sort results by. Default: created_at, which is backward compatible.
sort_dirs (list) – Optional. Directions to sort corresponding to sort_keys, “asc” or “desc” can be chosen. Default: desc. The length of sort_dirs can be equal or less than that of sort_keys.
fields (uniquelist) – Optional. A specified list of fields of the resource to be returned. ‘id’ will be included automatically in fields if it’s provided, since it will be used when constructing ‘next’ link.
name (unicode) – Optional. Keep only resources with a specific name.
workflow_name (unicode) – Optional. Keep only resources with a specific workflow name.
workflow_id (uuid) – Optional. Keep only resources with a specific workflow ID.
workflow_input (json) – Optional. Keep only resources with a specific workflow input.
workflow_params (json) – Optional. Keep only resources with specific workflow parameters.
scope (Enum(private, public)) – Optional. Keep only resources with a specific scope.
pattern (unicode) – Optional. Keep only resources with a specific pattern.
remaining_executions (integer) – Optional. Keep only resources with a specific number of remaining executions.
first_execution_time (unicode) – Optional. Keep only resources with a specific time and date of first execution.
next_execution_time (unicode) – Optional. Keep only resources with a specific time and date of next execution.
created_at (unicode) – Optional. Keep only resources created at a specific time and date.
updated_at (unicode) – Optional. Keep only resources with specific latest update time and date.

Return type:

CronTriggers

GET /v2/cron_triggers¶

Returns the named cron_trigger. :type name: unicode

Return type:	`CronTrigger`

POST /v2/cron_triggers¶

Creates a new cron trigger.

Parameters:	cron_trigger (`CronTrigger`) – Required. Cron trigger structure.
Return type:	`CronTrigger`

DELETE /v2/cron_triggers¶: Delete cron trigger. :type name: unicode

Environments¶

Environment contains a set of variables which can be used in specific workflow. Using an Environment it is possible to create and map action default values - just provide ‘__actions’ key in ‘variables’. All these variables can be accessed using the Workflow Language with the <% $.__env %> expression.

Example of usage:

workflow:
  tasks:
    task1:
      action: std.echo output=<% $.__env.my_echo_output %>

Example of creating action defaults

...ENV...
"variables": {
  "__actions": {
    "std.echo": {
      "output": "my_output"
    }
  }
},
...ENV...

Note: using CLI, Environment can be created via JSON or YAML file.

type Environment¶

Environment resource.

Data samples:

Json

{
    "created_at": "1970-01-01T00:00:00.000000",
    "description": "example environment entry",
    "id": "123e4567-e89b-12d3-a456-426655440000",
    "name": "sample",
    "scope": "private",
    "updated_at": "1970-01-01T00:00:00.000000",
    "variables": "{\"database\": \"temp\", \"verbose\": true, \"timeout\": 600, \"server\": \"localhost\"}"
}

type Environments¶

A collection of Environment resources.

Data samples:

Json

{
    "environments": [
        {
            "created_at": "1970-01-01T00:00:00.000000",
            "description": "example environment entry",
            "id": "123e4567-e89b-12d3-a456-426655440000",
            "name": "sample",
            "scope": "private",
            "updated_at": "1970-01-01T00:00:00.000000",
            "variables": "{\"database\": \"temp\", \"verbose\": true, \"timeout\": 600, \"server\": \"localhost\"}"
        }
    ]
}

GET /v2/environments¶

Return all environments.

Where project_id is the same as the requester or project_id is different but the scope is public.

Parameters:

marker (uuid) – Optional. Pagination marker for large data sets.
limit (int) – Optional. Maximum number of resources to return in a single result. Default value is None for backward compatibility.
sort_keys (uniquelist) – Optional. Columns to sort results by. Default: created_at, which is backward compatible.
sort_dirs (list) – Optional. Directions to sort corresponding to sort_keys, “asc” or “desc” can be chosen. Default: desc. The length of sort_dirs can be equal or less than that of sort_keys.
fields (uniquelist) – Optional. A specified list of fields of the resource to be returned. ‘id’ will be included automatically in fields if it’s provided, since it will be used when constructing ‘next’ link.
name (unicode) – Optional. Keep only resources with a specific name.
description (unicode) – Optional. Keep only resources with a specific description.
variables (json) – Optional. Keep only resources with specific variables.
scope (Enum(private, public)) – Optional. Keep only resources with a specific scope.
created_at (unicode) – Optional. Keep only resources created at a specific time and date.
updated_at (unicode) – Optional. Keep only resources with specific latest update time and date.

Return type:

Environments

GET /v2/environments¶

Return the named environment. :type name: unicode

Return type:	`Environment`

POST /v2/environments¶

Create a new environment. :type env: Environment

Return type:	`Environment`

PUT /v2/environments¶

Update an environment. :type env: Environment

Return type:	`Environment`

DELETE /v2/environments¶: Delete the named environment. :type name: unicode

Services¶

Through service management API, system administrator or operator can retrieve Mistral services information of the system, including service group and service identifier. The internal implementation of this feature make use of tooz library, which needs coordinator backend(the most commonly used at present is Zookeeper) installed, please refer to tooz official documentation for more detailed instruction.

There are three service groups according to Mistral architecture currently, namely api_group, engine_group and executor_group. The service identifier contains name of the host the service is running on and the process identifier of the service on that host.

type Service¶

Service resource.

Data samples:

Json

{
    "name": "host1_1234",
    "type": "executor_group"
}

type Services¶

A collection of Services.

Data samples:

Json

{
    "services": [
        {
            "name": "host1_1234",
            "type": "executor_group"
        }
    ]
}

GET /v2/services¶

Return all services.

Return type:	`Services`

Validation¶

Validation endpoints allow to check correctness of workbook, workflow and ad-hoc action Workflow Language without having to upload them into Mistral.

POST /v2/workbooks/validation: Validate workbook content (Workflow Language grammar and semantics).
POST /v2/workflows/validation: Validate workflow content (Workflow Language grammar and semantics).
POST /v2/actions/validation: Validate ad-hoc action content (Workflow Language grammar and semantics).

These endpoints expect workbook, workflow or ad-hoc action text (Workflow Language) correspondingly in a request body.

OpenStack

V2 API¶

Basics¶

Media types¶

Error states¶

Application root [/]¶

API v2 root [/v2/]¶

Workbooks¶

Workflows¶

Actions¶

Executions¶

Tasks¶

Action Executions¶

Cron Triggers¶

Environments¶

Services¶

Validation¶

Table Of Contents

Previous topic

Next topic

Project Source

This Page

OpenStack

V2 API¶

Basics¶

Media types¶

Error states¶

Application root [/]¶

API v2 root [/v2/]¶

Workbooks¶

Workflows¶

Actions¶

Executions¶

Tasks¶

Action Executions¶

Cron Triggers¶

Environments¶

Services¶

Validation¶

Table Of Contents

Previous topic

Next topic

Project Source

This Page

Quick search