Spaces:
Running
Running
Update LynxScribe module with recent changes.
Browse files
lynxkite-core/src/lynxkite/core/executors/one_by_one.py
CHANGED
@@ -142,12 +142,12 @@ async def execute(ws: workspace.Workspace, catalog, cache=None):
|
|
142 |
key = make_cache_key((inputs, params))
|
143 |
if key not in cache:
|
144 |
result: ops.Result = op(*inputs, **params)
|
145 |
-
output = await await_if_needed(result.output)
|
146 |
-
cache[key] =
|
147 |
-
|
148 |
else:
|
149 |
result = op(*inputs, **params)
|
150 |
-
|
151 |
except Exception as e:
|
152 |
traceback.print_exc()
|
153 |
node.publish_error(e)
|
|
|
142 |
key = make_cache_key((inputs, params))
|
143 |
if key not in cache:
|
144 |
result: ops.Result = op(*inputs, **params)
|
145 |
+
result.output = await await_if_needed(result.output)
|
146 |
+
cache[key] = result
|
147 |
+
result = cache[key]
|
148 |
else:
|
149 |
result = op(*inputs, **params)
|
150 |
+
output = await await_if_needed(result.output)
|
151 |
except Exception as e:
|
152 |
traceback.print_exc()
|
153 |
node.publish_error(e)
|