Run only test_external_browser_successful

Author: sfc-gh-turbaszek

ci/container/test_authentication.sh

@@ -19,7 +19,7 @@ export PYTHONPATH=$SOURCE_ROOT
 
 python3 -m pip install --break-system-packages -e ".[development]"
 
-python3 -m pytest test/auth/ --ignore=test/auth/aio
+#python3 -m pytest test/auth/ --ignore=test/auth/aio
 
 python3 -m pip install --break-system-packages -e ".[development,aio,aioboto]"
-python3 -m pytest -vvv test/auth/aio/
+python3 -m pytest -vvv test/auth/aio/ -k "test_external_browser_successful"

test/auth/aio/authorization_test_helper.py

@@ -76,50 +76,50 @@ async def connect_and_provide_credentials(
     ):
         import asyncio
 
-        try:
-            # Start connection as an async task in the main event loop
-            # This allows the browser to be opened from the main thread context
-            connect_task = asyncio.create_task(self.connect_and_execute_simple_query())
-
-            if self.auth_test_env == "docker":
-                # Give connection time to start and open the browser
-                await asyncio.sleep(5)
-
-                # Run browser automation in a thread
-                loop = asyncio.get_running_loop()
-                await loop.run_in_executor(
-                    None,
-                    self._provide_credentials,
-                    scenario,
-                    login,
-                    password,
-                )
+        # try:
+        # Start connection as an async task in the main event loop
+        # This allows the browser to be opened from the main thread context
+        connect_task = asyncio.create_task(self.connect_and_execute_simple_query())
 
-            # Wait for connection to complete
-            await connect_task
+        if self.auth_test_env == "docker":
+            # Give connection time to start and open the browser
+            await asyncio.sleep(5)
+
+            # Run browser automation in a thread
+            loop = asyncio.get_running_loop()
+            await loop.run_in_executor(
+                None,
+                self._provide_credentials,
+                scenario,
+                login,
+                password,
+            )
 
-        except Exception as e:
-            self.error_msg = e
-            logger.error(e)
+        # Wait for connection to complete
+        await connect_task
+
+        # except Exception as e:
+        #     self.error_msg = e
+        #     logger.error(e)
 
     def get_error_msg(self) -> str:
         return str(self.error_msg)
 
     async def connect_and_execute_simple_query(self):
-        try:
-            logger.info("Trying to connect to Snowflake")
-            async with snowflake.connector.aio.SnowflakeConnection(
-                **self.configuration
-            ) as con:
-                logger.info("Connected to Snowflake, executing query")
-                result = await con.cursor().execute("select 1;")
-                logger.debug(await result.fetchall())
-                logger.info("Successfully connected to Snowflake")
-                return True
-        except Exception as e:
-            self.error_msg = e
-            logger.error(e)
-            return False
+        # try:
+        logger.info("Trying to connect to Snowflake")
+        async with snowflake.connector.aio.SnowflakeConnection(
+            **self.configuration
+        ) as con:
+            logger.info("Connected to Snowflake, executing query")
+            result = await con.cursor().execute("select 1;")
+            logger.debug(await result.fetchall())
+            logger.info("Successfully connected to Snowflake")
+            return True
+        # except Exception as e:
+        #     self.error_msg = e
+        #     logger.error(e)
+        #     return False
 
     async def connect_and_execute_set_session_state(self, key: str, value: str):
         try: