|
@@ -120,7 +120,7 @@ def interpret_function_body(body_id, named_arguments, **kwargs):
|
|
symbol_edge, = yield [("CE", [new_symbols, variable])]
|
|
symbol_edge, = yield [("CE", [new_symbols, variable])]
|
|
yield [("CE", [symbol_edge, param_var])]
|
|
yield [("CE", [symbol_edge, param_var])]
|
|
|
|
|
|
- username = kwargs['username']
|
|
|
|
|
|
+ taskname = kwargs['taskname']
|
|
def exception_handler(ex):
|
|
def exception_handler(ex):
|
|
# print('Returning from interpreted function. Result: %s' % ex.result)
|
|
# print('Returning from interpreted function. Result: %s' % ex.result)
|
|
raise primitive_functions.PrimitiveFinished(ex.result)
|
|
raise primitive_functions.PrimitiveFinished(ex.result)
|
|
@@ -129,7 +129,7 @@ def interpret_function_body(body_id, named_arguments, **kwargs):
|
|
yield [("TRY", [])]
|
|
yield [("TRY", [])]
|
|
yield [("CATCH", [primitive_functions.InterpretedFunctionFinished, exception_handler])]
|
|
yield [("CATCH", [primitive_functions.InterpretedFunctionFinished, exception_handler])]
|
|
while 1:
|
|
while 1:
|
|
- result, = yield [("CALL_ARGS", [kernel.execute_rule, (username,)])]
|
|
|
|
|
|
+ result, = yield [("CALL_ARGS", [kernel.execute_rule, (taskname,)])]
|
|
# An instruction has completed. Forward it.
|
|
# An instruction has completed. Forward it.
|
|
yield result
|
|
yield result
|
|
|
|
|