Skip to content

Commit 0cec96f

Browse files
authored
fix: add terminated task status (#200)
1 parent f518175 commit 0cec96f

File tree

3 files changed

+3
-1
lines changed

3 files changed

+3
-1
lines changed

client/src/main/java/io/hstream/Connector.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,6 @@ public class Connector {
99
String target;
1010
Instant createdTime;
1111
String status;
12-
/** only available in GetConnector */
1312
String config;
1413

1514
List<String> offsets;

client/src/main/java/io/hstream/TaskStatus.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,5 +4,6 @@ public enum TaskStatus {
44
CREATING,
55
RUNNING,
66
ABORTED,
7+
TERMINATED,
78
UNKNOWN,
89
}

client/src/main/java/io/hstream/util/GrpcUtils.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -190,6 +190,8 @@ public static TaskStatus taskStatusFromInternal(TaskStatusPB statusPB) {
190190
return TaskStatus.RUNNING;
191191
case TASK_ABORTED:
192192
return TaskStatus.ABORTED;
193+
case TASK_TERMINATED:
194+
return TaskStatus.TERMINATED;
193195
default:
194196
return TaskStatus.UNKNOWN;
195197
}

0 commit comments

Comments
 (0)