Workflow Components

Conventions:

  • bold port name indicates that it is required
  • (parentheses) indicate data type accepted or emitted
  • all type means the data can be any type
  • bang means the data type is irrelevant only the presence of data matters

Atlas

Copy Dataset

Copies data from one Atlas record(source) to another(target), across resources if necessary

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • options (object) - Copy options
    • write_mode (string)
      • values: create, overwrite, overwrite_content, append
    • update_schema (boolean) - Update target with schema from source record
    • start_date (string)
    • end_date (string)
    • limit (number) - To limit the copy of number of bytes
    • skip (number) - Skip number of bytes before copying
    • retry (boolean) - Enable retry for certain error types
      • default: true
    • cachedmode (boolean) - To return previous results if possible
    • includeHeader (boolean) - To include header in the target record
    • throw_on_failure (string) - Whether or not to emit an error if a job fails
      • values: true, false
      • default: true
  • source (object) - Atlas record to copy from
  • target (object) - Atlas record to copy to
  • wait (bang)

Outputs:

  • error (object)
  • target (object) - Atlas record copied to

Copy Dataset Multi

Copies data from given set(s) of Atlas records to another, across resources if necessary.

Inputs:

  • concurrency (int) - Number of concurrent copies to perform. Max is 5.
  • context (object) - Aunsight Context
  • default_context (object) - Aunsight context
  • options (object) - Copy options
    • write_mode (string)
      • values: create, overwrite, overwrite_content, append
    • update_schema (boolean) - Update target with schema from source record
    • start_date (string)
    • end_date (string)
    • limit (number) - To limit the copy of number of bytes
    • skip (number) - Skip number of bytes before copying
    • retry (boolean) - Enable retry for certain error types
      • default: true
    • includeHeader (boolean) - To include header in the target record
    • throw_on_failure (string) - Whether or not to emit an error if a job fails
      • values: true, false
      • default: true
  • records (array) - List of source/target Atlas Record id pairs
  • wait (bang)

Outputs:

  • error (object)
  • jobs (array) - List of job objects

Create Atlas Record

Create an atlas record

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • organization (string) - Organization to create the record under
  • project (string) - Project to create the record under
  • record (object) - Atlas record to create
  • wait (bang)

Outputs:

  • error (object)
  • record (object) - Atlas record

Delete Atlas Record

Delete Atlas record

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • options (object) - Deletion options
    • ignoreRecord (boolean) - Delete the dataset but not the record itself
  • record (object) - Atlas record
  • wait (bang)

Outputs:

  • done (boolean)
  • error (object)

Download Structured Data

Download a small amount of structured data from a record in object mode

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • limit (int) - Number of rows to download
  • options (object) - Download options
  • record (object) - Atlas record
  • wait (bang)

Outputs:

  • data (object) - List of row objects
  • error (object)

Get Atlas Record

Gets an Atlas record by id. Emits error if not found.

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • id (string) - Record id
  • wait (bang)

Outputs:

  • error (object)
  • record (object) - Atlas record

Ingest from Query

Runs a stored query and saves the results into a dataset

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • options (object) - Options
    • name (string) - Query name
    • update_schema (boolean) - Update target schema
      • default: true
    • string_mode (boolean) - Retrieve all values as strings regardless of source record schemas
    • include_header (boolean) - To include header in the target record
    • throw_on_failure (string) - Whether or not to emit an error if a job fails
      • values: true, false
      • default: true
  • query (object) - Query to execute
  • resource (object) - Query resource
  • target (object) - Atlas record to save to
  • wait (bang)

Outputs:

  • error (object)
  • target (object) - Atlas record containing the result data

Initialize Dataset

Initialize dataset to be empty

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • options (object) - Init options
    • write_mode (string)
      • values: create, overwrite, overwrite_content
    • throw_on_failure (string) - Whether or not to emit an error if a job fails
      • values: true, false
      • default: true
  • record (object) - Atlas record
  • wait (bang)

Outputs:

  • done (boolean)
  • error (object)

Memento

Create Memento

Creates a memento in an existing series.

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • note (string) - Record id
  • series (string) - Memento series object
  • value (string) - Memento value
  • wait (bang)

Outputs:

  • error (object)
  • memento (object) - Memento

Get Memento Series

Get Memento series by id

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • id (string) - Series id
  • wait (bang)

Outputs:

  • error (object)
  • series (object) - Memento series

List Mementos

List mementos matching a query. The query input is a plain object using the <field>__<operator> format for the list-mementos API endpoint.

Note

Although limit allows the user to limit the maximum number of mementos returned, there is a platform-imposed limit of 2,000 mementos for any memento query.

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • limit (object) - Limit
  • query (object) - Query
  • series (string) - Memento series object
  • wait (bang)

Outputs:

  • error (object)
  • mementos (array) - Mementos from query

Organization

Get Organization

Get organization by id

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • id (string) - Organization id
  • wait (bang)

Outputs:

  • error (object)
  • organization (object) - Aunsight organization

Get Project

Get project by id

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • id (string) - Project id
  • organization (string) - Organization id
  • wait (bang)

Outputs:

  • error (object)
  • project (object) - Aunsight project

Send Mail to Member

Send Mail to Organization Member. Mail currently means “email” and as such it requires both text and html representations. Other components may be used to generate the mail content.

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • html (string) - Mail html content
  • member (string) - Member id
  • organization (object) - Aunsight organization
  • subject (string) - Mail subject
  • text (string) - Mail text content
  • wait (bang)

Outputs:

  • error (object)

Send Mail to Role

Sends mail to all members of an organization role. Mail currently means “email” and as such it requires both text and html representations. Other components may be used to generate the mail content.

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • html (string) - Mail html content
  • organization (object) - Aunsight organization
  • role (string) - Role id
  • subject (string) - Mail subject
  • text (string) - Mail text content
  • wait (bang)

Outputs:

  • error (object)

Send SMS to Member

Sends an SMS message to an organization member. There is a maximum limit of 1600 characters. Exceeding this limit will cause an error. Aunsight may prepend a short prefix to the message which also contributes to the total.

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • member (string) - Member id
  • message (string) - SMS message
  • organization (object) - Aunsight organization
  • wait (bang)

Outputs:

  • error (object)

Send SMS to Role

Sends an SMS message to all members of an organization role. There is a maximum limit of 1600 characters. Exceeding this limit will cause an error. Aunsight may prepend a short prefix to the message which also contributes to the total.

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • message (string) - SMS message
  • organization (object) - Aunsight organization
  • role (string) - Role id
  • wait (bang)

Outputs:

  • error (object)

Peeper

Peeper Run Peeper

Run a peeper job

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • options (object) - Submission options
    • throw_on_failure (string) - Whether or not to emit an error if a job fails
      • values: true, false
      • default: true
  • record (object) - Atlas record lib-aunsight model object
  • resource (string) - Resource id
  • wait (bang)

Outputs:

  • error (object)
  • report (object) - Peeper job lib-aunsight model object

Peeper View Report

View a Peeper Report

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • record (object) - Atlas record lib-aunsight model object
  • wait (bang)

Outputs:

  • error (object)
  • report (object) - Last successful peeper job for record

Process

Get Process Version

Get process version by id

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • process (string) - Process id
  • version (string) - Version id
  • wait (bang)

Outputs:

  • error (object)
  • version (object) - Process version

Run Process Version

Submits a process version to be run. Will wait for the process to finish before emitting output. If the job’s error field is present and ends in a failure state will emit the error from that field.

Inputs:

  • arguments (object) - Job Arguments
  • env (object) - Job Environment
  • options (object) - Submission options
    • token (string) - Authentication to communicate with Aunsight
    • throw_on_failure (string) - Whether or not to emit an error if a job fails
      • values: true, false
      • default: true
    • name (string) - Process name
    • env (array) - Environment variables
    • memory (number) - Size in bytes of memory to allocate to the process. Cannot exceed resource max
    • cpu (number)
    • ttl (object) - Maximum lifetime for a job relative to some timestamp field
    • capabilities (object)
  • resource (object) - Process resource
  • version (object) - Process version
  • wait (bang)

