2026-01-19 15:02:02,174 - distributed.worker - WARNING - Compute Failed Key: ('shuffle-transfer-40c48032c2a8567c1cb703aa3460d1c2', 13) Function: shuffle_transfer args: ( schema_version detector_id ... heading_diff_cur_and_next _partitions 440 1 2794848443 ... 0.0 1 440 1 2794848470 ... 0.0 3 440 1 2794848427 ... 0.0 2 440 1 2794848427 ... 0.1 2 440 1 2794848483 ... 0.0 10 .. ... ... ... ... ... 473 1 2794848489 ... -1.0 2 473 1 2794848471 ... 0.4 8 473 1 2794848471 ... -0.2 8 473 1 2794848427 ... 0.1 1 473 1 2794848427 ... -0.1 1 [541 rows x 21 columns], '40c48032c2a8567c1cb703aa3460d1c2', 13, 16, '_par kwargs: {} Exception: "RuntimeError('shuffle_transfer failed during shuffle 40c48032c2a8567c1cb703aa3460d1c2')"

2026-01-19 15:01:29,872 - distributed.worker - WARNING - Compute Failed Key: ('shuffle-transfer-19b050aaaf35e9e0332052c16d1adfa7', 10) Function: shuffle_transfer args: ( schema_version detector_id ... heading_diff_cur_and_next _partitions 338 1 2794848503 ... -0.1 6 338 1 2794848469 ... 0.0 12 338 1 2794848456 ... -0.6 12 338 1 2794848514 ... -0.2 12 338 1 2794848489 ... -0.1 7 .. ... ... ... ... ... 371 1 2794848509 ... -0.2 3 371 1 2794848469 ... 0.1 12 371 1 2794848450 ... -0.1 9 371 1 2794848514 ... 0.0 15 371 1 2794848450 ... 0.1 8 [544 rows x 21 columns], '19b050aaaf35e9e0332052c16d1adfa7', 10, 16, '_par kwargs: {} Exception: "RuntimeError('shuffle_transfer failed during shuffle 19b050aaaf35e9e0332052c16d1adfa7')"

2026-01-19 12:31:05,962 - distributed.worker - INFO - -------------------------------------------------

2026-01-19 12:31:05,962 - distributed.worker - INFO - Registered to: tcp://dask-scheduler:8786

2026-01-19 12:31:05,502 - distributed.worker - INFO - -------------------------------------------------

2026-01-19 12:31:05,502 - distributed.worker - INFO - Local Directory: /tmp/dask-worker-space/worker-o_w1ucwl

2026-01-19 12:31:05,502 - distributed.worker - INFO - Memory: 3.73 GiB

2026-01-19 12:31:05,502 - distributed.worker - INFO - Threads: 1

2026-01-19 12:31:05,502 - distributed.worker - INFO - -------------------------------------------------

2026-01-19 12:31:05,502 - distributed.worker - INFO - Waiting to connect to: tcp://dask-scheduler:8786

2026-01-19 12:31:05,502 - distributed.worker - INFO - dashboard at: 172.21.12.247:8790

2026-01-19 12:31:05,502 - distributed.worker - INFO - Listening to: tcp://172.21.12.247:34539

2026-01-19 12:31:05,501 - distributed.worker - INFO - Start worker at: tcp://172.21.12.247:34539