RanchiMall/pyflo
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

connector

Browse Source
This commit is contained in:
4tochka 2019-05-07 03:10:47 +04:00
parent 737139ba4d
commit 976ad9f64f
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pybtc/connector/block_loader.py
View File

@ -7,7 +7,7 @@ import logging
import signal import signal
import sys import sys
import aiojsonrpc import aiojsonrpc
import traceback
class BlockLoader: class BlockLoader:
def __init__(self, parent, workers=4): def __init__(self, parent, workers=4):
self.worker = dict() self.worker = dict()
@ -56,6 +56,8 @@ class BlockLoader:
self.log.warning("<<<<<") self.log.warning("<<<<<")
self.pipe_sent_msg(self.worker[i].writer, b'get', batch) self.pipe_sent_msg(self.worker[i].writer, b'get', batch)
self.log.warning("ok<") self.log.warning("ok<")
except:
self.log.warning(str(traceback.format_exc()))
finally: finally:
self.worker_busy[i] = False self.worker_busy[i] = False
return None return None