Skip to content

Commit

Permalink
Pylint updates
Browse files Browse the repository at this point in the history
  • Loading branch information
Paul Nilsson committed Nov 4, 2024
1 parent e20a831 commit f60beed
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions pilot/user/rubin/esprocessfinegrainedproc.py
Original file line number Diff line number Diff line change
Expand Up @@ -60,17 +60,17 @@ def __init__(self, max_workers=None, thread_name_prefix='', initializer=None, in
self.outputs = {}
self._lock = threading.RLock()
self.max_workers = max_workers
super(ESRunnerThreadPool, self).__init__(max_workers=max_workers,
thread_name_prefix=thread_name_prefix,
initializer=initializer,
initargs=initargs)
super().__init__(max_workers=max_workers,
thread_name_prefix=thread_name_prefix,
initializer=initializer,
initargs=initargs)

def submit(self, fn, *args, **kwargs):
future = super(ESRunnerThreadPool, self).submit(fn, *args, **kwargs)
future = super().submit(fn, *args, **kwargs)
return future

def run_event(self, fn, event):
future = super(ESRunnerThreadPool, self).submit(fn, event)
future = super().submit(fn, event)
with self._lock:
self.futures[event['eventRangeID']] = {'event': event, 'future': future}

Expand Down

0 comments on commit f60beed

Please sign in to comment.