2026-01-19 15:02:38,644 - distributed.worker - WARNING - Compute Failed Key: ('shuffle-transfer-dd0235e2b443afff522d4ae5c408aeda', 7) Function: shuffle_transfer args: ( schema_version detector_id ... heading_diff_cur_and_next _partitions 237 1 2794848489 ... 1.7 15 237 1 2794848516 ... 0.0 4 237 1 2794848422 ... 0.2 6 237 1 2794848503 ... 0.4 4 237 1 2794848514 ... 0.5 11 .. ... ... ... ... ... 270 1 2794848516 ... 0.2 6 270 1 2794848489 ... 0.2 10 270 1 2794848483 ... -0.4 11 270 1 2794848514 ... -1.3 15 270 1 2794848503 ... 0.1 6 [544 rows x 21 columns], 'dd0235e2b443afff522d4ae5c408aeda', 7, 16, '_part kwargs: {} Exception: "RuntimeError('shuffle_transfer failed during shuffle dd0235e2b443afff522d4ae5c408aeda')"
2026-01-19 15:02:02,298 - distributed.worker - WARNING - Compute Failed Key: ('shuffle-transfer-6bc3d86cb004340f35e7e3f39bdfd805', 12) Function: shuffle_transfer args: ( source_id timestamp ... date_diff_ms _partitions 0 2794848523 1768833006591 ... 5.0 7 1 2794848523 1768833007787 ... 11.0 7 2 2794848523 1768833008415 ... 8.0 7 3 2794848523 1768833009304 ... 299.0 7 4 2794848555 1768833010275 ... 911.0 12 ... ... ... ... ... ... 2071205 2794848523 1768833239354 ... 204.0 7 2071206 2794848523 1768833243019 ... 217.0 7 2071207 2794848524 1768833246135 ... 225.0 7 2071208 2794848621 1768833247728 ... 809.0 1 2071209 2794848523 1768833259310 ... 212.0 7 [2071210 rows x 5 columns], '6bc3d86cb004340f35e7e3f39bdfd805', 12, 16, '_partitions') kwargs: {} Exception: "RuntimeError('shuffle_transfer failed during shuffle 6bc3d86cb004340f35e7e3f39bdfd805')"
2026-01-19 04:10:21,097 - distributed.worker - WARNING - Compute Failed Key: ('assign-3a432aa46fcff6a8a79ca3e5b7fdefcd', 9) Function: subgraph_callable-edab7962-975c-4fa9-bdff-80786b56 args: ( source_id geometry 409 2794848570 POINT Z (448050.086 5900566.020 0.000)) kwargs: {} Exception: "GEOSException('IllegalArgumentException: point array must contain 0 or >1 elements\\n')"
2026-01-19 04:00:27,771 - distributed.worker - WARNING - Compute Failed Key: ('assign-b6b82d33da70aed296cd127e77ccd7cd', 9) Function: subgraph_callable-7d3d360e-5f4b-4051-a80d-4b258e50 args: ( source_id geometry 2864 2794848570 POINT Z (448050.086 5900566.020 0.000)) kwargs: {} Exception: "GEOSException('IllegalArgumentException: point array must contain 0 or >1 elements\\n')"
2026-01-18 10:31:24,958 - distributed.worker - WARNING - Compute Failed Key: ('shuffle-transfer-7824cbfb7b72b8fc4e08526fd250e853', 1) Function: shuffle_transfer args: ( source_id timestamp ... date_diff_ms _partitions 0 2794848541 1768731771600 ... 732.0 13 1 2794848541 1768731781924 ... 627.0 13 2 2794848541 1768731782530 ... 606.0 13 3 2794848541 1768731787183 ... 640.0 13 4 2794848541 1768731797053 ... 526.0 13 ... ... ... ... ... ... 2070994 2794848541 1768731583142 ... 478.0 13 2070995 2794848541 1768731589407 ... 16.0 13 2070996 2794848541 1768731590761 ... 13.0 13 2070997 2794848541 1768731597854 ... 381.0 13 2070998 2794848541 1768731601639 ... 23.0 13 [2070999 rows x 5 columns], '7824cbfb7b72b8fc4e08526fd250e853', 1, 16, '_partitions') kwargs: {} Exception: "RuntimeError('shuffle_transfer failed during shuffle 7824cbfb7b72b8fc4e08526fd250e853')"
2026-01-18 03:01:22,447 - distributed.worker - WARNING - Compute Failed Key: shuffle-barrier-ab8e8ea9bf2e4e0be0d66dd1f30e9997 Function: shuffle_barrier args: ('ab8e8ea9bf2e4e0be0d66dd1f30e9997', [4629, 4629, 4629, 4629, 4629, 4629, 4629, 4629, 4629, 4629, 4629, 4629, 4629, 4629, 4629, 4629]) kwargs: {} Exception: "RuntimeError('shuffle_barrier failed during shuffle ab8e8ea9bf2e4e0be0d66dd1f30e9997')"
2026-01-17 07:03:41,178 - distributed.worker - INFO - -------------------------------------------------
2026-01-17 07:03:41,178 - distributed.worker - INFO - Registered to: tcp://dask-scheduler:8786
2026-01-17 07:03:40,807 - distributed.worker - INFO - -------------------------------------------------
2026-01-17 07:03:40,807 - distributed.worker - INFO - Local Directory: /tmp/dask-worker-space/worker-0w6ayptg
2026-01-17 07:03:40,807 - distributed.worker - INFO - Memory: 3.73 GiB
2026-01-17 07:03:40,807 - distributed.worker - INFO - Threads: 1
2026-01-17 07:03:40,807 - distributed.worker - INFO - -------------------------------------------------
2026-01-17 07:03:40,807 - distributed.worker - INFO - Waiting to connect to: tcp://dask-scheduler:8786
2026-01-17 07:03:40,807 - distributed.worker - INFO - dashboard at: 172.21.159.225:8790
2026-01-17 07:03:40,807 - distributed.worker - INFO - Listening to: tcp://172.21.159.225:42711
2026-01-17 07:03:40,807 - distributed.worker - INFO - Start worker at: tcp://172.21.159.225:42711