Skip to content

Commit d89b9bd

Browse files
committed
fix(server): fix some issues of the distributed scheduler
1 parent a31e937 commit d89b9bd

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

  • hugegraph-server/hugegraph-core/src/main/java/org/apache/hugegraph/task

hugegraph-server/hugegraph-core/src/main/java/org/apache/hugegraph/task/HugeTask.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -371,7 +371,9 @@ protected void done() {
371371
protected void set(V v) {
372372
String result = JsonUtil.toJson(v);
373373
checkPropertySize(result, P.RESULT);
374-
assert this.result(TaskStatus.SUCCESS, result) || this.completed();
374+
if (!this.result(TaskStatus.SUCCESS, result)) {
375+
assert this.completed();
376+
}
375377
// Will call done() and may cause to save to store
376378
super.set(v);
377379
}

0 commit comments

Comments
 (0)