Outputs:

  • error (object)
  • job (object) - Process job

Run Process Version multiple times

Run a Process Version multiple times for given environment variable sets

Inputs:

  • concurrency (int) - Number of concurrent runs to perform. Max is 5.
  • envs (array) - List of env vars used per process version submission
  • options (object) - Submission options
    • token (string) - Authentication to communicate with Aunsight
    • throw_on_failure (string) - Whether or not to emit an error if a job fails
      • values: true, false
      • default: true
    • name (string) - Process name
    • env (array) - Environment variables
    • memory (number) - Size in bytes of memory to allocate to the process. Cannot exceed resource max
    • cpu (number)
    • ttl (object) - Maximum lifetime for a job relative to some timestamp field
    • capabilities (object)
  • resource (object) - Process resource
  • version (object) - Process version
  • wait (bang)

Outputs:

  • error (object)
  • jobs (array) - List of Process job objects

Resource

Get Resource

Get resource by id

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • id (string) - Resource id
  • organization (object) - Organization object or id
  • wait (bang)

Outputs:

  • error (object)
  • resource (object) - Aunsight resource

Rule

Evaluate Rule

Evaluates Rule (AuQL Script) and returns from true or false output depending on Rule output.

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • options (object) - Submission options
    • throw_on_failure (string) - Whether or not to emit an error if a job fails
      • values: true, false
      • default: true
    • name (string) - Rule name
    • parameters (object) - Provide required rule parameters (if any) as KVPs
  • parameters (object) - parameters object
  • rule (object) - Aunsight rule
  • wait (bang)

Outputs:

  • error (object)
  • job (object) - Rule job

Get Rule

Get rule by id

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • id (string) - Rule id
  • wait (bang)

Outputs:

  • error (object)
  • rule (object) - Aunsight rule

Script

Evaluate Rule

Evaluates Rule (AuQL Script) and returns from true or false port depending on Rule output.

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • options (object) - Submission options
    • throw_on_failure (string) - Whether or not to emit an error if a job fails
      • values: true, false
      • default: true
    • name (string) - Rule name
  • parameters (object) - parameters object
  • rule (object) - AuQL Rule
  • wait (bang)

Outputs:

  • error (object)
  • false (boolean) - Rule evaluates as False
  • job (object) - Rule job
  • true (boolean) - Rule evaluates as True

Evaluate Script

Evaluates AuQL Script and returns output.

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • options (object) - Submission options
    • throw_on_failure (string) - Whether or not to emit an error if a job fails
      • values: true, false
      • default: true
    • name (string) - Script name
    • path (string) - Extract this path from the output object if present
  • parameters (object) - parameters object
  • script (object) - AuQL script
  • wait (bang)

Outputs:

  • error (object)
  • job (object) - Script job
  • output (string) - Stringified script output

Get Script

Get AuQL Script by id.

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • id (string) - Script id
  • wait (bang)

Outputs:

  • error (object)
  • script (object) - AuQL Script

Sightglass

Create Release

Creates a release. throw_on_failure - Whether to emit an error if the job ends in a failure state (KILLED, FAILED, SUSPENDED). Default is false to emit the job regardless of final state for subsequent handling.

Inputs:

  • app (string) - SightglassApp object
  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • options (object) - Submission options
    • throw_on_failure (string) - Whether or not to emit an error if a job fails
      • values: true, false
      • default: true
  • record (string) - Atlas record
  • resource (string) - Task resource
  • source (string) - Sightglass data source id
  • token (string) - Token for the task to use (DEPRECATED)
  • wait (bang)

Outputs:

  • error (object)
  • release (object) - Sightglass data source release

Get Sightglass app

Get Sightglass app by id

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • id (string) - app id
  • wait (bang)

Outputs:

  • app (object) - Sightglass app
  • error (object)

Publish App

Publish an app

Inputs:

  • app (string) - SightglassApp object
  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • wait (bang)

Outputs:

  • app (object) - Sightglass app
  • error (object)

Send Insight

Send an Insight

Inputs:

  • actions (string) - Insight actions (in stringified JSON)
  • app (string) - SightglassApp object
  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • detail (string) - Insight detail
  • extended_detail (string) - Insight extended detail
  • groups (array) - Array of app user group ids
  • options (object) - Submission options
    • throw_on_failure (string) - Whether or not to emit an error if a job fails
      • values: true, false
      • default: true
  • title (string) - Insight title
  • type (string) - Insight type
  • users (array) - Array of app user ids
  • wait (bang)

Outputs:

  • error (object)

Set Current Release

Set the current source release

Inputs:

  • app (string) - SightglassApp object
  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • release (string) - Sightglass data source release
  • source (string) - Sightglass data source id
  • wait (bang)

Outputs:

  • app (object) - Sightglass app
  • error (object)

Tokamak

Create Dynamic Outputs

Create new Atlas records for any dynamic outputs.

Inputs:

  • context (object) - Aunsight context
  • dataflow (object) - Tokamak dataflow
  • default_context (object) - Aunsight context
  • resource (object) - Storage resource
  • wait (bang)

Outputs:

  • dataflow (object) - Tokamak dataflow
  • error (object)
  • records (object) - List of new Atlas records

Get Dataflow

Get Tokamak dataflow by id

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • id (string) - Dataflow id
  • wait (bang)

Outputs:

  • dataflow (object) - Tokamak dataflow
  • error (object)

Get Dataflow Job

Get Tokamak job by id

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • id (string) - Tokamak job id
  • wait (bang)

Outputs:

  • error (object)
  • job (object) - Tokamak Job

Get Dataflow Job Output By Name

Gets the Atlas record for an output of the job by name. Emits error if not found in the job or in Aunsight.

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • job (object) - Tokamak job
  • name (string) - Atlas record name
  • wait (bang)

Outputs:

  • error (object)
  • record (object) - Atlas record

Run Dataflow

Submits a Tokamak dataflow to run on the specified resource. Waits for the job to finish before emitting output.

Inputs:

  • context (object) - Aunsight context
  • dataflow (object) - Tokamak dataflow
  • default_context (object) - Aunsight context
  • options (object) - Submission options
    • throw_on_failure (string) - Whether or not to emit an error if a job fails
      • values: true, false
      • default: true
    • name (string) - Dataflow job name
    • overwrite (string) - To overwrite existing output records
      • values: true, false
      • default: true
    • cleanup (string) - To clean up the job artifacts
      • values: true, false
      • default: true
    • parameters (array) - To overwrite the dataflow defaults on submission in key-value pairs
    • execution_options (object)
    • cachedmode (boolean) - To return previous results if possible
  • parameters (object) - To overwrite the dataflow defaults on submission
  • resource (object) - Aunsight resource
  • wait (bang)

Outputs:

  • error (object)
  • job (object) - Tokamak job

Run Dataflow multiple times

Run a Tokamak dataflow on a specified resource for multiple parameter sets. Same options as for Tokamak_RunDataflow. The parameters input is a list of plain objects which are each a set of valid dataflow parameters. The provided dataflow will be submitted once for each parameter set. If there is an error during submission, or if the throw_on_failure option is set and there is an error during execution, the first error encountered will be emitted from the error port. The error will not be emitted until all the jobs have succeeded or failed. If throw_on_failure is not set and a job fails, an error will not be thrown, but the individual jobs can be inspected subsequently to find any errors.

