switching version check to spark session (capitalone#321)

* switching version check to spark session * bumping version
rhaffar · Sep 11, 2024 · 988e425 · 988e425
1 parent 8dec01b
commit 988e425
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/datacompy/__init__.py b/datacompy/__init__.py
@@ -13,7 +13,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-__version__ = "0.13.1"
+__version__ = "0.13.2"
 
 import platform
 from warnings import warn

diff --git a/datacompy/spark/sql.py b/datacompy/spark/sql.py
@@ -48,8 +48,6 @@
         upper,
         when,
     )
-    from pyspark.version import __version__
-
 except ImportError:
     pass  # Let non-Spark people at least enjoy the loveliness of the spark sql datacompy functionality
 
@@ -210,7 +208,7 @@ def _validate_dataframe(
         """
         dataframe = getattr(self, index)
 
-        if __version__ >= "3.4.0":
+        if self.spark_session.version >= "3.4.0":
             import pyspark.sql.connect.dataframe
 
             instances = (pyspark.sql.DataFrame, pyspark.sql.connect.dataframe.DataFrame)