diff --git a/setup.py b/setup.py index 8c924fc0a3..331e22d4ac 100644 --- a/setup.py +++ b/setup.py @@ -85,7 +85,7 @@ kwargs = dict( "chia_farmer = src.server.start_farmer:main", "chia_introducer = src.server.start_introducer:main", "chia_timelord = src.server.start_timelord:main", - "chia_timelord_launcher = src.timelord_launcher:main", + "chia_timelord_launcher = src.timelord.timelord_launcher:main", "chia_full_node_simulator = src.simulator.start_simulator:main", ] }, diff --git a/src/full_node/full_node_api.py b/src/full_node/full_node_api.py index e90594c46c..2bae83f442 100644 --- a/src/full_node/full_node_api.py +++ b/src/full_node/full_node_api.py @@ -620,7 +620,8 @@ class FullNodeAPI: prev_sb = None else: self.log.warning( - f"Making a non-genesis block. curr total iters{curr.total_iters} {total_iters_pos_slot + sp_iters}" + f"Making a non-genesis block. curr total iters{curr.total_iters} " + f"{total_iters_pos_slot + sp_iters}" ) pool_target = request.pool_target prev_sb = curr diff --git a/src/server/server.py b/src/server/server.py index c6b9ef7c4b..2b57cc0407 100644 --- a/src/server/server.py +++ b/src/server/server.py @@ -391,10 +391,10 @@ class ChiaServer: await self.app_shut_down_task if self.site_shutdown_task is not None: await self.site_shutdown_task - - _, pending = await asyncio.wait(self.api_tasks, timeout=3, return_when=asyncio.ALL_COMPLETED) - for task in pending: - task.cancel() + if len(self.api_tasks) > 0: + _, pending = await asyncio.wait(self.api_tasks, timeout=3, return_when=asyncio.ALL_COMPLETED) + for task in pending: + task.cancel() async def get_peer_info(self) -> Optional[PeerInfo]: ip = None diff --git a/src/timelord/timelord.py b/src/timelord/timelord.py index 3363701eb5..bc7b57cd59 100644 --- a/src/timelord/timelord.py +++ b/src/timelord/timelord.py @@ -103,7 +103,6 @@ class Timelord: async with self.lock: client_ip = writer.get_extra_info("peername")[0] log.info(f"New timelord connection from client: {client_ip}.") - # print(client_ip, self.ip_whitelist) if client_ip in self.ip_whitelist: self.free_clients.append((client_ip, reader, writer)) log.info(f"Added new VDF client {client_ip}.") @@ -220,6 +219,7 @@ class Timelord: self.iters_to_submit[Chain.CHALLENGE_CHAIN].append(left_subslot_iters) self.iters_to_submit[Chain.REWARD_CHAIN].append(left_subslot_iters) self.iteration_to_proof_type[left_subslot_iters] = IterationType.END_OF_SUBSLOT + log.warning(f"Iters to submit {self.iters_to_submit}") for chain, iters in self.iters_to_submit.items(): for iteration in iters: @@ -697,7 +697,7 @@ class Timelord: # Send (a, b) from 'initial_form'. for num in [initial_form.a, initial_form.b]: prefix_l = len(str(num)) - prefix_len = len(str(prefix)) + prefix_len = len(str(prefix_l)) writer.write((str(prefix_len) + str(prefix_l) + str(num)).encode()) await writer.drain() try: diff --git a/tests/pytest.ini b/tests/pytest.ini index 5add771687..6adc42a252 100644 --- a/tests/pytest.ini +++ b/tests/pytest.ini @@ -1,5 +1,5 @@ [pytest] ; logging options log_cli = 1 -log_level = WARNING +log_level = INFO log_format = %(asctime)s %(name)s: %(levelname)s %(message)s