2026-01-20 13:31:36,190 - distributed.worker - WARNING - Compute Failed Key: ('assign-40771b150f9d93cf6cd28d980990ead3', 13) Function: subgraph_callable-6eeac2ed-e0f4-49b9-b606-5448f614 args: ( source_id geometry 0 2794848545 POINT Z (442893.825 5895134.932 0.000) 2 2794848545 POINT Z (442893.825 5895134.932 0.000) 4 2794848545 POINT Z (442893.825 5895134.932 0.000) 13 2794848545 POINT Z (442893.825 5895134.932 0.000) 16 2794848545 POINT Z (442893.825 5895134.932 0.000) ... ... ... 1875 2794848545 POINT Z (444816.028 5895813.938 0.000) 1877 2794848545 POINT Z (444816.028 5895813.938 0.000) 1880 2794848545 POINT Z (444816.022 5895813.949 0.000) 1882 2794848545 POINT Z (444816.022 5895813.960 0.000) 1885 2794848545 POINT Z (444816.015 5895813.971 0.000) [665 rows x 2 columns]) kwargs: {} Exception: "GEOSException('IllegalArgumentException: point array must contain 0 or >1 elements\\n')"

2026-01-17 03:30:34,602 - distributed.worker - WARNING - Compute Failed Key: ('hash-join-6ecf3f6b6bbf2dcd44736aa9f15af56e', 11) Function: merge_unpack args: ('0daf590db3ff54d36d8b96524d4704eb', '32bc94ad0f277ef7c0ea52efd9f2b324', 11, 3489, 3491, 'inner', 'hashed_source_and_date', 'hashed_source_and_date', <distributed.protocol.serialize.Serialized object at 0x7f60249f5ea0>, ['_x', '_y']) kwargs: {} Exception: "KeyError('0daf590db3ff54d36d8b96524d4704eb')"

2026-01-16 16:01:26,665 - distributed.worker - WARNING - Compute Failed Key: shuffle-barrier-d5e03160a9793cb8edc1822fb4edcfcf Function: shuffle_barrier args: ('d5e03160a9793cb8edc1822fb4edcfcf', [3044, 3044, 3044, 3044, 3044, 3044, 3044, 3044, 3044, 3044, 3044, 3044, 3044, 3044, 3044, 3044]) kwargs: {} Exception: "RuntimeError('shuffle_barrier failed during shuffle d5e03160a9793cb8edc1822fb4edcfcf')"

2026-01-15 16:31:43,530 - distributed.worker - WARNING - Compute Failed Key: ('hash-join-fe8a8b5e0aedb9f2195eddc391aaa09e', 11) Function: merge_unpack args: ('e08f1b0bb0ff4c7fe0d803d6c4e25867', 'd3b58a9bd4341ffebd1463dbcc43bdcd', 11, 1741, 1742, 'inner', 'hashed_source_and_date', 'hashed_source_and_date', <distributed.protocol.serialize.Serialized object at 0x7f60ec15b100>, ['_x', '_y']) kwargs: {} Exception: "ArrowInvalid('Schema at index 6 was different: \\nschema_version: int64\\ndetector_id: int64\\nsource_id: int64\\ntimestamp: int64\\ngdt: int64\\nsrt: int64\\nheading: double\\nspeed: double\\nevent_type: string\\nexterior_lights: string\\nlongitude: double\\nlatitude: double\\naltitude: int64\\ngeometry_type: string\\nis_day: bool\\nhashed_source_and_date: string\\nindex: int64\\nheading_diff_prev_and_cur: double\\nheading_diff_cur_and_next: double\\n__hash_partition: uint64\\ndate: timestamp[ns]\\nvs\\nschema_version: int64\\ndetector_id: int64\\nsource_id: int64\\ntimestamp: int64\\ngdt: int64\\nsrt: int64\\nheading: double\\nspeed: double\\nevent_type: string\\nexterior_lights: null\\nlongitude: double\\nlatitude: double\\naltitude: int64\\ngeometry_type: string\\nis_day: bool\\nhashed_source_and_date: string\\nindex: int64\\nheading_diff_prev_and_cur: double\\nheading_diff_cur_and_next: double\\n__hash_partition: uint64\\ndate: timestamp[ns]')"

2026-01-15 12:00:50,556 - distributed.worker - INFO - -------------------------------------------------

2026-01-15 12:00:50,555 - distributed.worker - INFO - Registered to: tcp://dask-scheduler:8786

2026-01-15 12:00:50,162 - distributed.worker - INFO - -------------------------------------------------

2026-01-15 12:00:50,162 - distributed.worker - INFO - Local Directory: /tmp/dask-worker-space/worker-2pkgb8c5

2026-01-15 12:00:50,162 - distributed.worker - INFO - Memory: 3.73 GiB

2026-01-15 12:00:50,162 - distributed.worker - INFO - Threads: 1

2026-01-15 12:00:50,162 - distributed.worker - INFO - -------------------------------------------------

2026-01-15 12:00:50,162 - distributed.worker - INFO - Waiting to connect to: tcp://dask-scheduler:8786

2026-01-15 12:00:50,162 - distributed.worker - INFO - dashboard at: 172.21.159.254:8790

2026-01-15 12:00:50,162 - distributed.worker - INFO - Listening to: tcp://172.21.159.254:33329

2026-01-15 12:00:50,162 - distributed.worker - INFO - Start worker at: tcp://172.21.159.254:33329