We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2a2a497 commit b15506cCopy full SHA for b15506c
src/neptune_query/internal/retrieval/series.py
@@ -184,7 +184,7 @@ def _make_new_series_page_params(
184
if series.HasField("searchAfter")
185
}
186
187
- if not updated_request_tokens:
+ if not updated_request_tokens: # no progress, stop fetching
188
return None
189
190
new_requests = [
@@ -193,5 +193,8 @@ def _make_new_series_page_params(
193
if request["requestId"] in existing_series and request["requestId"] not in finished_requests
194
]
195
196
+ if not new_requests: # all requests are finished
197
+ return None
198
+
199
params["requests"] = new_requests
200
return params
0 commit comments