2024-08-07 17:07:43 - log_args - INFO - running function: ras_pyramid
2024-08-07 17:07:43 - log_args - INFO - fetching args:
2024-08-07 17:07:43 - log_args - INFO - ras = './load_data/rslc.zarr'
2024-08-07 17:07:43 - log_args - INFO - out_dir = './load_data/rslc_pyramid'
2024-08-07 17:07:43 - log_args - INFO - chunks = (256, 256)
2024-08-07 17:07:43 - log_args - INFO - processes = False
2024-08-07 17:07:43 - log_args - INFO - n_workers = 1
2024-08-07 17:07:43 - log_args - INFO - threads_per_worker = 2
2024-08-07 17:07:43 - log_args - INFO - dask_cluster_arg = {}
2024-08-07 17:07:43 - log_args - INFO - fetching args done.
2024-08-07 17:07:44 - zarr_info - INFO - ./load_data/rslc.zarr zarray shape, chunks, dtype: (2500, 1834, 17), (1000, 1000, 1), complex64
2024-08-07 17:07:44 - ras_pyramid - INFO - rendered raster pyramid with zoom level ranging from 0 (finest resolution) to 10 (coarsest resolution).
2024-08-07 17:07:44 - ras_pyramid - INFO - dask local cluster started.
2024-08-07 17:07:44 - dask_cluster_info - INFO - dask cluster: LocalCluster(dashboard_link='http://10.211.48.15:8787/status', workers=1, threads=2, memory=1.46 TiB)
2024-08-07 17:07:44 - darr_info - INFO - downsampled ras dask array in level 0 dask array shape, chunksize, dtype: (2500, 1834, 17), (2500, 1834, 1), complex64
2024-08-07 17:07:44 - zarr_info - INFO - load_data/rslc_pyramid/0.zarr zarray shape, chunks, dtype: (2500, 1834, 17), (256, 256, 1), complex64
2024-08-07 17:07:44 - darr_info - INFO - downsampled ras dask array in level 1 dask array shape, chunksize, dtype: (1250, 917, 17), (1250, 917, 1), complex64
2024-08-07 17:07:44 - zarr_info - INFO - load_data/rslc_pyramid/1.zarr zarray shape, chunks, dtype: (1250, 917, 17), (256, 256, 1), complex64
2024-08-07 17:07:44 - darr_info - INFO - downsampled ras dask array in level 2 dask array shape, chunksize, dtype: (625, 459, 17), (625, 459, 1), complex64
2024-08-07 17:07:44 - zarr_info - INFO - load_data/rslc_pyramid/2.zarr zarray shape, chunks, dtype: (625, 459, 17), (256, 256, 1), complex64
2024-08-07 17:07:44 - darr_info - INFO - downsampled ras dask array in level 3 dask array shape, chunksize, dtype: (313, 230, 17), (313, 230, 1), complex64
2024-08-07 17:07:44 - zarr_info - INFO - load_data/rslc_pyramid/3.zarr zarray shape, chunks, dtype: (313, 230, 17), (256, 256, 1), complex64
2024-08-07 17:07:44 - darr_info - INFO - downsampled ras dask array in level 4 dask array shape, chunksize, dtype: (157, 115, 17), (157, 115, 1), complex64
2024-08-07 17:07:44 - zarr_info - INFO - load_data/rslc_pyramid/4.zarr zarray shape, chunks, dtype: (157, 115, 17), (256, 256, 1), complex64
2024-08-07 17:07:44 - darr_info - INFO - downsampled ras dask array in level 5 dask array shape, chunksize, dtype: (79, 58, 17), (79, 58, 1), complex64
2024-08-07 17:07:44 - zarr_info - INFO - load_data/rslc_pyramid/5.zarr zarray shape, chunks, dtype: (79, 58, 17), (256, 256, 1), complex64
2024-08-07 17:07:44 - darr_info - INFO - downsampled ras dask array in level 6 dask array shape, chunksize, dtype: (40, 29, 17), (40, 29, 1), complex64
2024-08-07 17:07:44 - zarr_info - INFO - load_data/rslc_pyramid/6.zarr zarray shape, chunks, dtype: (40, 29, 17), (256, 256, 1), complex64
2024-08-07 17:07:44 - darr_info - INFO - downsampled ras dask array in level 7 dask array shape, chunksize, dtype: (20, 15, 17), (20, 15, 1), complex64
2024-08-07 17:07:44 - zarr_info - INFO - load_data/rslc_pyramid/7.zarr zarray shape, chunks, dtype: (20, 15, 17), (256, 256, 1), complex64
2024-08-07 17:07:44 - darr_info - INFO - downsampled ras dask array in level 8 dask array shape, chunksize, dtype: (10, 8, 17), (10, 8, 1), complex64
2024-08-07 17:07:44 - zarr_info - INFO - load_data/rslc_pyramid/8.zarr zarray shape, chunks, dtype: (10, 8, 17), (256, 256, 1), complex64
2024-08-07 17:07:44 - darr_info - INFO - downsampled ras dask array in level 9 dask array shape, chunksize, dtype: (5, 4, 17), (5, 4, 1), complex64
2024-08-07 17:07:44 - zarr_info - INFO - load_data/rslc_pyramid/9.zarr zarray shape, chunks, dtype: (5, 4, 17), (256, 256, 1), complex64
2024-08-07 17:07:44 - darr_info - INFO - downsampled ras dask array in level 10 dask array shape, chunksize, dtype: (3, 2, 17), (3, 2, 1), complex64
2024-08-07 17:07:44 - zarr_info - INFO - load_data/rslc_pyramid/10.zarr zarray shape, chunks, dtype: (3, 2, 17), (256, 256, 1), complex64
2024-08-07 17:07:44 - ras_pyramid - INFO - computing graph setted. doing all the computing.
2024-08-07 17:07:49 - ras_pyramid - INFO - computing finished. 4.6s
2024-08-07 17:07:49,535 - distributed.worker - ERROR - Unexpected exception during heartbeat. Closing worker.
Traceback (most recent call last):
File "/users/kangl/miniforge3/envs/work/lib/python3.10/site-packages/distributed/worker.py", line 1252, in heartbeat
response = await retry_operation(
File "/users/kangl/miniforge3/envs/work/lib/python3.10/site-packages/distributed/utils_comm.py", line 455, in retry_operation
return await retry(
File "/users/kangl/miniforge3/envs/work/lib/python3.10/site-packages/distributed/utils_comm.py", line 434, in retry
return await coro()
File "/users/kangl/miniforge3/envs/work/lib/python3.10/site-packages/distributed/core.py", line 1392, in send_recv_from_rpc
comm = await self.pool.connect(self.addr)
File "/users/kangl/miniforge3/envs/work/lib/python3.10/site-packages/distributed/core.py", line 1591, in connect
raise RuntimeError("ConnectionPool is closed")
RuntimeError: ConnectionPool is closed
2024-08-07 17:07:49,538 - tornado.application - ERROR - Exception in callback <bound method Worker.heartbeat of <Worker 'inproc://10.211.48.15/1986199/14', name: 0, status: closed, stored: 0, running: 0/2, ready: 0, comm: 0, waiting: 0>>
Traceback (most recent call last):
File "/users/kangl/miniforge3/envs/work/lib/python3.10/site-packages/tornado/ioloop.py", line 939, in _run
await val
File "/users/kangl/miniforge3/envs/work/lib/python3.10/site-packages/distributed/worker.py", line 1252, in heartbeat
response = await retry_operation(
File "/users/kangl/miniforge3/envs/work/lib/python3.10/site-packages/distributed/utils_comm.py", line 455, in retry_operation
return await retry(
File "/users/kangl/miniforge3/envs/work/lib/python3.10/site-packages/distributed/utils_comm.py", line 434, in retry
return await coro()
File "/users/kangl/miniforge3/envs/work/lib/python3.10/site-packages/distributed/core.py", line 1392, in send_recv_from_rpc
comm = await self.pool.connect(self.addr)
File "/users/kangl/miniforge3/envs/work/lib/python3.10/site-packages/distributed/core.py", line 1591, in connect
raise RuntimeError("ConnectionPool is closed")
RuntimeError: ConnectionPool is closed