2026-01-19 15:02:38,603 - distributed.worker - WARNING - Compute Failed Key: ('shuffle-transfer-dd0235e2b443afff522d4ae5c408aeda', 15) Function: shuffle_transfer args: ( schema_version detector_id ... heading_diff_cur_and_next _partitions 512 1 2794848450 ... 0.1 8 512 1 2794848471 ... 1.4 9 512 1 2794848471 ... -0.3 9 512 1 2794848471 ... 0.0 9 512 1 2794848450 ... 0.0 8 .. ... ... ... ... ... 585 1 2794848483 ... 0.2 10 586 1 2794848483 ... -0.2 10 587 1 2794848489 ... -0.8 10 588 1 2794848483 ... 0.0 10 589 1 2794848483 ... -1.3 10 [549 rows x 21 columns], 'dd0235e2b443afff522d4ae5c408aeda', 15, 16, '_par kwargs: {} Exception: "RuntimeError('shuffle_transfer failed during shuffle dd0235e2b443afff522d4ae5c408aeda')"

2026-01-18 03:01:22,345 - distributed.worker - WARNING - Compute Failed Key: shuffle-barrier-7c52d3d0d8538952953be808b5865164 Function: shuffle_barrier args: ('7c52d3d0d8538952953be808b5865164', [4628, 4628, 4628, 4628, 4628, 4628, 4628, 4628, 4628, 4628, 4628, 4628, 4628, 4628, 4628, 4628]) kwargs: {} Exception: "RuntimeError('shuffle_barrier failed during shuffle 7c52d3d0d8538952953be808b5865164')"

2026-01-17 12:40:34,544 - distributed.worker - WARNING - Compute Failed Key: ('assign-5e0b6d80ad051794189fc21b7c95b2e9', 2) Function: subgraph_callable-fb163031-6108-474b-8826-78227fcd args: ( source_id geometry 1873 2794848552 POINT Z (444106.065 5895426.414 0.000)) kwargs: {} Exception: "GEOSException('IllegalArgumentException: point array must contain 0 or >1 elements\\n')"

2026-01-16 15:32:22,006 - distributed.worker - INFO - -------------------------------------------------

2026-01-16 15:32:22,006 - distributed.worker - INFO - Registered to: tcp://dask-scheduler:8786

2026-01-16 15:32:21,558 - distributed.worker - INFO - -------------------------------------------------

2026-01-16 15:32:21,558 - distributed.worker - INFO - Local Directory: /tmp/dask-worker-space/worker-9zwz0ag9

2026-01-16 15:32:21,558 - distributed.worker - INFO - Memory: 3.73 GiB

2026-01-16 15:32:21,558 - distributed.worker - INFO - Threads: 1

2026-01-16 15:32:21,558 - distributed.worker - INFO - -------------------------------------------------

2026-01-16 15:32:21,558 - distributed.worker - INFO - Waiting to connect to: tcp://dask-scheduler:8786

2026-01-16 15:32:21,558 - distributed.worker - INFO - dashboard at: 172.21.25.62:8790

2026-01-16 15:32:21,558 - distributed.worker - INFO - Listening to: tcp://172.21.25.62:44951

2026-01-16 15:32:21,558 - distributed.worker - INFO - Start worker at: tcp://172.21.25.62:44951