Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Test bokeh3.4 RC in tests #8565

Open
wants to merge 1 commit into
base: main
Choose a base branch
from
Open

Conversation

quasiben
Copy link
Member

@quasiben quasiben commented Mar 8, 2024

Bokeh 3.4 has a new release candidate: 3.4.0rc1 . @bryevdv asked that we test before the upcoming release next week.

@quasiben quasiben requested a review from fjetter as a code owner March 8, 2024 16:34
@quasiben quasiben changed the title Test bokeh3.4 rc1 in tests Test bokeh3.4 RC in tests Mar 8, 2024
Copy link
Contributor

github-actions bot commented Mar 8, 2024

Unit Test Results

See test report for an extended history of previous test failures. This is useful for diagnosing flaky tests.

    27 files  ± 0      27 suites  ±0   9h 57m 13s ⏱️ + 3m 28s
 4 050 tests ± 0   3 923 ✅  - 15    110 💤 ±0  17 ❌ +15 
50 854 runs  +18  48 479 ✅  -  6  2 334 💤  - 6  41 ❌ +30 

For more details on these failures, see this check.

Results for commit 7895a22. ± Comparison against base commit 0438768.

♻️ This comment has been updated with latest results.

@bryevdv
Copy link
Contributor

bryevdv commented Mar 8, 2024

There seem to be a lot of test failures but at least skimming through, they don't appear related to Bokeh at all. I was really just interested in a basic smoke test, i.e. someone who runs the dashboard often to try and update their installed Bokeh to 3.4.0rc1 and see that things seem to be working as usual (I don't run dask code with any regularity at all so I'm not a great person to try and compare)

@bryevdv
Copy link
Contributor

bryevdv commented Mar 8, 2024

OK I dug up my trivial script and AFAICT everything is working 🤷 I do see on deprecation for yall to handle at some point:

In [27]: for _ in range (50): df.groupby('name').mean().compute()
BokehDeprecationWarning: 'square() method' was deprecated in Bokeh 3.4.0 and will be removed, use "scatter(marker='square', ...) instead" instead.

In any case I am not going to hold up the planned release Monday unless something else comes up.


FYI I did get an error when running this (my previous smoke test) but as far as I can see it's not related to Bokeh at all:

from dask.distributed import Client, progress
import dask
import dask.dataframe as dd
from sklearn.linear_model import LinearRegression

client = Client(threads_per_worker=4,
                n_workers=2, memory_limit='2GB')

df = dask.datasets.timeseries()

def train(partition):
    est = LinearRegression()
    est.fit(partition[['x']].values, partition.y.values)
    return est

df.groupby('name').apply(train, meta=object).compute()

stack trace:

In [30]: df.groupby('name').apply(train, meta=object).compute()
/Users/bryan/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/dask/dataframe/core.py:7234: FutureWarning: Meta is not valid, `map_partitions` and `map_overlap` expects output to be a pandas object. Try passing a pandas object as meta or a dict or tuple representing the (name, dtype) of the columns. In the future the meta you passed will not work.
  warnings.warn(
2024-03-08 15:19:52,624 - distributed.protocol.core - CRITICAL - Failed to deserialize
Traceback (most recent call last):
  File "/Users/bryan/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/distributed/protocol/core.py", line 160, in loads
    return msgpack.loads(
           ^^^^^^^^^^^^^^
  File "/Users/bryan/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/msgpack/fallback.py", line 136, in unpackb
    raise ExtraData(ret, unpacker._get_extradata())
msgpack.exceptions.ExtraData: unpack(b) received extra data.
2024-03-08 15:19:52,626 - distributed.core - ERROR - Exception while handling op register-client
Traceback (most recent call last):
  File "/Users/bryan/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/distributed/core.py", line 968, in _handle_comm
    result = await result
             ^^^^^^^^^^^^
  File "/Users/bryan/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/distributed/scheduler.py", line 5532, in add_client
    await self.handle_stream(comm=comm, extra={"client": client})
  File "/Users/bryan/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/distributed/core.py", line 1023, in handle_stream
    msgs = await comm.read()
           ^^^^^^^^^^^^^^^^^
  File "/Users/bryan/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/distributed/comm/tcp.py", line 248, in read
    msg = await from_frames(
          ^^^^^^^^^^^^^^^^^^
  File "/Users/bryan/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/distributed/comm/utils.py", line 78, in from_frames
    res = _from_frames()
          ^^^^^^^^^^^^^^
  File "/Users/bryan/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/distributed/comm/utils.py", line 61, in _from_frames
    return protocol.loads(
           ^^^^^^^^^^^^^^^
  File "/Users/bryan/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/distributed/protocol/core.py", line 160, in loads
    return msgpack.loads(
           ^^^^^^^^^^^^^^
  File "/Users/bryan/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/msgpack/fallback.py", line 136, in unpackb
    raise ExtraData(ret, unpacker._get_extradata())
msgpack.exceptions.ExtraData: unpack(b) received extra data.
Task exception was never retrieved
future: <Task finished name='Task-69478' coro=<Server._handle_comm() done, defined at /Users/bryan/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/distributed/core.py:874> exception=ExtraData(({'op': 'update-graph', 'graph_header': {'serializer': 'pickle', 'writeable': (True, True, True, True, True, True, True, True)}, 'graph_frames': (b'\x80\x05\x95(\x1d\x00\x00\x00\x00\x00\x00\x8c\x1edistributed.protocol.serialize\x94\x8c\x08ToPickle\x94\x93\x94)\x81\x94}\x94\x8c\x04data\x94\x8c\x13dask.highlevelgraph\x94\x8c\x0eHighLevelGraph\x94\x93\x94)\x81\x94}\x94(\x8c\x0cdependencies\x94}\x94(\x8c2to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x94\x8f\x94(\x8c,shuffle_p2p-53ff43a5dbe7c86e569229a3f1e1637e\x94\x90h\x0f\x8f\x94(\x8c\'assign-7f71bea5bc88090c2956e831e52f0c2b\x94\x90h\x11\x8f\x94u\x8c\x10key_dependencies\x94}\x94\x8c\x06layers\x94}\x94(h\r\x8c\x0edask.blockwise\x94\x8c\tBlockwise\x94\x93\x94)\x81\x94}\x94(\x8c\x0bannotations\x94N\x8c\x16collection_annotations\x94N\x8c\x06output\x94h\r\x8c\x0eoutput_indices\x94\x8c\x02.0\x94\x85\x94\x8c\routput_blocks\x94N\x8c\x03dsk\x94}\x94(h\r\x8c\tfunctools\x94\x8c\x07partial\x94\x93\x94\x8c\x17dask.dataframe._pyarrow\x94\x8c\x10_to_string_dtype\x94\x93\x94\x85\x94R\x94(h*)}\x94(\x8c\x0bdtype_check\x94h(\x8c\x16is_object_string_dtype\x94\x93\x94\x8c\x0bindex_check\x94h(\x8c\x16is_object_string_index\x94\x93\x94\x8c\x0cstring_dtype\x94\x8c\x07pyarrow\x94uNt\x94b\x8c)train-8033d89230e988340266fdf415b5307a_.0\x94\x86\x94h7(\x8c\ndask.utils\x94\x8c\x05apply\x94\x93\x94\x8c\x13dask.dataframe.core\x94\x8c\x11apply_and_enforce\x94\x93\x94]\x94(\x8c8drop_by_shallow_copy-d929683038e3a9eec5fa87589d6b2ca0_.0\x94\x8c\x13__dask_blockwise__0\x94\x8c\x13__dask_blockwise__1\x94\x8c\x13__dask_blockwise__2\x94e\x8c\x08builtins\x94\x8c\x04dict\x94\x93\x94]\x94(]\x94(\x8c\x05_func\x94\x8c\x16dask.dataframe.groupby\x94\x8c\x14_groupby_slice_apply\x94\x93\x94e]\x94(\x8c\x05_meta\x94\x8c\x12pandas.core.series\x94\x8c\x06Series\x94\x93\x94)\x81\x94}\x94(\x8c\x04_mgr\x94\x8c\x1epandas.core.internals.managers\x94\x8c\x12SingleBlockManager\x94\x93\x94)\x81\x94(]\x94\x8c\x18pandas.core.indexes.base\x94\x8c\n_new_Index\x94\x93\x94\x8c\x19pandas.core.indexes.range\x94\x8c\nRangeIndex\x94\x93\x94}\x94(\x8c\x04name\x94N\x8c\x05start\x94K\x00\x8c\x04stop\x94K\x00\x8c\x04step\x94K\x01u\x86\x94R\x94a]\x94\x8c\x15numpy.core.multiarray\x94\x8c\x0c_reconstruct\x94\x93\x94\x8c\x05numpy\x94\x8c\x07ndarray\x94\x93\x94K\x00\x85\x94C\x01b\x94\x87\x94R\x94(K\x01K\x00\x85\x94hk\x8c\x05dtype\x94\x93\x94\x8c\x02O8\x94\x89\x88\x87\x94R\x94(K\x03\x8c\x01|\x94NNNJ\xff\xff\xff\xffJ\xff\xff\xff\xffK?t\x94b\x89]\x94t\x94ba]\x94h\\hZ\x8c\x05Index\x94\x93\x94}\x94(h\x05\x8c\x12numpy.core.numeric\x94\x8c\x0b_frombuffer\x94\x93\x94(\x97ht\x8c\x02i8\x94\x89\x88\x87\x94R\x94(K\x03\x8c\x01<\x94NNNJ\xff\xff\xff\xffJ\xff\xff\xff\xffK\x00t\x94bK\x00\x85\x94\x8c\x01C\x94t\x94R\x94haNu\x86\x94R\x94a}\x94\x8c\x060.14.1\x94}\x94(\x8c\x04axes\x94hY\x8c\x06blocks\x94]\x94}\x94(\x8c\x06values\x94hq\x8c\x08mgr_locs\x94h\x82(\x97h\x85K\x00\x85\x94h\x89t\x94R\x94uaust\x94b\x8c\x04_typ\x94\x8c\x06series\x94\x8c\t_metadata\x94]\x94\x8c\x05_name\x94a\x8c\x05attrs\x94}\x94\x8c\x06_flags\x94}\x94\x8c\x17allows_duplicate_labels\x94\x88sh\x9fNube]\x94(\x8c\ngroup_keys\x94\x88ee\x86\x94t\x94h@(h;\x8c\x14dask.dataframe.utils\x94\x8c\x14drop_by_shallow_copy\x94\x93\x94]\x94(\x8c\x13__dask_blockwise__4\x94\x8c\x13__dask_blockwise__5\x94ehF]\x94]\x94(\x8c\x06errors\x94\x8c\x05raise\x94ea\x86\x94t\x94u\x8c\tnumblocks\x94}\x94h\x0fK\x1e\x85\x94s\x8c\x07io_deps\x94}\x94\x8c\x07indices\x94(haN\x86\x94NN\x86\x94\x8c\x17cloudpickle.cloudpickle\x94\x8c\x0e_make_function\x94\x93\x94(h\xbd\x8c\r_builtin_type\x94\x93\x94\x8c\x08CodeType\x94\x85\x94R\x94(K\x01K\x00K\x00K\x02K\x04K\x03C\x82\x97\x00t\x01\x00\x00\x00\x00\x00\x00\x00\x00\xab\x00\x00\x00\x00\x00\x00\x00}\x01|\x01j\x03\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00|\x00d\x01g\x01\x19\x00\x00\x00j\x04\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00|\x00j\x06\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00j\x04\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\xab\x02\x00\x00\x00\x00\x00\x00\x01\x00|\x01S\x00\x94N\x8c\x01x\x94\x86\x94(\x8c\x10LinearRegression\x94\x8c\x03fit\x94h\x95\x8c\x01y\x94t\x94\x8c\tpartition\x94\x8c\x03est\x94\x86\x94\x8c\x1e<ipython-input-4-4a6ceb5a387d>\x94\x8c\x05train\x94h\xd0K\x0bC4\x80\x00\xdc\n\x1a\xd3\n\x1c\x80C\xd8\x04\x07\x87G\x81G\x88I\x90s\x90e\xd1\x0c\x1c\xd7\x0c#\xd1\x0c#\xa0Y\xa7[\xa1[\xd7%7\xd1%7\xd4\x048\xd8\x0b\x0e\x80J\x94C\x00\x94))t\x94R\x94}\x94(\x8c\x0b__package__\x94N\x8c\x08__name__\x94\x8c\x08__main__\x94uNNNt\x94R\x94\x8c\x1ccloudpickle.cloudpickle_fast\x94\x8c\x12_function_setstate\x94\x93\x94h\xda}\x94}\x94(h\xd7h\xd0\x8c\x0c__qualname__\x94h\xd0\x8c\x0f__annotations__\x94}\x94\x8c\x0e__kwdefaults__\x94N\x8c\x0c__defaults__\x94N\x8c\n__module__\x94h\xd8\x8c\x07__doc__\x94N\x8c\x0b__closure__\x94N\x8c\x17_cloudpickle_submodules\x94]\x94\x8c\x0b__globals__\x94}\x94h\xc8\x8c\x1asklearn.linear_model._base\x94h\xc8\x93\x94su\x86\x94\x86R0N\x86\x94\x8c5drop_by_shallow_copy-d929683038e3a9eec5fa87589d6b2ca0\x94N\x86\x94h\x0fh \x85\x94\x86\x94]\x94\x8c\x0b_partitions\x94aN\x86\x94h\x0fN\x86\x94t\x94\x8c\x0bconcatenate\x94N\x8c\x08new_axes\x94}\x94\x8c\x05_dims\x94}\x94h K\x1esubh\x0f\x8c\x1cdistributed.shuffle._shuffle\x94\x8c\x0fP2PShuffleLayer\x94\x93\x94)\x81\x94}\x94(hah\x0f\x8c\x06column\x94h\xf5\x8c\x0bnpartitions\x94K\x1e\x8c\nname_input\x94h\x11\x8c\nmeta_input\x94\x8c\x11pandas.core.frame\x94\x8c\tDataFrame\x94\x93\x94)\x81\x94}\x94(hThU\x8c\x0cBlockManager\x94\x93\x94\x8c\x16pandas._libs.internals\x94\x8c\x0f_unpickle_block\x94\x93\x94\x8c\x1fpandas.core.arrays.string_arrow\x94\x8c\x10ArrowStringArray\x94\x93\x94)\x81\x94}\x94(\x8c\t_pa_array\x94\x8c\x0bpyarrow.lib\x94\x8c\x0e_restore_array\x94\x93\x94(j\x17\x01\x00\x00\x8c\x0etype_for_alias\x94\x93\x94\x8c\x0clarge_string\x94\x85\x94R\x94K\x00K\x00K\x00]\x94(Nj\x17\x01\x00\x00\x8c\tpy_buffer\x94\x93\x94\x97\x85\x94R\x94j!\x01\x00\x00\x97\x85\x94R\x94e]\x94Nt\x94\x85\x94R\x94\x8c\x06_dtype\x94\x8c\x1apandas.core.arrays.string_\x94\x8c\x0bStringDtype\x94\x93\x94)\x81\x94}\x94\x8c\x07storage\x94h5sbubhD\x8c\x05slice\x94\x93\x94K\x00K\x01K\x01\x87\x94R\x94K\x02\x87\x94R\x94j\x10\x01\x00\x00h\x82(\x97ht\x8c\x02f8\x94\x89\x88\x87\x94R\x94(K\x03h\x86NNNJ\xff\xff\xff\xffJ\xff\xff\xff\xffK\x00t\x94bK\x02K\x00\x86\x94h\x89t\x94R\x94j2\x01\x00\x00K\x02K\x04K\x01\x87\x94R\x94K\x02\x87\x94R\x94j\x10\x01\x00\x00h\x82(\x97h\x85K\x02K\x00\x86\x94h\x89t\x94R\x94j2\x01\x00\x00K\x01K\x07K\x03\x87\x94R\x94K\x02\x87\x94R\x94\x87\x94]\x94(h\\h~}\x94(h\x05hjhmK\x00\x85\x94ho\x87\x94R\x94(K\x01K\x05\x85\x94hw\x89]\x94(ha\x8c\x02id\x94h\xc6h\xcah\xf5et\x94bhaNu\x86\x94R\x94\x8c\x1dpandas.core.indexes.datetimes\x94\x8c\x12_new_DatetimeIndex\x94\x93\x94jU\x01\x00\x00\x8c\rDatetimeIndex\x94\x93\x94}\x94(h\x05\x8c\x13pandas._libs.arrays\x94\x8c\x1c__pyx_unpickle_NDArrayBacked\x94\x93\x94\x8c\x1cpandas.core.arrays.datetimes\x94\x8c\rDatetimeArray\x94\x93\x94J\x1f\x06\xf1\x04N\x87\x94R\x94ht\x8c\x02M8\x94\x89\x88\x87\x94R\x94(K\x04h\x86NNNJ\xff\xff\xff\xffJ\xff\xff\xff\xffK\x00}\x94(C\x02ns\x94K\x01K\x01K\x01t\x94\x86\x94t\x94bhjhmK\x00\x85\x94ho\x87\x94R\x94(K\x01K\x00\x85\x94ht\x8c\x02M8\x94\x89\x88\x87\x94R\x94(K\x04h\x86NNNJ\xff\xff\xff\xffJ\xff\xff\xff\xffK\x00}\x94(C\x02ns\x94K\x01K\x01K\x01t\x94\x86\x94t\x94b\x89h\xd2t\x94b}\x94\x8c\x05_freq\x94\x8c\x1bpandas._libs.tslibs.offsets\x94\x8c\x06Second\x94\x93\x94K\x01\x89\x86\x94R\x94s\x87\x94bha\x8c\ttimestamp\x94u\x86\x94R\x94e\x86\x94R\x94h\x9b\x8c\tdataframe\x94h\x9d]\x94h\xa0}\x94h\xa2}\x94h\xa4\x88sub\x8c\x04disk\x94\x88\x8c\tparts_out\x94\x8f\x94(K\x00K\x01K\x02K\x03K\x04K\x05K\x06K\x07K\x08K\tK\nK\x0bK\x0cK\rK\x0eK\x0fK\x10K\x11K\x12K\x13K\x14K\x15K\x16K\x17K\x18K\x19K\x1aK\x1bK\x1cK\x1d\x90\x8c\x11npartitions_input\x94K\x1eh\x1cNh\x1d}\x94(j\x04\x01\x00\x00K\x1e\x8c\x07columns\x94]\x94(hajQ\x01\x00\x00h\xc6h\xcah\xf5e\x8c\x04type\x94\x8c\x1ddask.dataframe.core.DataFrame\x94\x8c\x0edataframe_type\x94\x8c\x1bpandas.core.frame.DataFrame\x94\x8c\rseries_dtypes\x94}\x94(haj-\x01\x00\x00)\x81\x94}\x94j0\x01\x00\x00h5sbjQ\x01\x00\x00h\x85h\xc6j9\x01\x00\x00h\xcaj9\x01\x00\x00h\xf5h\x85uuubh\x11h\x19)\x81\x94}\x94(h\x1cNh\x1dNh\x1eh\x11h\x1f\x8c\x02.0\x94\x85\x94h"Nh#}\x94(h\x11(\x8c\x16dask.dataframe.methods\x94\x8c\x06assign\x94\x93\x94\x8c5to_pyarrow_string-1c5db2f3260e527b07569740a1773e63_.0\x94\x8c\x13__dask_blockwise__0\x94\x8c6partitioning_index-fa140c0065fbad45aa30edddf4c47226_.0\x94t\x94j\xa2\x01\x00\x00(h;h>]\x94\x8c+getitem-b0727fc77aa2e5baeed4b75778b9498b_.0\x94ahF]\x94(]\x94(hI\x8c\x16dask.dataframe.shuffle\x94\x8c\x12partitioning_index\x94\x93\x94e]\x94(hNhQ)\x81\x94}\x94(hThW)\x81\x94(]\x94jW\x01\x00\x00jY\x01\x00\x00}\x94(h\x05j]\x01\x00\x00j`\x01\x00\x00J\x1f\x06\xf1\x04N\x87\x94R\x94ht\x8c\x02M8\x94\x89\x88\x87\x94R\x94(K\x04h\x86NNNJ\xff\xff\xff\xffJ\xff\xff\xff\xffK\x00}\x94(C\x02ns\x94K\x01K\x01K\x01t\x94\x86\x94t\x94bhjhmK\x00\x85\x94ho\x87\x94R\x94(K\x01K\x00\x85\x94ht\x8c\x02M8\x94\x89\x88\x87\x94R\x94(K\x04h\x86NNNJ\xff\xff\xff\xffJ\xff\xff\xff\xffK\x00}\x94(C\x02ns\x94K\x01K\x01K\x01t\x94\x86\x94t\x94b\x89h\xd2t\x94b}\x94jy\x01\x00\x00j~\x01\x00\x00s\x87\x94bhaj\x80\x01\x00\x00u\x86\x94R\x94a]\x94h\x82(\x97h\x85K\x00\x85\x94h\x89t\x94R\x94a]\x94jW\x01\x00\x00jY\x01\x00\x00}\x94(h\x05j]\x01\x00\x00j`\x01\x00\x00J\x1f\x06\xf1\x04N\x87\x94R\x94j\xb5\x01\x00\x00hjhmK\x00\x85\x94ho\x87\x94R\x94(K\x01K\x00\x85\x94j\xc1\x01\x00\x00\x89h\xd2t\x94b}\x94jy\x01\x00\x00Ns\x87\x94bhaj\x80\x01\x00\x00u\x86\x94R\x94a}\x94h\x8f}\x94(h\x91j\xaf\x01\x00\x00h\x92]\x94}\x94(h\x95j\xcf\x01\x00\x00h\x96h\x82(\x97h\x85K\x00\x85\x94h\x89t\x94R\x94uaust\x94bh\x9bh\x9ch\x9dh\x9eh\xa0}\x94h\xa2}\x94h\xa4\x88sh\x9fNube]\x94(j\x04\x01\x00\x00K\x1eee\x86\x94t\x94j\xa5\x01\x00\x00\x8c\t_operator\x94\x8c\x07getitem\x94\x93\x94j\xa0\x01\x00\x00\x8c\x13__dask_blockwise__2\x94\x87\x94\x8c3make-timeseries-bf04580489ffad8d512bdb9dd8404786_.0\x94\x8c\x16dask.dataframe.io.demo\x94\x8c\x11MakeDataframePart\x94\x93\x94)\x81\x94}\x94(\x8c\x0bindex_dtype\x94\x8c\x0edatetime64[ns]\x94\x8c\x08_columns\x94]\x94(hajQ\x01\x00\x00h\xc6h\xcae\x8c\x06dtypes\x94}\x94(hahD\x8c\x03str\x94\x93\x94jQ\x01\x00\x00hD\x8c\x03int\x94\x93\x94h\xc6hD\x8c\x05float\x94\x93\x94h\xcaj\x00\x02\x00\x00u\x8c\x06kwargs\x94}\x94\x8c\x04freq\x94\x8c\x021s\x94sub\x8c\x13__dask_blockwise__3\x94\x86\x94j\xa0\x01\x00\x00h,j\xef\x01\x00\x00\x86\x94uh\xb5}\x94\x8c 12ad2942fdb9bc7444d1608bc27d7678\x94K\x1e\x85\x94sh\xb8}\x94j\t\x02\x00\x00h\x17\x8c\x10BlockwiseDepDict\x94\x93\x94)\x81\x94}\x94(\x8c\x07mapping\x94}\x94(K\x00\x85\x94]\x94(\x8c\x1epandas._libs.tslibs.timestamps\x94\x8c\x13_unpickle_timestamp\x94\x93\x94(\x8a\x08\x00\x00CR\xcfL#\rNNK\nt\x94R\x94j\x16\x02\x00\x00(\x8a\x08\x00\x00\x92\xe3c\x9b#\rNNK\nt\x94R\x94ehh\x8c\x06scalar\x94\x93\x94h\x85C\x08j\x99HO\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x01\x85\x94]\x94(j\x1a\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00\xe1t\xf8\xe9#\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x080\xe6\t\x04\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x02\x85\x94]\x94(j$\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x000\x06\x8d8$\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08\xbf\r\x0b\x12\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x03\x85\x94]\x94(j,\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00\x7f\x97!\x87$\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08IW\xc6D\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x04\x85\x94]\x94(j4\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00\xce(\xb6\xd5$\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08\x13\x13Zr\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x05\x85\x94]\x94(j<\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00\x1d\xbaJ$%\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08\xe1\xae\x8dm\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x06\x85\x94]\x94(jD\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00lK\xdfr%\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08\x83\x00cL\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x07\x85\x94]\x94(jL\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00\xbb\xdcs\xc1%\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08\xb9\xe3\xeb\x1d\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x08\x85\x94]\x94(jT\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00\nn\x08\x10&\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08\x88\x853m\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\t\x85\x94]\x94(j\\\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00Y\xff\x9c^&\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08\xf7\xda\xe7&\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\n\x85\x94]\x94(jd\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00\xa8\x901\xad&\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08p\xed\x12\x16\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x0b\x85\x94]\x94(jl\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00\xf7!\xc6\xfb&\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08\xf7MYV\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x0c\x85\x94]\x94(jt\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00F\xb3ZJ\'\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08\xf0\x91\xe8\x16\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\r\x85\x94]\x94(j|\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00\x95D\xef\x98\'\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08A\xbb\xde\'\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x0e\x85\x94]\x94(j\x84\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00\xe4\xd5\x83\xe7\'\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08\xd4\x97\xa6.\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x0f\x85\x94]\x94(j\x8c\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x003g\x186(\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08\n!\xb3\x18\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x10\x85\x94]\x94(j\x94\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00\x82\xf8\xac\x84(\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08%o\x98_\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x11\x85\x94]\x94(j\x9c\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00\xd1\x89A\xd3(\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08\x00\xca\xb9\x00\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x12\x85\x94]\x94(j\xa4\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00 \x1b\xd6!)\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08\xba \'Z\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x13\x85\x94]\x94(j\xac\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00o\xacjp)\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08\xd9\x00\xfb\r\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x14\x85\x94]\x94(j\xb4\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00\xbe=\xff\xbe)\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08\x06,\xacd\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x15\x85\x94]\x94(j\xbc\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00\r\xcf\x93\r*\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08i\x1d\xc0K\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x16\x85\x94]\x94(j\xc4\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00\\`(\\*\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08cN\x07\x05\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x17\x85\x94]\x94(j\xcc\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00\xab\xf1\xbc\xaa*\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08Y\xebC]\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x18\x85\x94]\x94(j\xd4\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00\xfa\x82Q\xf9*\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08\x9e{\x17L\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x19\x85\x94]\x94(j\xdc\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00I\x14\xe6G+\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08\xf4^%l\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x1a\x85\x94]\x94(j\xe4\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00\x98\xa5z\x96+\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08\xf8D\x9fC\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x1b\x85\x94]\x94(j\xec\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00\xe76\x0f\xe5+\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08Z\xc16\x17\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x1c\x85\x94]\x94(j\xf4\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x006\xc8\xa33,\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08\x85Cdi\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94K\x1d\x85\x94]\x94(j\xfc\x02\x00\x00j\x16\x02\x00\x00(\x8a\x08\x00\x00\x85Y8\x82,\rNNK\nt\x94R\x94ej\x1c\x02\x00\x00h\x85C\x08\t\x92v\x0c\x00\x00\x00\x00\x94\x86\x94R\x94\x86\x94u\x8c\x0eproduces_tasks\x94\x89h\xb5j\n\x02\x00\x00\x8c\x0e_produces_keys\x94\x89ubsh\xba(h\xf5N\x86\x94\x8c(getitem-b0727fc77aa2e5baeed4b75778b9498b\x94N\x86\x94]\x94haaN\x86\x94j\t\x02\x00\x00j\x9a\x01\x00\x00\x85\x94\x86\x94t\x94h\xf9Nh\xfa}\x94h\xfc}\x94j\x9a\x01\x00\x00K\x1esubuubsb.', b'', b'', b'\x00\x00\x00\x00\x00\x00\x00\x00', b'', b'\xc4\x10\xc4\x00\xc4\x00\xa4keys\xdc\x00\x1e\x92\xd9', 50, 116, 111), 95: 115, 121: 97, 114: 114, 111: 119, 116: 114, 105: 110},), bytearray(b'g-4be438ca8e8e753862b269dc981d17a1\x00\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x03\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\t\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x06\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x0c\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x0f\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x15\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x12\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x18\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x1b\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x02\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x05\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x08\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x0e\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x0b\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x11\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x14\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x1a\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x17\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x1d\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x01\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x07\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x04\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\n\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\r\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x13\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x10\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x16\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x1c\x92\xd92to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1\x19\xb1internal_priority\xc0\xafsubmitting_task\xc0\xacfifo_timeout\xa360s\xa6actors\xc0\xa4code\x81\xab__Pickled__\x01\xabannotations\x81\xab__Pickled__\x02'))>
Traceback (most recent call last):
  File "/Users/bryan/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/distributed/core.py", line 968, in _handle_comm
    result = await result
             ^^^^^^^^^^^^
  File "/Users/bryan/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/distributed/scheduler.py", line 5532, in add_client
    await self.handle_stream(comm=comm, extra={"client": client})
  File "/Users/bryan/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/distributed/core.py", line 1023, in handle_stream
    msgs = await comm.read()
           ^^^^^^^^^^^^^^^^^
  File "/Users/bryan/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/distributed/comm/tcp.py", line 248, in read
    msg = await from_frames(
          ^^^^^^^^^^^^^^^^^^
  File "/Users/bryan/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/distributed/comm/utils.py", line 78, in from_frames
    res = _from_frames()
          ^^^^^^^^^^^^^^
  File "/Users/bryan/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/distributed/comm/utils.py", line 61, in _from_frames
    return protocol.loads(
           ^^^^^^^^^^^^^^^
  File "/Users/bryan/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/distributed/protocol/core.py", line 160, in loads
    return msgpack.loads(
           ^^^^^^^^^^^^^^
  File "/Users/bryan/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/msgpack/fallback.py", line 136, in unpackb
    raise ExtraData(ret, unpacker._get_extradata())
msgpack.exceptions.ExtraData: unpack(b) received extra data.
---------------------------------------------------------------------------
CancelledError                            Traceback (most recent call last)
Cell In[30], line 1
----> 1 df.groupby('name').apply(train, meta=object).compute()

File ~/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/dask/base.py:342, in DaskMethodsMixin.compute(self, **kwargs)
    318 def compute(self, **kwargs):
    319     """Compute this dask collection
    320
    321     This turns a lazy Dask collection into its in-memory equivalent.
   (...)
    340     dask.compute
    341     """
--> 342     (result,) = compute(self, traverse=False, **kwargs)
    343     return result

File ~/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/dask/base.py:628, in compute(traverse, optimize_graph, scheduler, get, *args, **kwargs)
    625     postcomputes.append(x.__dask_postcompute__())
    627 with shorten_traceback():
--> 628     results = schedule(dsk, keys, **kwargs)
    630 return repack([f(r, *a) for r, (f, a) in zip(results, postcomputes)])

File ~/anaconda3/envs/bk34-py312/lib/python3.12/site-packages/distributed/client.py:2245, in Client._gather(self, futures, errors, direct, local_worker)
   2243     else:
   2244         raise exception.with_traceback(traceback)
-> 2245     raise exc
   2246 if errors == "skip":
   2247     bad_keys.add(key)

CancelledError: ('to_pyarrow_string-4be438ca8e8e753862b269dc981d17a1', 16)

@fjetter
Copy link
Member

fjetter commented Mar 11, 2024

There seem to be a lot of test failures but at least skimming through, t

Most of the failures have been resolved on main. I rebased the PR to get a better picture.

FYI I did get an error when running this (my previous smoke test) but as far as I can see it's not related to Bokeh at all:

This looks as if your workers/scheduler and your client are running on different versions. Maybe your venv is broken?

@bryevdv
Copy link
Contributor

bryevdv commented Mar 11, 2024

@fjetter maybe, as I said I am not a regular Dask user. For ref I created the env like this:

conda create -n bk34-py312 python=3.12 dask distributed

and then pip installed the Bokeh rc into the env.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

3 participants