Update more fields to use the new more efficient dict field.
@@ -40,10 +40,9 @@ class WorkflowExecutionDB(stormbase.StormFoundationDB, stormbase.ChangeRevisionF
action_execution = me.StringField(required=True)
spec = stormbase.EscapedDictField()
graph = me.DictField()
- input = stormbase.EscapedDictField()
+ input = JSONDictEscapedFieldCompatibilityField()
notify = me.DictField()
- context = stormbase.EscapedDictField()
- #state = stormbase.EscapedDictField()
+ context = JSONDictEscapedFieldCompatibilityField()
state = JSONDictEscapedFieldCompatibilityField()
status = me.StringField(required=True)
output = JSONDictEscapedFieldCompatibilityField()
@@ -65,12 +64,12 @@ class TaskExecutionDB(stormbase.StormFoundationDB, stormbase.ChangeRevisionField
task_name = me.StringField(required=True)
task_id = me.StringField(required=True)
task_route = me.IntField(required=True, min_value=0)
- task_spec = stormbase.EscapedDictField()
+ task_spec = JSONDictEscapedFieldCompatibilityField()
delay = me.IntField(min_value=0)
itemized = me.BooleanField(default=False)
items_count = me.IntField(min_value=0)
items_concurrency = me.IntField(min_value=1)
- context = stormbase.EscapedDictField()
+ context = JSONDictEscapedFieldCompatibilityField()
status = me.StringField(required=True)
result = JSONDictEscapedFieldCompatibilityField()
start_timestamp = db_field_types.ComplexDateTimeField(default=date_utils.get_datetime_utc_now)
