| 55 | |
| 56 | |
| 57 | class TaskExecutionDB(stormbase.StormFoundationDB, stormbase.ChangeRevisionFieldMixin): |
| 58 | RESOURCE_TYPE = types.ResourceType.EXECUTION |
| 59 | |
| 60 | workflow_execution = me.StringField(required=True) |
| 61 | task_name = me.StringField(required=True) |
| 62 | task_id = me.StringField(required=True) |
| 63 | task_route = me.IntField(required=True, min_value=0) |
| 64 | task_spec = JSONDictEscapedFieldCompatibilityField() |
| 65 | delay = me.IntField(min_value=0) |
| 66 | itemized = me.BooleanField(default=False) |
| 67 | items_count = me.IntField(min_value=0) |
| 68 | items_concurrency = me.IntField(min_value=1) |
| 69 | context = JSONDictEscapedFieldCompatibilityField() |
| 70 | status = me.StringField(required=True) |
| 71 | result = JSONDictEscapedFieldCompatibilityField() |
| 72 | start_timestamp = db_field_types.ComplexDateTimeField( |
| 73 | default=date_utils.get_datetime_utc_now |
| 74 | ) |
| 75 | end_timestamp = db_field_types.ComplexDateTimeField() |
| 76 | |
| 77 | meta = { |
| 78 | "indexes": [ |
| 79 | {"fields": ["workflow_execution"]}, |
| 80 | {"fields": ["task_id"]}, |
| 81 | {"fields": ["task_id", "task_route"]}, |
| 82 | {"fields": ["workflow_execution", "task_id"]}, |
| 83 | {"fields": ["workflow_execution", "task_id", "task_route"]}, |
| 84 | ] |
| 85 | } |
| 86 | |
| 87 | |
| 88 | MODELS = [WorkflowExecutionDB, TaskExecutionDB] |