Skip to content

Commit bfcdc21

Browse files
authored
Revert #1312 (#1357)
Signed-off-by: Kevin Su <pingsutw@apache.org>
1 parent 5242d77 commit bfcdc21

4 files changed

Lines changed: 2 additions & 23 deletions

File tree

examples/plugins/dask_example.py

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -9,24 +9,8 @@
99
import flyte.storage
1010
from flyte import Resources
1111

12-
# The scheduler and worker pods inherit this image (Scheduler()/WorkerGroup() below leave
13-
# image unset), and the Dask K8s operator launches them via the standalone `dask-scheduler`
14-
# and `dask-worker` commands. Those console scripts were removed from `distributed` in
15-
# 2026.6.0 (replaced by the `dask scheduler` / `dask worker` subcommands), so a newer
16-
# dask[distributed] makes the cluster pods crash-loop with
17-
# "dask-scheduler: executable file not found in $PATH". Pin below 2026.6.0 to keep them.
18-
# (flyteplugins-dask caps this itself as of the next release; the explicit pin here keeps
19-
# the example working against the currently-published, un-capped plugin.)
20-
#
21-
# connectrpc<0.11 keeps the runtime from hitting "'Headers' object is not callable":
22-
# connectrpc 0.11 turned RequestContext.request_headers into a property, which the flyte
23-
# auth interceptor (method-call style) can't use. flyte>=2.5.10 caps this too, but pinning
24-
# here guarantees a clean rebuild picks up a compatible connectrpc.
2512
image = flyte.Image.from_debian_base(python_version=(3, 12)).with_pip_packages(
2613
"flyteplugins-dask",
27-
"dask[distributed]<2026.6.0",
28-
"connectrpc<0.11",
29-
"bokeh",
3014
)
3115

3216
dask_config = Dask(

plugins/dask/pyproject.toml

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -6,12 +6,7 @@ readme = "README.md"
66
authors = [{ name = "Kevin Su", email = "pingsutw@users.noreply.github.com" }]
77
requires-python = ">=3.10"
88
dependencies = [
9-
# Cap below 2026.6.0: distributed removed the standalone `dask-scheduler` /
10-
# `dask-worker` console scripts in that release (deprecated back in 2022.10.0 in
11-
# favor of the `dask scheduler` / `dask worker` subcommands). The Dask K8s operator
12-
# still launches cluster pods via the old commands, so a newer distributed makes the
13-
# scheduler/worker pods crash-loop with "dask-scheduler: executable file not found".
14-
"dask[distributed]>=2022.10.2,<2026.6.0",
9+
"dask[distributed]>=2022.10.2",
1510
"flyte",
1611
"bokeh"
1712
]

plugins/dask/uv.lock

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

plugins/sglang/src/flyteplugins/__init__.py

Whitespace-only changes.

0 commit comments

Comments
 (0)