Inputs:

  • context (object) - Aunsight context
  • dataflow (object) - Tokamak dataflow
  • default_context (object) - Aunsight context
  • options (object) - Submission options
    • throw_on_failure (string) - Whether or not to emit an error if a job fails
      • values: true, false
      • default: true
    • name (string) - Dataflow job name
    • overwrite (string) - To overwrite existing output records
      • values: true, false
      • default: false
    • cleanup (string) - To clean up the job artifacts
      • values: true, false
      • default: true
    • execution_options (object)
    • cachedmode (boolean) - To return previous results if possible
    • concurrency (integer) - Number of dataflows to run simultaneously. Max is 5.
  • parameters (array) - List of input parameters
  • resource (object) - Aunsight resource
  • wait (bang)

Outputs:

  • error (object)
  • jobs (array) - List of Tokamak job objects

Utility

Array First Item

Get first item from an array or throw error if empty.

Inputs:

  • array (array) - Input array

Outputs:

  • error (object)
  • item (object) - First item

Array Ordered Concat

Concatenate up to 5 arrays in order

Inputs:

  • data1 (array)
  • data2 (array)
  • data3 (array)
  • data4 (array)
  • data5 (array)

Outputs:

  • data (array)
  • error (object)

Array Ordered Create

Create an array of 2-5 inputs in order

Inputs:

  • data1 (all) - First required input
  • data2 (all) - Second required input
  • data3 (all) - Third input
  • data4 (all) - Fourth input
  • data5 (all) - Fifth input

Outputs:

  • data (array) - Resulting array
  • error (object)

Array Unordered Concat

Concatenate multiple arrays in the order they are received

Inputs:

  • data (array)

Outputs:

  • done (boolean)
  • error (object)

Build Aunsight Context

Build Aunsight context for use in other processes

Inputs:

  • facts (object) - Information about the workflow
  • rest_host (string) - Aunsight API REST address
  • socketio_host (string) - Aunsight API SocketIO address
  • token (string) - User token

Outputs:

  • context (object) - Aunsight context
  • error (object)

Console Log

Log input to the console

Inputs:

  • in (all)

Outputs:

Delay

Delay for an amount of time after receiving input data

Inputs:

  • delay (int)
  • in (all)

Outputs:

  • out (all)

Hash SHA-1

Compute SHA-1 hash of input string

Inputs:

  • input (string) - String to hash

Outputs:

  • error (object)
  • hash (string) - Resulting hash

Is Equal

Check the equality of two things

Inputs:

  • other (all) - Second thing to compare
  • paths (array) - Path(s) on both things to compare
  • value (all) - First thing to compare

Outputs:

  • error (object)
  • no (boolean)
  • yes (boolean)

Call Object Method

Calls the specified method of an object. Emits error if the method is not found, is not a function or produces an error.

Inputs:

  • arguments (array) - Array of arguments to apply
  • method (string) - Method name to call
  • object (object) - Object to call on

Outputs:

  • error (object)
  • result (all) - Method return value

Get Object Path

Gets a value at a path in an object. Paths can use dot notation (a.b) to get nested values. If the path does not exist, the default is emitted or an error is emitted if a default is not specified.

Inputs:

  • default (all) - Default if path nonexistent
  • object (object) - Object to get from
  • path (string) - Path to get

Outputs:

  • error (object)
  • value (all) - Path value or default

Extend Object Ordered

Extend an object with given objects in order

Inputs:

  • object_1 (object) - Object to extend
  • object_2 (object) - Object
  • object_3 (object) - Object
  • object_4 (object) - Object
  • object_5 (object) - Object

Outputs:

  • error (object)
  • object (object) - Resulting object

Merge Object Ordered

Merge an object with given objects in order

Inputs:

  • object_1 (object) - Object to merge into
  • object_2 (object) - Object
  • object_3 (object) - Object
  • object_4 (object) - Object
  • object_5 (object) - Object

Outputs:

  • error (object)
  • object (object) - Resulting object

Pick Object Paths

Returns an object composed of values at the specified paths. Paths can use dot notation (a.b) to get nested values. If all is true, will emit error if any paths do not exist.

Inputs:

  • all (boolean) - Whether all must exist
  • object (object) - Object to pick from
  • paths (array) - Array of paths to pick

Outputs:

  • error (object)
  • value (all) - Resulting object

