Tasks

Tasks are the Cloudomation functions that allow your flow scripts to interact with the outside world - anything and everything outside of the Cloudomation platform. Whenever you want to issue a command to a program, run a script on a remote system, or get query a database - all that is performed through tasks.

Tasks are called through the Cloudomation function this.task(). Each task creates a separate execution, with its own inputs and outputs.

For example, you can call a REST API using the Cloudomation REST task:

import flow_api
def handler(system: flow_api.System, this: flow_api.Execution):
    inputs = {
        'url': 'https://httpbin.org/post',
        'method': 'post',
        'data': 'payload',
    }
    task = this.task('REST', **inputs, run=False)
    task.run_async()
    # do other stuff
    task.wait()
    outputs = task.get('output_value')
    this.log(outputs)
    return this.success('all done')

The inputs required and outputs supplied by a task depend on the task type. Below your find documentation on each of the currently available task types.