rebalance: log errors of our own channels

daywalker90 · daywalker90 · commit e12241b2eb1d · 2025-12-15T15:35:17.000+01:00
diff --git a/rebalance/rebalance.py b/rebalance/rebalance.py
@@ -535,10 +535,12 @@ def rebalance(
                 erring_channel = e.error.get("data", {}).get("erring_channel")
                 erring_direction = e.error.get("data", {}).get("erring_direction")
                 if erring_channel == incoming_scid:
+                    plugin.log(f"Error with incoming channel: {e}")
                     raise RpcError(
                         "rebalance", payload, {"message": "Error with incoming channel"}
                     )
                 if erring_channel == outgoing_scid:
+                    plugin.log(f"Error with outgoing channel: {e}")
                     raise RpcError(
                         "rebalance", payload, {"message": "Error with outgoing channel"}
                     )

Original file line number	Diff line number	Diff line change
`@@ -535,10 +535,12 @@ def rebalance(`
`535`	`535`	`erring_channel = e.error.get("data", {}).get("erring_channel")`
`536`	`536`	`erring_direction = e.error.get("data", {}).get("erring_direction")`
`537`	`537`	`if erring_channel == incoming_scid:`
	`538`	`+ plugin.log(f"Error with incoming channel: {e}")`
`538`	`539`	`raise RpcError(`
`539`	`540`	`"rebalance", payload, {"message": "Error with incoming channel"}`
`540`	`541`	`)`
`541`	`542`	`if erring_channel == outgoing_scid:`
	`543`	`+ plugin.log(f"Error with outgoing channel: {e}")`
`542`	`544`	`raise RpcError(`
`543`	`545`	`"rebalance", payload, {"message": "Error with outgoing channel"}`
`544`	`546`	`)`