compat: Bokeh 3.10.0 (#8716)

Co-authored-by: Philipp Rudiger <prudiger@anaconda.com>

Author: hoxbro

.github/workflows/build.yaml

@@ -19,7 +19,7 @@ concurrency:
 env:
   NODE_VERSION: "24"
   PACKAGE: "panel"
-  PYTHON_VERSION: "3.10"
+  PYTHON_VERSION: "3.12"
 
 jobs:
   waiting_room:

.github/workflows/test.yaml

@@ -114,23 +114,23 @@ jobs:
         run: |
           MATRIX=$(jq -nsc '{
               "os": ["ubuntu-latest", "macos-latest", "windows-latest"],
-              "environment": ["test-310", "test-314"]
+              "environment": ["test-312", "test-314"]
           }')
           echo "MATRIX=$MATRIX" >> $GITHUB_ENV
       - name: Set test matrix with 'full' option
         if: env.MATRIX_OPTION == 'full'
         run: |
           MATRIX=$(jq -nsc '{
               "os": ["ubuntu-latest", "macos-latest", "windows-latest"],
-              "environment": ["test-310", "test-311", "test-312", "test-313", "test-314"]
+              "environment": ["test-312", "test-313", "test-314"]
           }')
           echo "MATRIX=$MATRIX" >> $GITHUB_ENV
       - name: Set test matrix with 'downstream' option
         if: env.MATRIX_OPTION == 'downstream'
         run: |
           MATRIX=$(jq -nsc '{
               "os": ["ubuntu-latest"],
-              "environment": ["test-310"]
+              "environment": ["test-312"]
           }')
           echo "MATRIX=$MATRIX" >> $GITHUB_ENV
 
@@ -256,7 +256,7 @@ jobs:
       fail-fast: false
       matrix:
         os: ["ubuntu-latest"]
-        environment: ["test-core", "test-bokeh38"]
+        environment: ["test-core"]
     timeout-minutes: 30
     steps:
       - uses: holoviz-dev/holoviz_tasks/pixi-install@11eb638302f76ec64217e2eeddfb11df1f788b54 # v1.0.2

.gitignore

@@ -164,3 +164,4 @@ panel/_version.py
 .uicoveragerc
 mario_button.*
 counter_button.*
+/.claude/skills/developing-with-holoviz/skills/panel/reviewing-panel-apps.md

panel/_param.py

@@ -6,7 +6,7 @@
 from param import Parameter, _is_number
 
 AlignmentType = t.Literal["auto", "start", "center", "end"]
-Alignment = enumeration(AlignmentType)
+Alignment = enumeration(*t.get_args(AlignmentType))
 MarginType: t.TypeAlias = int | tuple[int, int] | tuple[int, int, int, int]
 
 

panel/command/__init__.py

@@ -95,7 +95,8 @@ def main(args: list[str] | None = None):
                     raise e
                 die("ERROR: " + str(e))
         else:
-            ret = bokeh_entry_point()
+            bokeh_entry_point()
+            ret = None
     else:
         parser.parse_args(sys.argv[1:])
         sys.exit(1)

panel/command/serve.py

@@ -461,14 +461,13 @@ def setup_file():
         if args.warm or config.autoreload:
             argvs = {f: args.args for f in files}
             applications = build_single_handler_applications(files, argvs)
-            initialize_session = not (args.num_procs != 1 and sys.version_info < (3, 12))
             if config.autoreload:
                 with record_modules(list(applications.values())):
                     self.warm_applications(
-                        applications, args.reuse_sessions, error=False, initialize_session=initialize_session, index=kwargs['index']
+                        applications, args.reuse_sessions, error=False, index=kwargs['index']
                     )
             else:
-                self.warm_applications(applications, args.reuse_sessions, initialize_session=initialize_session, index=kwargs['index'])
+                self.warm_applications(applications, args.reuse_sessions, index=kwargs['index'])
 
         # Disable Tornado's autoreload
         if args.dev:

panel/config.py

@@ -15,7 +15,6 @@
 import typing as t
 import warnings
 
-from concurrent.futures import ThreadPoolExecutor
 from contextlib import contextmanager
 from weakref import WeakKeyDictionary
 
@@ -397,15 +396,16 @@ def __init__(self, **params):
 
     @param.depends('_nthreads', watch=True, on_init=True)
     def _set_thread_pool(self):
+        from .io.state import _SharedThreadPoolExecutor
         if self.nthreads is None:
             if state._thread_pool is not None:
-                state._thread_pool.shutdown(wait=False)
+                state._thread_pool.shutdown(wait=False, _shared=False)
             state._thread_pool = None
             return
         if state._thread_pool:
             raise RuntimeError("Thread pool already running")
         threads = self.nthreads if self.nthreads else None
-        state._thread_pool = ThreadPoolExecutor(max_workers=threads)
+        state._thread_pool = _SharedThreadPoolExecutor(max_workers=threads)
 
     @param.depends('notifications', watch=True)
     def _setup_notifications(self):

panel/custom.py

@@ -571,7 +571,7 @@ def _get_model(
         parent: Model | None = None, comm: Comm | None = None
     ) -> Model:
         props = self._get_properties(doc)
-        model = self._bokeh_model(**props)
+        model = self._bokeh_model(**props) # type: ignore[abstract]
         root = root or model
         children, _ = self._get_children(model.data, doc, root, model, comm)
         model.data.update(**children)

panel/entry_points.py

@@ -10,14 +10,7 @@
 
 
 def entry_points_for(group: str) -> Iterator[importlib.metadata.EntryPoint]:
-    try:
-        eps = importlib.metadata.entry_points(group=group)
-    except TypeError:
-        # Load-time selection requires Python >= 3.10 or importlib_metadata >= 3.6,
-        # so we'll retain this fallback logic for some time to come.  See also
-        # https://importlib-metadata.readthedocs.io/en/latest/using.html
-        eps = importlib.metadata.entry_points().get(group, [])  # type: ignore[arg-type]
-    yield from eps
+    yield from importlib.metadata.entry_points(group=group)
 
 
 def load_entry_points(group: str) -> None:

panel/io/callbacks.py

@@ -172,11 +172,11 @@ def start(self):
         self._start_time = time.time()
         if state.curdoc and state.curdoc.session_context and not state._is_pyodide and self.session_scoped:
             self._doc = state.curdoc
-            if state._unblocked(state.curdoc):
-                self._cb = self._doc.add_periodic_callback(self._periodic_callback, self.period)
-            else:
-                self._doc.add_next_tick_callback(self.start)
-        elif state._thread_id and state._thread_id != state._current_thread:
+            # Bokeh schedules periodic callbacks in a threadsafe manner so we
+            # can register directly even when initialization runs on a worker
+            # thread rather than the server event loop thread.
+            self._cb = self._doc.add_periodic_callback(self._periodic_callback, self.period)
+        elif not state._on_loop_thread:
             state.execute(self.start, schedule=True)
         else:
             try: