File tree Expand file tree Collapse file tree 1 file changed +3
-0
lines changed
kafka-connect-fitbit-source/src/main/java/org/radarbase/connect/rest/fitbit/route Expand file tree Collapse file tree 1 file changed +3
-0
lines changed Original file line number Diff line number Diff line change @@ -164,6 +164,9 @@ public void requestEmpty(RestRequest request) {
164164 lastPollPerUser .put (((FitbitRestRequest ) request ).getUser ().getId (), lastPoll );
165165 FitbitRestRequest fitbitRequest = (FitbitRestRequest ) request ;
166166 Instant endOffset = fitbitRequest .getDateRange ().end ().toInstant ();
167+ // When having polled a date range for a route for HISTORICAL_TIME_DAYS days and
168+ // the response has no data, consider this data not to be present by considering
169+ // the end of the date range as the last successful data retrieval.
167170 if (DAYS .between (endOffset , lastPoll ) >= HISTORICAL_TIME_DAYS ) {
168171 String key = fitbitRequest .getUser ().getVersionedId ();
169172 offsets .put (key , endOffset );
You can’t perform that action at this time.
0 commit comments