Loading poolpay/director/Director.py +3 −1 Original line number Diff line number Diff line Loading @@ -193,7 +193,9 @@ class Director: try: receipt.successful = self._handle_message(message) except Exception: logging.exception("Error occurred while processing message, continuing anyway") logging.exception( "Error occurred while processing message, continuing anyway" ) finally: db.session.commit() Loading poolpay/wire/ingest/__main__.py +3 −2 Original line number Diff line number Diff line Loading @@ -17,6 +17,7 @@ logging.basicConfig( level=logging.DEBUG, format="[%(levelname)s] <%(module)s.%(funcName)s> %(message)s" ) def _decrypt_if_necessary(content: str) -> str: if content.startswith("-----BEGIN AGE ENCRYPTED FILE-----"): identity_string = "\n".join( Loading Loading @@ -72,9 +73,9 @@ def ingest( client = Client(socket_path) for m in messages: logging.info(f"Sending message {m["uuid"]}") logging.info(f"Sending message {m['uuid']}") client.send(m) logging.info(f"Sent message") logging.info("Sent message") if __name__ == "__main__": Loading Loading
poolpay/director/Director.py +3 −1 Original line number Diff line number Diff line Loading @@ -193,7 +193,9 @@ class Director: try: receipt.successful = self._handle_message(message) except Exception: logging.exception("Error occurred while processing message, continuing anyway") logging.exception( "Error occurred while processing message, continuing anyway" ) finally: db.session.commit() Loading
poolpay/wire/ingest/__main__.py +3 −2 Original line number Diff line number Diff line Loading @@ -17,6 +17,7 @@ logging.basicConfig( level=logging.DEBUG, format="[%(levelname)s] <%(module)s.%(funcName)s> %(message)s" ) def _decrypt_if_necessary(content: str) -> str: if content.startswith("-----BEGIN AGE ENCRYPTED FILE-----"): identity_string = "\n".join( Loading Loading @@ -72,9 +73,9 @@ def ingest( client = Client(socket_path) for m in messages: logging.info(f"Sending message {m["uuid"]}") logging.info(f"Sending message {m['uuid']}") client.send(m) logging.info(f"Sent message") logging.info("Sent message") if __name__ == "__main__": Loading