fix: pysparkvalue error

Author: zhiweilin-svg

google/cloud/dataproc_spark_connect/session.py

@@ -519,7 +519,7 @@ def _get_exiting_active_session(
             self,
         ) -> Optional["DataprocSparkSession"]:
             s8s_session_id = DataprocSparkSession._active_s8s_session_id
-            session_name = f"projects/{self._project_id}/locations/{self._region}/sessions/{s8s_session_id}"
+            session_name = f"sc://projects/{self._project_id}/locations/{self._region}/sessions/{s8s_session_id}"
             session_response = None
             session = None
             if s8s_session_id is not None:

tests/unit/test_session.py

@@ -2312,18 +2312,20 @@ def test_create_session_with_client_environment_label(
                 expected_request.session.labels["dataproc-session-client"] = (
                     env_label
                 )
+                expected_request.session.environment_config.execution_config.subnetwork_uri = "projects/google.com:hadoop-cloud-dev/regions/us-central1/subnetworks/svls-bugbash-vpc"
 
                 try:
                     # Reset singleton state before each subtest run
                     DataprocSparkSession._active_s8s_session_id = None
                     DataprocSparkSession._default_session = None
 
-                    # Set up project and region for the builder
-                    session = (
-                        DataprocSparkSession.builder.projectId("test-project")
-                        .location("test-region")
-                        .getOrCreate()
-                    )
+                    with mock.patch.dict(os.environ, {"DATAPROC_SPARK_CONNECT_SUBNET": "projects/google.com:hadoop-cloud-dev/regions/us-central1/subnetworks/svls-bugbash-vpc"}):
+                        # Set up project and region for the builder
+                        session = (
+                            DataprocSparkSession.builder.projectId("test-project")
+                            .location("test-region")
+                            .getOrCreate()
+                        )
 
                     mock_get_client_environment_label.assert_called_once()
                     mock_session_controller_client_instance.create_session.assert_called_once_with(