Chore!: bump sqlglot to v25.20.1 (#3100)

Author: georgesittas

setup.py

@@ -47,7 +47,7 @@
         "requests",
         "rich[jupyter]",
         "ruamel.yaml",
-        "sqlglot[rs]~=25.19.0",
+        "sqlglot[rs]~=25.20.1",
     ],
     extras_require={
         "bigquery": [

sqlmesh/core/console.py

@@ -215,7 +215,7 @@ def plan(
 
     @abc.abstractmethod
     def log_test_results(
-        self, result: unittest.result.TestResult, output: str, target_dialect: str
+        self, result: unittest.result.TestResult, output: t.Optional[str], target_dialect: str
     ) -> None:
         """Display the test result and output.
 
@@ -985,7 +985,7 @@ def _prompt_promote(self, plan_builder: PlanBuilder) -> None:
             plan_builder.apply()
 
     def log_test_results(
-        self, result: unittest.result.TestResult, output: str, target_dialect: str
+        self, result: unittest.result.TestResult, output: t.Optional[str], target_dialect: str
     ) -> None:
         divider_length = 70
         if result.wasSuccessful():
@@ -1477,7 +1477,7 @@ def radio_button_selected(change: t.Dict[str, t.Any]) -> None:
         self.display(radio)
 
     def log_test_results(
-        self, result: unittest.result.TestResult, output: str, target_dialect: str
+        self, result: unittest.result.TestResult, output: t.Optional[str], target_dialect: str
     ) -> None:
         import ipywidgets as widgets
 
@@ -1786,7 +1786,7 @@ def _show_categorized_snapshots(self, plan: Plan, default_catalog: t.Optional[st
             self._print("\n```")
 
     def log_test_results(
-        self, result: unittest.result.TestResult, output: str, target_dialect: str
+        self, result: unittest.result.TestResult, output: t.Optional[str], target_dialect: str
     ) -> None:
         # import ipywidgets as widgets
         if result.wasSuccessful():
@@ -2079,7 +2079,7 @@ def show_model_difference_summary(
             self._write(f"  Modified: {modified}")
 
     def log_test_results(
-        self, result: unittest.result.TestResult, output: str, target_dialect: str
+        self, result: unittest.result.TestResult, output: t.Optional[str], target_dialect: str
     ) -> None:
         self._write("Test Results:", result)
 

sqlmesh/core/constants.py

@@ -41,7 +41,7 @@
         MAX_FORK_WORKERS: t.Optional[int] = int(os.getenv("MAX_FORK_WORKERS"))  # type: ignore
     except TypeError:
         MAX_FORK_WORKERS = (
-            len(os.sched_getaffinity(0)) if hasattr(os, "sched_getaffinity") else None
+            len(os.sched_getaffinity(0)) if hasattr(os, "sched_getaffinity") else None  # type: ignore
         )
 else:
     MAX_FORK_WORKERS = 1

sqlmesh/integrations/github/cicd/controller.py

@@ -665,7 +665,9 @@ def update_test_check(
         """
 
         def conclusion_handler(
-            conclusion: GithubCheckConclusion, result: unittest.result.TestResult, output: str
+            conclusion: GithubCheckConclusion,
+            result: t.Optional[unittest.result.TestResult],
+            output: t.Optional[str],
         ) -> t.Tuple[GithubCheckConclusion, str, t.Optional[str]]:
             if result:
                 # Clear out console

web/server/console.py

@@ -238,7 +238,7 @@ def log_event(
         )
 
     def log_test_results(
-        self, result: unittest.result.TestResult, output: str, target_dialect: str
+        self, result: unittest.result.TestResult, output: t.Optional[str], target_dialect: str
     ) -> None:
         if result.wasSuccessful():
             self.log_event(