diff --git a/providers/apache/pig/src/airflow/providers/apache/pig/hooks/pig.py b/providers/apache/pig/src/airflow/providers/apache/pig/hooks/pig.py
index b067d5ab5316d..99a97c4cd5e12 100644
--- a/providers/apache/pig/src/airflow/providers/apache/pig/hooks/pig.py
+++ b/providers/apache/pig/src/airflow/providers/apache/pig/hooks/pig.py
@@ -22,11 +22,7 @@
 from typing import Any
 
 from airflow.exceptions import AirflowException
-
-try:
-    from airflow.sdk import BaseHook
-except ImportError:
-    from airflow.hooks.base import BaseHook  # type: ignore[attr-defined,no-redef]
+from airflow.providers.apache.pig.version_compat import BaseHook
 
 
 class PigCliHook(BaseHook):
diff --git a/providers/apache/pig/src/airflow/providers/apache/pig/version_compat.py b/providers/apache/pig/src/airflow/providers/apache/pig/version_compat.py
index e7a259afb357c..615e9c2f23db7 100644
--- a/providers/apache/pig/src/airflow/providers/apache/pig/version_compat.py
+++ b/providers/apache/pig/src/airflow/providers/apache/pig/version_compat.py
@@ -33,6 +33,12 @@ def get_base_airflow_version_tuple() -> tuple[int, int, int]:
 
 
 AIRFLOW_V_3_0_PLUS = get_base_airflow_version_tuple() >= (3, 0, 0)
+AIRFLOW_V_3_1_PLUS: bool = get_base_airflow_version_tuple() >= (3, 1, 0)
+
+if AIRFLOW_V_3_1_PLUS:
+    from airflow.sdk import BaseHook
+else:
+    from airflow.hooks.base import BaseHook  # type: ignore[attr-defined,no-redef]
 
 if AIRFLOW_V_3_0_PLUS:
     from airflow.sdk import BaseOperator
@@ -41,5 +47,7 @@ def get_base_airflow_version_tuple() -> tuple[int, int, int]:
 
 __all__ = [
     "AIRFLOW_V_3_0_PLUS",
+    "AIRFLOW_V_3_1_PLUS",
+    "BaseHook",
     "BaseOperator",
 ]