2026-01-19 15:02:38,625 - distributed.worker - WARNING - Compute Failed Key: ('shuffle-transfer-dd0235e2b443afff522d4ae5c408aeda', 5) Function: shuffle_transfer args: ( schema_version detector_id ... heading_diff_cur_and_next _partitions 169 1 2794848489 ... 0.2 13 169 1 2794848489 ... -0.2 7 169 1 2794848417 ... 0.0 0 169 1 2794848459 ... 0.1 3 169 1 2794848503 ... -0.2 6 .. ... ... ... ... ... 202 1 2794848489 ... -3.1 5 202 1 2794848516 ... 2.1 0 202 1 2794848514 ... 0.0 12 202 1 2794848489 ... 0.0 14 202 1 2794848469 ... -0.2 11 [544 rows x 21 columns], 'dd0235e2b443afff522d4ae5c408aeda', 5, 16, '_part kwargs: {} Exception: "RuntimeError('shuffle_transfer failed during shuffle dd0235e2b443afff522d4ae5c408aeda')"

2026-01-19 12:31:06,559 - distributed.worker - INFO - -------------------------------------------------

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

2026-01-19 12:31:06,112 - distributed.worker - INFO - -------------------------------------------------

2026-01-19 12:31:06,112 - distributed.worker - INFO - Local Directory: /tmp/dask-worker-space/worker-vie9g0zf

2026-01-19 12:31:06,112 - distributed.worker - INFO - Memory: 3.73 GiB

2026-01-19 12:31:06,112 - distributed.worker - INFO - Threads: 1

2026-01-19 12:31:06,112 - distributed.worker - INFO - -------------------------------------------------

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

2026-01-19 12:31:06,112 - distributed.worker - INFO - dashboard at: 172.21.151.159:8790

2026-01-19 12:31:06,112 - distributed.worker - INFO - Listening to: tcp://172.21.151.159:34751

2026-01-19 12:31:06,111 - distributed.worker - INFO - Start worker at: tcp://172.21.151.159:34751