fix: logging

This commit is contained in:
Vlad Stan
2026-02-09 08:53:33 +02:00
parent d40515e1ba
commit 561d0976b3
+9 -5
View File
@@ -150,12 +150,16 @@ class LightsparkSparkWallet(Wallet):
) )
print("### Spark sidecar DONE") print("### Spark sidecar DONE")
await asyncio.to_thread(
self._log_process_output, process
)
# if process.stdout: def _log_process_output(self, process: subprocess.Popen):
# for line in process.stdout: if process.stdout:
# logger.info(f"Spark: {line}", end="") for line in process.stdout:
# else: logger.info(f"Spark: {line}", end="")
# logger.warning(" No output captured for Spark sidecar.") else:
logger.warning(" No output captured for Spark sidecar.")
async def cleanup(self): async def cleanup(self):
try: try: