Skip to content

Commit

Permalink
Signed commit
Browse files Browse the repository at this point in the history
Signed-off-by: Ankush Khanna <[email protected]>
  • Loading branch information
ankush-cohere committed Sep 12, 2024
1 parent 659b9a4 commit 7756502
Showing 1 changed file with 0 additions and 1 deletion.
1 change: 0 additions & 1 deletion compass_sdk/utils.py
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,6 @@ def imap_queued(executor: Executor, f: Callable[[T], U], it: Iterable[T], max_qu

for x in it:
futures_set.add(executor.submit(f, x))

while len(futures_set) > max_queued:
done, futures_set = futures.wait(futures_set, return_when=futures.FIRST_COMPLETED)
for future in done:
Expand Down

0 comments on commit 7756502

Please sign in to comment.