Skip to content

Commit

Permalink
Backport of commit from Celery branch to fix off by one error
Browse files Browse the repository at this point in the history
  • Loading branch information
BenGalewsky committed Jul 22, 2024
1 parent 7c671fa commit b5e671b
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion src/servicex_did_finder_lib/communication.py
Original file line number Diff line number Diff line change
@@ -51,7 +51,10 @@ def send_on(self, count):
if self._hold_till_end:
self._hold_till_end = False
files = sorted(self._file_cache, key=lambda x: x["paths"])
self.send_bulk(files[:count])
if count == -1:
self.send_bulk(files)
else:
self.send_bulk(files[:count])

def send_bulk(self, file_list: List[Dict[str, Any]]):
"does a bulk put of files"

0 comments on commit b5e671b

Please sign in to comment.