connector

This commit is contained in:
4tochka 2019-05-07 02:58:30 +04:00
parent ee1e191c53
commit 737139ba4d

View File

@ -55,6 +55,7 @@ class BlockLoader:
try:
self.log.warning("<<<<<")
self.pipe_sent_msg(self.worker[i].writer, b'get', batch)
self.log.warning("ok<")
finally:
self.worker_busy[i] = False
return None