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
- write_mode (string)
- 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
- write_mode (string)
- 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
- write_mode (string)
- 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
- throw_on_failure (string) - Whether or not to emit an error if a job fails
- 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
- throw_on_failure (string) - Whether or not to emit an error if a job fails
- 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
- throw_on_failure (string) - Whether or not to emit an error if a job fails
- 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
- throw_on_failure (string) - Whether or not to emit an error if a job fails
- 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
- throw_on_failure (string) - Whether or not to emit an error if a job fails
- 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
- throw_on_failure (string) - Whether or not to emit an error if a job fails
- 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
- throw_on_failure (string) - Whether or not to emit an error if a job fails
- 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.
- throw_on_failure (string) - Whether or not to emit an error if a job fails
- 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)