|
@@ -250,25 +250,26 @@ class ModelverseKernel(object):
|
|
|
self.success = False
|
|
|
self.returnvalue = None
|
|
|
else:
|
|
|
- rv_value, = yield [("RV", [rv])]
|
|
|
- _, _ = yield [("CD", [task_root, "output", next_output]),
|
|
|
+ rv_value, _, _ = \
|
|
|
+ yield [("RV", [rv]),
|
|
|
+ ("CD", [task_root, "output", next_output]),
|
|
|
("DN", [first_output]),
|
|
|
]
|
|
|
+
|
|
|
self.returnvalue = rv_value
|
|
|
self.success = True
|
|
|
|
|
|
def set_input(self, taskname, value):
|
|
|
task_root, = yield [("RD", [self.root, taskname])]
|
|
|
- old_input, link = yield [("RD", [task_root, "last_input"]),
|
|
|
+ old_input, link, new_input, new_value = \
|
|
|
+ yield [("RD", [task_root, "last_input"]),
|
|
|
("RDE", [task_root, "last_input"]),
|
|
|
+ ("CN", []),
|
|
|
+ ("CNV", [value]),
|
|
|
]
|
|
|
- new_input, = yield [("CN", [])]
|
|
|
- _, _ = yield [("CD", [task_root, "last_input", new_input]),
|
|
|
+ _, _, _, _ = yield [("CD", [task_root, "last_input", new_input]),
|
|
|
("CD", [old_input, "next", new_input]),
|
|
|
- ]
|
|
|
-
|
|
|
- new_value, = yield [("CNV", [value])]
|
|
|
- _, _ = yield [("CD", [old_input, "value", new_value]),
|
|
|
+ ("CD", [old_input, "value", new_value]),
|
|
|
("DE", [link])
|
|
|
]
|
|
|
self.returnvalue = {"id": 100, "value": "success"}
|
|
@@ -1087,7 +1088,6 @@ class ModelverseKernel(object):
|
|
|
else:
|
|
|
# No input yet, so just wait and don't advance IP or phase
|
|
|
self.input_value = None
|
|
|
- self.success = False
|
|
|
|
|
|
def output_init(self, task_root):
|
|
|
task_frame, = yield [("RD", [task_root, "frame"])]
|