Skip to content

Commit 76c369d

Browse files
committed
Fix processing of sleep efficiency in FitbitSleepAvroConverter
1 parent 001ff4d commit 76c369d

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka-connect-fitbit-source/src/main/java/org/radarbase/connect/rest/fitbit/converter/FitbitSleepAvroConverter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -95,6 +95,7 @@ protected Stream<TopicData> processRecords(
9595
.flatMap(tryOrNull(s -> {
9696
Instant startTime = Instant.from(DATE_TIME_FORMAT.parse(s.get("startTime").asText()));
9797
boolean isStages = s.get("type") == null || s.get("type").asText().equals("stages");
98+
int efficiency = s.has("efficiency") ? s.get("efficiency").asInt() : null;
9899

99100
// use an intermediate offset for all records but the last. Since the query time
100101
// depends only on the start time of a sleep stages group, this will reprocess the entire
@@ -109,7 +110,6 @@ protected Stream<TopicData> processRecords(
109110
String dateTime = d.get("dateTime").asText();
110111
int duration = d.get("seconds").asInt();
111112
String level = d.get("level").asText();
112-
int efficiency = d.get("efficiency").asInt();
113113

114114
if (isStages) {
115115
sleep = new FitbitSleepStage(

0 commit comments

Comments
 (0)