2026-01-19 15:02:38,635 - distributed.worker - WARNING - Compute Failed Key: ('shuffle-transfer-dd0235e2b443afff522d4ae5c408aeda', 6) Function: shuffle_transfer args: ( schema_version detector_id ... heading_diff_cur_and_next _partitions 203 1 2794848503 ... -0.2 4 203 1 2794848489 ... -4.1 6 203 1 2794848514 ... 0.0 11 203 1 2794848489 ... 0.0 10 203 1 2794848514 ... -2.4 12 .. ... ... ... ... ... 236 1 2794848422 ... 0.1 6 236 1 2794848503 ... 0.0 6 236 1 2794848516 ... 2.8 4 236 1 2794848516 ... -0.5 0 236 1 2794848422 ... 0.0 6 [544 rows x 21 columns], 'dd0235e2b443afff522d4ae5c408aeda', 6, 16, '_part kwargs: {} Exception: "RuntimeError('shuffle_transfer failed during shuffle dd0235e2b443afff522d4ae5c408aeda')"

2026-01-19 05:32:26,717 - distributed.worker - INFO - -------------------------------------------------

2026-01-19 05:32:26,717 - distributed.worker - INFO - Registered to: tcp://dask-scheduler:8786

2026-01-19 05:32:26,335 - distributed.worker - INFO - -------------------------------------------------

2026-01-19 05:32:26,335 - distributed.worker - INFO - Local Directory: /tmp/dask-worker-space/worker-shk7y5fa

2026-01-19 05:32:26,335 - distributed.worker - INFO - Memory: 3.73 GiB

2026-01-19 05:32:26,335 - distributed.worker - INFO - Threads: 1

2026-01-19 05:32:26,335 - distributed.worker - INFO - -------------------------------------------------

2026-01-19 05:32:26,335 - distributed.worker - INFO - Waiting to connect to: tcp://dask-scheduler:8786

2026-01-19 05:32:26,335 - distributed.worker - INFO - dashboard at: 172.21.159.228:8790

2026-01-19 05:32:26,335 - distributed.worker - INFO - Listening to: tcp://172.21.159.228:41119

2026-01-19 05:32:26,335 - distributed.worker - INFO - Start worker at: tcp://172.21.159.228:41119