| 32 | |
| 33 | |
| 34 | class WorkflowExecutionDB( |
| 35 | stormbase.StormFoundationDB, stormbase.ChangeRevisionFieldMixin |
| 36 | ): |
| 37 | RESOURCE_TYPE = types.ResourceType.EXECUTION |
| 38 | |
| 39 | action_execution = me.StringField(required=True) |
| 40 | spec = stormbase.EscapedDictField() |
| 41 | graph = me.DictField() |
| 42 | input = JSONDictEscapedFieldCompatibilityField() |
| 43 | notify = me.DictField() |
| 44 | context = JSONDictEscapedFieldCompatibilityField() |
| 45 | state = JSONDictEscapedFieldCompatibilityField() |
| 46 | status = me.StringField(required=True) |
| 47 | output = JSONDictEscapedFieldCompatibilityField() |
| 48 | errors = stormbase.EscapedDynamicField() |
| 49 | start_timestamp = db_field_types.ComplexDateTimeField( |
| 50 | default=date_utils.get_datetime_utc_now |
| 51 | ) |
| 52 | end_timestamp = db_field_types.ComplexDateTimeField() |
| 53 | |
| 54 | meta = {"indexes": [{"fields": ["action_execution"]}]} |
| 55 | |
| 56 | |
| 57 | class TaskExecutionDB(stormbase.StormFoundationDB, stormbase.ChangeRevisionFieldMixin): |