chaintool/chainsyncer
4
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Change result in threadpoolhistorysyncer

Browse Source
This commit is contained in:
nolash 2021-09-29 19:37:31 +02:00
parent d0c4aa5679
commit 30c574a74b
Signed by: lash
GPG Key ID: 21D2E7BB88C2A746
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
chainsyncer/driver/threadrange.py
View File

@ -76,7 +76,6 @@ class ThreadPoolRangeHistorySyncer:
for sync_range in self.ranges: for sync_range in self.ranges:
task = ThreadPoolRangeTask(self.src_backend, sync_range, self.chain_interface, filters=self.filters) task = ThreadPoolRangeTask(self.src_backend, sync_range, self.chain_interface, filters=self.filters)
t = self.worker_pool.apply_async(task.start_loop, (0.1,)) t = self.worker_pool.apply_async(task.start_loop, (0.1,))
print('result {}'.format(t.get())) logg.debug('result of worker {}: {}'.format(t, t.get()))
self.worker_pool.close() self.worker_pool.close()
self.worker_pool.join() self.worker_pool.join()