diff --git a/mkdocs.yml b/mkdocs.yml index 9bf512f9..70fe3246 100644 --- a/mkdocs.yml +++ b/mkdocs.yml @@ -120,7 +120,6 @@ nav: - Domain Model: - Compose a Domain: - - guides/compose-a-domain/index.md - guides/compose-a-domain/register-elements.md - guides/compose-a-domain/initialize-domain.md - guides/compose-a-domain/activate-domain.md diff --git a/src/protean/server/broker_subscription.py b/src/protean/server/broker_subscription.py index 6393c0e4..9567366b 100644 --- a/src/protean/server/broker_subscription.py +++ b/src/protean/server/broker_subscription.py @@ -114,7 +114,7 @@ async def shutdown(self): None """ self.keep_going = False # Signal to stop polling - logger.info(f"Shutting down subscription {self.subscriber_id}") + logger.debug(f"Shutting down subscription {self.subscriber_id}") async def get_next_batch_of_messages(self): """ diff --git a/src/protean/server/engine.py b/src/protean/server/engine.py index ee1d9566..bc3f525c 100644 --- a/src/protean/server/engine.py +++ b/src/protean/server/engine.py @@ -217,7 +217,7 @@ def run(self): """ Start the Protean Engine and run the subscriptions. """ - logger.info("Starting Protean Engine...") + logger.debug("Starting Protean Engine...") # Handle Signals signals = (signal.SIGHUP, signal.SIGTERM, signal.SIGINT) for s in signals: @@ -270,7 +270,8 @@ def handle_exception(loop, context): # Then immediately call and await the shutdown directly self.loop.run_until_complete(self.shutdown()) else: + logger.info("Protean Engine is running...") self.loop.run_forever() finally: self.loop.close() - logger.debug("Successfully shutdown Protean Engine.") + logger.info("Protean Engine has stopped.") diff --git a/src/protean/server/subscription.py b/src/protean/server/subscription.py index 76df9872..f6c279a7 100644 --- a/src/protean/server/subscription.py +++ b/src/protean/server/subscription.py @@ -131,7 +131,7 @@ async def shutdown(self): """ self.keep_going = False # Signal to stop polling await self.update_current_position_to_store() - logger.info(f"Shutting down subscription {self.subscriber_id}") + logger.debug(f"Shutting down subscription {self.subscriber_id}") async def fetch_last_position(self): """