Skip to content

Commit f793224

Browse files
Cut unused code
1 parent 4f65a38 commit f793224

File tree

1 file changed

+0
-15
lines changed

1 file changed

+0
-15
lines changed

bio2zarr/core.py

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -201,11 +201,6 @@ def get_progress():
201201
return val
202202

203203

204-
def set_progress(value):
205-
with _progress_counter.get_lock():
206-
_progress_counter.value = value
207-
208-
209204
def setup_progress_counter(counter):
210205
global _progress_counter
211206
_progress_counter = counter
@@ -270,16 +265,6 @@ def submit(self, *args, **kwargs):
270265
self.futures.add(future)
271266
return future
272267

273-
def wait_for_completed(self, timeout=None):
274-
done, not_done = cf.wait(self.futures, timeout, cf.FIRST_COMPLETED)
275-
for future in done:
276-
exception = future.exception()
277-
# TODO do the check for BrokenProcessPool here
278-
if exception is not None:
279-
raise exception
280-
self.futures = not_done
281-
return done
282-
283268
def results_as_completed(self):
284269
for future in cf.as_completed(self.futures):
285270
yield future.result()

0 commit comments

Comments
 (0)