Fix test connectivity issue by allowing lazy connection initialization

Co-authored-by: BeatsuDev <[email protected]>

Author: Copilot

tibber/account.py

@@ -30,7 +30,7 @@ def __init__(
         self._token: str = token
         self.user_agent = user_agent
 
-        super().__init__(transport_kwargs=transport_kwargs)
+        super().__init__(transport_kwargs=transport_kwargs, connect_on_init=immediate_update)
 
         if immediate_update:
             self.fetch_all()

tibber/networking/query_executor.py

@@ -17,23 +17,31 @@
 class QueryExecutor:
     """A class for executing queries."""
 
-    def __init__(self, session=None, transport_kwargs={}):
+    def __init__(self, session=None, transport_kwargs={}, connect_on_init=True):
         self.gql_client = None
+        self.session = None
         transport = AIOHTTPTransport(
             url=API_ENDPOINT,
             headers={"Authorization": "Bearer " + self.token},
             ssl=True,
             **transport_kwargs,
         )
         self.gql_client = gql.Client(
-            transport=transport, fetch_schema_from_transport=True
+            transport=transport, fetch_schema_from_transport=False
         )
 
-        asyncio.run(self.__ainit__(session))
+        if connect_on_init:
+            asyncio.run(self.__ainit__(session))
 
     async def __ainit__(self, session):
         self.session = session or await self.gql_client.connect_async()
         asyncio_atexit.register(self.gql_client.close_async)
+    
+    async def _ensure_connected(self):
+        """Ensure the client is connected before executing queries."""
+        if self.session is None:
+            self.session = await self.gql_client.connect_async()
+            asyncio_atexit.register(self.gql_client.close_async)
 
     def execute_query(
         self, access_token: str, query: str, max_tries: int = 1, **kwargs
@@ -89,6 +97,7 @@ async def execute_async(
         return result
 
     async def execute_async_single(self, access_token: str, query: str):
+        await self._ensure_connected()
         try:
             result = await self.gql_client.execute_async(gql.gql(query))
         except TransportQueryError as e: