fix: logging
This commit is contained in:
@@ -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:
|
||||||
|
|||||||
Reference in New Issue
Block a user