Skip to content

Commit 29d5b6d

Browse files
committed
Revert "update comments"
This reverts commit 130b518.
1 parent 130b518 commit 29d5b6d

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

google/cloud/dataproc_spark_connect/session.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -577,11 +577,11 @@ def _get_exiting_active_session(
577577
def getOrCreate(self) -> "DataprocSparkSession":
578578
with DataprocSparkSession._lock:
579579
if environment.is_dataproc_batch():
580-
# For Dataproc batch workloads, connect to the already initialized local SparkSession
580+
# For Dataproc batch workloads, connect to the initial Spark session
581581
from pyspark.sql import SparkSession as PySparkSQLSession
582582

583583
session = PySparkSQLSession.builder.getOrCreate()
584-
return session # type: ignore
584+
return session
585585

586586
# Handle custom session ID by setting it early and letting existing logic handle it
587587
if self._custom_session_id:

0 commit comments

Comments
 (0)