"Runner started" log info
This commit is contained in:
@@ -211,12 +211,11 @@ class BlockStateRunner(BlockProgressor):
|
|||||||
|
|
||||||
async def worker(self):
|
async def worker(self):
|
||||||
try:
|
try:
|
||||||
log.debug(f'runner worker started')
|
log.info(f'Runner started')
|
||||||
w3 = current_w3.get()
|
w3 = current_w3.get()
|
||||||
chain = current_chain.get()
|
chain = current_chain.get()
|
||||||
assert chain.id == await w3.eth.chain_id
|
assert chain.id == await w3.eth.chain_id
|
||||||
current_clock.set(BlockClock())
|
current_clock.set(BlockClock())
|
||||||
fork = None
|
|
||||||
while self.running:
|
while self.running:
|
||||||
try:
|
try:
|
||||||
await asyncio.wait_for(self.new_head_event.wait(), timeout=1) # todo configure
|
await asyncio.wait_for(self.new_head_event.wait(), timeout=1) # todo configure
|
||||||
|
|||||||
Reference in New Issue
Block a user