Execution
class resources.execution.Execution
Base class: Activity
An automation (flow or task) which is or was running.
:py:obj:flow_api.execution.Execution
| Property | Description | Type |
|---|---|---|
| id | UUID() | |
| process_id | UUID() | |
| schedule_id | The associated schedule for this execution | UUID() |
| type | The type of the execution. | Enum('FLOW', 'SCRIPT', 'TASK', 'SCHEDULE', name='executiontype') |
| status | The status of the execution. Output only. | Enum('WAITING_DEPENDENCY', 'WAITING_LOCK', 'WAITING_ENGINE', 'WAITING_RESPONSE', 'AT_ENGINE', 'ENDED_SUCCESS', 'ENDED_ERROR', 'ENDED_CANCELLED', 'PAUSED', 'SCHEDULED', 'LOST', name='executionstatus') |
| end_status | Enum('WAITING_DEPENDENCY', 'WAITING_LOCK', 'WAITING_ENGINE', 'WAITING_RESPONSE', 'AT_ENGINE', 'ENDED_SUCCESS', 'ENDED_ERROR', 'ENDED_CANCELLED', 'PAUSED', 'SCHEDULED', 'LOST', name='executionstatus') | |
| is_paused | A flag to control if the execution should be processed. | Boolean() |
| runtime | The duration the execution is running. | Interval() |
| started_at | The timestamp when the execution started. | DateTime(timezone=True) |
| ended_at | The timestamp when the execution ended. | DateTime(timezone=True) |
| scheduled_for | The timestamp when the execution will continue. This field is also used for timeouts. | DateTime(timezone=True) |
| parent_execution_id | The ID of the execution which created this execution. | UUID() |
| input_value | The data which was passed to the execution. | JSONB(astext_type=Text()) |
| output_value | The data returned by the execution | JSONB(astext_type=Text()) |
| protect_inputs | A list of input_value keys which should not be displayed in the user-interface. | JSONB(astext_type=Text()) |
| protect_outputs | A list of output_value keys which should not be displayed in the user-interface. | JSONB(astext_type=Text()) |
| message | A status message. | Text() |
| dependency_id | The ID of the dependency record the execution is currently waiting for. | UUID() |
| setting_id | The ID of the setting record the execution is currently trying to acquire a lock from. | UUID() |
| message_id | The ID of the message record the execution is currently awaiting a response from. | UUID() |
| metadata | Additional data which can be stored in the execution. | JSONB(astext_type=Text()) |
| is_productive | A flag to control if the execution runs in productive mode. | Boolean() |
| flow_id | The ID of the flow record the execution is processing. | UUID() |
| flow_name | The name of the flow record the execution is processing. | String(length=128) |
| flow_source | String(length=256) | |
| script | The script the execution is processing. | Text() |
| connection_type | The type of the connection / the type of the remote system. | Enum('AWS', 'GIT', 'GOOGLE', 'IMAP', 'K8S', 'LDAP', 'PS', 'REDIS', 'REST', 'SCP', 'SMB', 'SMTP', 'SOAP', 'SQLMSSQL', 'SQLORACLE', 'SQLPG', 'SSH', 'VAULT', 'XMLRPC', name='connectiontype') |
| connection_id | The ID of the connection record the execution is using. | UUID() |
| sync_config_id | The ID of the workspace sync_config the execution is associated with. | UUID() |
| is_remote_processed | A flag to control if the execution is processed in a remote workspace. | Boolean() |
| is_dirty | Mark executions for need of syncing to remote. | Boolean() |
| last_sync | DateTime(timezone=True) | |
| plugin_action_id | UUID() | |
| type_label | String(length=128) | |
| status_label | String(length=128) | |
| connection_name | String(length=128) | |
| vault_secrets | String(length=10240) | |
| remote_workspace_name | String(length=128) | |
| size_bytes | BigInteger() | |
| roles | Text() |