mirror of
https://github.com/ethauvin/kobalt.git
synced 2025-04-26 16:28:12 -07:00
Fix log.
This commit is contained in:
parent
30ce95fdf2
commit
a9b4d23b0e
1 changed files with 2 additions and 2 deletions
|
@ -154,12 +154,12 @@ class DynamicGraphExecutor<T>(val graph : DynamicGraph<T>, val factory: IThreadW
|
||||||
running--
|
running--
|
||||||
if (taskResult.success) {
|
if (taskResult.success) {
|
||||||
nodesRun.add(taskResult.value)
|
nodesRun.add(taskResult.value)
|
||||||
log(1, "Task succeeded: $taskResult")
|
log(2, "Task succeeded: $taskResult")
|
||||||
graph.removeNode(taskResult.value)
|
graph.removeNode(taskResult.value)
|
||||||
newFreeNodes.clear()
|
newFreeNodes.clear()
|
||||||
newFreeNodes.addAll(graph.freeNodes.minus(nodesRun))
|
newFreeNodes.addAll(graph.freeNodes.minus(nodesRun))
|
||||||
} else {
|
} else {
|
||||||
log(1, "Task failed: $taskResult")
|
log(2, "Task failed: $taskResult")
|
||||||
gotError = true
|
gotError = true
|
||||||
}
|
}
|
||||||
} catch(ex: TimeoutException) {
|
} catch(ex: TimeoutException) {
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue