Close
    logoCloudomation Docs

    Execution

    class flow_api.execution.Execution(select=None, init=None, by=id, **kwargs)

    Base class: Identity

    The Execution class represents an execution (flow, connection, or script). Functions from the execution class can be applied on execution objects. Execution objects are created by the following functions from the Cloudomation class: flow(), connect(), script(). It provides functions to set input parameters, run, and get information about the execution.

    Do not create execution objects directly, but using System.execution

    :py:obj:resources.execution.Execution

    Parameters

    NameTypeDescription
    selectThe ID of the execution object this instance operates on
    init
    by
    **kwargs

    Constants

    RESOURCE = execution

    Methods

    archive ()
    cancel (message=None)
    child (name=None, run=True, wait=True, init=None, input_value=None, protect_inputs=None, protect_outputs=None, metadata=None, remote_workspace_name=None, vault_secrets=None, roles=None, **kwargs)
    clone (init=None, name=None, run=True, wait=True, input_value=None, protect_inputs=None, protect_outputs=None, **kwargs)
    connect (connector_name=None, connector_type=None, name=None, run=True, wait=True, init=None, input_value=None, protect_inputs=None, protect_outputs=None, metadata=None, remote_workspace_name=None, vault_secrets=None, roles=None, **kwargs)
    create_dump (name)
    delete ()
    dependency (*args, return_when=ALL_SUCCEEDED, unpause=False, timeout_sec=None)
    end (end_status, message='end status set by script')
    error (message='error set by script')
    exists ()
    flow (flow_name, name=None, run=True, wait=True, init=None, input_value=None, protect_inputs=None, protect_outputs=None, metadata=None, remote_workspace_name=None, roles=None, flow_by=name, **kwargs)
    get (*fields, default=None)
    get_dict (*fields, default=None)
    get_identity_created_by ()
    get_identity_modified_by ()
    load (*fields)
    load_dump (id_, by='id')
    lock (setting, wait_timeout=60)
    log (*args, **kwargs)
    pause (message=None)
    release_lock (setting)
    roles ()
    run (*args, return_when=ALL_SUCCEEDED, wait=True, timeout_sec=None)
    run_async (*args, wait_for=None, return_when=ALL_SUCCEEDED)
    save (update=None, **kwargs)
    schedule (scheduled_for, message=None)
    script (script, name=None, run=True, wait=True, init=None, input_value=None, protect_inputs=None, protect_outputs=None, metadata=None, remote_workspace_name=None, roles=None, **kwargs)
    set (key, value)
    set_output (key=None, value=None, **kwargs)
    sleep (delay_sec, message=None)
    sleep_until (sleep_until)
    success (message='done')
    task (connector_type, **kwargs)
    wait (return_when=ALL_SUCCEEDED, timeout_sec=None)
    wait_for (*args, return_when=ALL_SUCCEEDED, timeout_sec=None)
    wait_lock (setting, wait_timeout=60)
    wait_status (execution, status, timeout=60)
    webhook_html_response (body=None, message='done')
    webhook_json_response (body=None, message='done')
    webhook_response (status=200, headers=None, body=None, message='done')
    Previous
    Connector
    Next
    File