2026-01-19 15:02:54,235 - distributed.worker - WARNING - Compute Failed Key: ('hash-join-transfer-9d367886730c1a6f221942d84c750289', 12) Function: merge_transfer args: ( schema_version detector_id ... date_diff_ms __hash_partition 0 1 2794848514 ... 398.0 12 1 1 2794848467 ... 410.0 12 2 1 2794848514 ... 652.0 12 3 1 2794848467 ... 436.0 12 4 1 2794848514 ... 499.0 12 ... ... ... ... ... ... 2071205 1 2794848516 ... 738.0 12 2071206 1 2794848427 ... 205.0 12 2071207 1 2794848427 ... 204.0 12 2071208 1 2794848427 ... 203.0 12 2071209 1 2794848427 ... 205.0 12 [2071210 rows x 28 columns], '9d367886730c1a6f221942d84c750289', 12, 16) kwargs: {} Exception: "RuntimeError('shuffle_transfer failed during shuffle 9d367886730c1a6f221942d84c750289')"
2026-01-19 15:02:23,385 - distributed.worker - WARNING - Compute Failed Key: ('hash-join-transfer-f8e59ce3dd3848ae2f76070607d62973', 12) Function: merge_transfer args: ( schema_version detector_id ... date_diff_ms __hash_partition 0 1 2794848469 ... 200.0 12 1 1 2794848469 ... 195.0 12 2 1 2794848514 ... 827.0 12 3 1 2794848514 ... 408.0 12 4 1 2794848469 ... 248.0 12 ... ... ... ... ... ... 2071205 1 2794848422 ... 243.0 12 2071206 1 2794848422 ... 254.0 12 2071207 1 2794848422 ... 305.0 12 2071208 1 2794848422 ... 307.0 12 2071209 1 2794848422 ... 249.0 12 [2071210 rows x 28 columns], 'f8e59ce3dd3848ae2f76070607d62973', 12, 16) kwargs: {} Exception: "RuntimeError('shuffle_transfer failed during shuffle f8e59ce3dd3848ae2f76070607d62973')"
2026-01-19 15:02:02,747 - distributed.worker - WARNING - Compute Failed Key: ('hash-join-transfer-83ebb5dd97ec23d66c72d5526c6a4609', 12) Function: merge_transfer args: ( schema_version detector_id ... date_diff_ms __hash_partition 0 1 2794848443 ... 5.0 12 1 1 2794848443 ... 11.0 12 2 1 2794848417 ... 8.0 12 3 1 2794848417 ... 299.0 12 4 1 2794848516 ... 911.0 12 ... ... ... ... ... ... 2071205 1 2794848427 ... 204.0 12 2071206 1 2794848509 ... 217.0 12 2071207 1 2794848507 ... 225.0 12 2071208 1 2794848516 ... 809.0 12 2071209 1 2794848509 ... 212.0 12 [2071210 rows x 28 columns], '83ebb5dd97ec23d66c72d5526c6a4609', 12, 16) kwargs: {} Exception: "RuntimeError('shuffle_transfer failed during shuffle 83ebb5dd97ec23d66c72d5526c6a4609')"
2026-01-19 15:01:30,744 - distributed.worker - WARNING - Compute Failed Key: ('hash-join-transfer-b94b140c6de8b361dc40112d22e1f016', 12) Function: merge_transfer args: ( schema_version detector_id ... date_diff_ms __hash_partition 0 1 2794848456 ... 18.0 12 1 1 2794848483 ... 6.0 12 2 1 2794848456 ... 10.0 12 3 1 2794848483 ... 395.0 12 4 1 2794848483 ... 296.0 12 ... ... ... ... ... ... 2071285 1 2794848516 ... 610.0 12 2071286 1 2794848516 ... 408.0 12 2071287 1 2794848470 ... 408.0 12 2071288 1 2794848470 ... 445.0 12 2071289 1 3020093209 ... 5.0 12 [2071290 rows x 28 columns], 'b94b140c6de8b361dc40112d22e1f016', 12, 16) kwargs: {} Exception: "RuntimeError('shuffle_transfer failed during shuffle b94b140c6de8b361dc40112d22e1f016')"
2026-01-19 12:31:05,902 - distributed.worker - INFO - -------------------------------------------------
2026-01-19 12:31:05,902 - distributed.worker - INFO - Registered to: tcp://dask-scheduler:8786
2026-01-19 12:31:05,443 - distributed.worker - INFO - -------------------------------------------------
2026-01-19 12:31:05,443 - distributed.worker - INFO - Local Directory: /tmp/dask-worker-space/worker-lqgv_4qa
2026-01-19 12:31:05,443 - distributed.worker - INFO - Memory: 3.73 GiB
2026-01-19 12:31:05,442 - distributed.worker - INFO - Threads: 1
2026-01-19 12:31:05,442 - distributed.worker - INFO - -------------------------------------------------
2026-01-19 12:31:05,442 - distributed.worker - INFO - Waiting to connect to: tcp://dask-scheduler:8786
2026-01-19 12:31:05,442 - distributed.worker - INFO - dashboard at: 172.21.25.37:8790
2026-01-19 12:31:05,442 - distributed.worker - INFO - Listening to: tcp://172.21.25.37:41029
2026-01-19 12:31:05,442 - distributed.worker - INFO - Start worker at: tcp://172.21.25.37:41029