Skip to content

Commit

Permalink
Fix the bug that a client connecting to multiple servers only pulls f…
Browse files Browse the repository at this point in the history
…rom the first server (#274)
  • Loading branch information
LiSu committed Aug 16, 2023
1 parent 526e7d1 commit 3810908
Showing 1 changed file with 9 additions and 2 deletions.
11 changes: 9 additions & 2 deletions graphlearn/python/gsl/dag_dataset.py
Original file line number Diff line number Diff line change
Expand Up @@ -82,11 +82,18 @@ def next(self):
return self.next()
return result
else:
global_dag_state.inc(self._dag.name)
if res:
self._last_responses.append(res)
self.del_last_responses()
raise OutOfRangeError("OutOfRange")

if self._current_index < len(self._dag_datasets) - 1:
self._current_index = self._current_index + 1
return self.next()
else:
self._current_index = 0
# start the next epoch
global_dag_state.inc(self._dag.name)
raise OutOfRangeError("OutOfRange: end of epoch")

def close(self):
for dataset in self._dag_datasets:
Expand Down

0 comments on commit 3810908

Please sign in to comment.