diff --git a/cardano_clusterlib/query_group.py b/cardano_clusterlib/query_group.py
index 628510e..db4be44 100644
--- a/cardano_clusterlib/query_group.py
+++ b/cardano_clusterlib/query_group.py
@@ -59,7 +59,7 @@ def get_utxo(
         Returns:
             List[structs.UTXOData]: A list of UTxO data.
         """
-        cli_args = ["utxo", "--out-file", "/dev/stdout"]
+        cli_args = ["utxo", "--output-json"]
 
         address_single = ""
         sort_results = False
@@ -300,7 +300,7 @@ def get_gov_action_deposit(self, pparams: dict[str, tp.Any] | None = None) -> in
     def get_stake_distribution(self) -> dict[str, float]:
         """Return current aggregated stake distribution per stake pool."""
         # Stake pool values are displayed starting with line 2 of the command output
-        result = self.query_cli(["stake-distribution"]).splitlines()[2:]
+        result = self.query_cli(["stake-distribution", "--output-text"]).splitlines()[2:]
         stake_distribution: dict[str, float] = {}
         for pool in result:
             pool_id, stake = pool.split()
@@ -309,7 +309,7 @@ def get_stake_distribution(self) -> dict[str, float]:
 
     def get_stake_pools(self) -> list[str]:
         """Return the node's current set of stake pool ids."""
-        stake_pools = self.query_cli(["stake-pools"]).splitlines()
+        stake_pools = self.query_cli(["stake-pools", "--output-text"]).splitlines()
         return stake_pools
 
     def get_leadership_schedule(
@@ -366,6 +366,7 @@ def get_leadership_schedule(
         unparsed = self.query_cli(
             [
                 "leadership-schedule",
+                "--output-text",
                 "--genesis",
                 str(self._clusterlib_obj.genesis_json),
                 "--vrf-signing-key-file",