Set Object Path

Set a value at a path in an object

Inputs:

  • object (object) - Object to set on
  • path (string) - Path to set
  • value (all) - Value to set

Outputs:

  • error (object)
  • object (object) - Resulting object

Extend Object Unordered

Extend an object with given objects in the order received

Inputs:

  • objects (array)

Outputs:

  • done (boolean)
  • error (object)

Object Unordered Merge

Merge multiple objects in the order they are received

Inputs:

  • objects (array)

Outputs:

  • error (object)
  • object (object)

Objects Array To Key Groups Distinct

Transform array of objects to object of arrays with distinct values

Inputs:

  • array (array) - Array of objects

Outputs:

  • error (object)
  • object (object) - Object of arrays

Parse JSON

Parse a JSON string into a plain object

Inputs:

  • json (string) - JSON string to parse

Outputs:

  • error (object)
  • object (object) - Resulting object

Pick Objects Array

Pick object fields by key(s) from objects in array

Inputs:

  • all (boolean) - Whether all must exist
  • array (array) - Array of objects to pick from
  • paths (array) - Array of paths to pick

Outputs:

  • array (array) - Filtered array of objects composed of only paths
  • error (object)

Render Error Mail

Render an error into a mail message

Inputs:

  • error (all) - Error to render

Outputs:

  • html (string) - Mail html content
  • text (string) - Mail text content

Rethrow Error

Rethrow an error

Inputs:

  • error (object) - The error to rethrow

Outputs:

  • error (object)

Some

Wait for at least one input to be delivered

Inputs:

  • dependencies (bang) - Dependencies to be awaited

Outputs:

  • done (boolean)

Stringify JSON

Stringify a plain object into a JSON string

Inputs:

  • object (object) - Plain object to stringify

Outputs:

  • error (object)
  • json (string) - Resulting string

Throw Error

Throw a custom error

Inputs:

  • message (string) - Error message
  • name (string) - Error name
  • wait (bang)

Outputs:

  • error (object)

Wait

Wait for all inputs to be delivered

Inputs:

  • dependencies (bang) - Dependencies to be awaited

Outputs:

  • done (boolean)

Workflow Parameters

Merges submission parameters with defaults. There can only be 0 or 1 processes of this type in a workflow. If not present and parameters are provided on submission, they will be ignored.

Inputs:

  • defaults (object) - JSON default parameters to use
  • parameters (object) - Submission parameters

Outputs:

  • error (object)
  • parameters (object) - Merged parameters & defaults

Workflow

Get Workflow

Get workflow by id

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • id (string) - Workflow id
  • wait (bang)

Outputs:

  • error (object)
  • workflow (object) - Aunsight workflow

Run Workflow

Run workflow

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • options (object) - Submission options
    • token (string) - Token is used for execution
    • throw_on_failure (string) - Whether or not to emit an error if a job fails
      • values: true, false
      • default: true
    • name (string) - Workflow name
    • parameters (array) - To overwrite the workflow defaults on submission in key-value pairs
  • parameters (object) - To overwrite the workflow defaults on submission
  • wait (bang)
  • workflow (object) - Aunsight workflow

Outputs:

  • error (object)
  • job (object) - Workflow job

Run Workflow Multi

Run a workflow multiple times

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • options (object) - Submission options
    • token (string) - Token is used for execution
    • throw_on_failure (string) - Whether or not to emit an error if a job fails
      • values: true, false
      • default: true
    • name (string) - Workflow name
    • concurrency (integer) - Number of workflows to run simultaneously. Max is 5.
  • parameters (array) - List of input parameters
  • wait (bang)
  • workflow (object) - Aunsight workflow to run multiple times

Outputs:

  • error (object)
  • jobs (object) - Aunsight Workflow jobs

Update Workflow Status

Update current workflow status

Inputs:

  • context (object) - Aunsight context
  • default_context (object) - Aunsight context
  • status (string) - Status string
  • structured_status (object) - Structured Status
  • wait (bang)

Outputs:

  • error (object)