2026-03-15 07:24:29,220 - distributed.worker - ERROR - Compute Failed Key: ('read_parquet-2395db18cffca8e4c4883a7125373810', 486) State: executing Task: <Task ('read_parquet-2395db18cffca8e4c4883a7125373810', 486) <dask.dataframe.io.parquet.core.ParquetFunctionWra(...)> Exception: "FileNotFoundError(2, 'No such file or directory')" Traceback: ' File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 82, in __call__\n return read_parquet_part(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 184, in read_parquet_part\n func(\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 572, in read_partition\n arrow_table = cls._read_table(\n ^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 1704, in _read_table\n arrow_table = _read_table_from_path(\n ^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 255, in _read_table_from_path\n with _open_input_files(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/utils.py", line 221, in _open_input_files\n return [_set_context(fs.open(path, **kwargs), context_stack) for path in paths]\n ^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/spec.py", line 1338, in open\n f = self._open(\n ^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 210, in _open\n return LocalFileOpener(path, mode, fs=self, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 387, in __init__\n self._open()\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 392, in _open\n self.f = open(self.path, mode=self.mode)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n'

2026-03-15 07:24:29,217 - distributed.worker - ERROR - Compute Failed Key: ('read_parquet-2395db18cffca8e4c4883a7125373810', 476) State: executing Task: <Task ('read_parquet-2395db18cffca8e4c4883a7125373810', 476) <dask.dataframe.io.parquet.core.ParquetFunctionWra(...)> Exception: "FileNotFoundError(2, 'No such file or directory')" Traceback: ' File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 82, in __call__\n return read_parquet_part(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 184, in read_parquet_part\n func(\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 572, in read_partition\n arrow_table = cls._read_table(\n ^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 1704, in _read_table\n arrow_table = _read_table_from_path(\n ^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 255, in _read_table_from_path\n with _open_input_files(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/utils.py", line 221, in _open_input_files\n return [_set_context(fs.open(path, **kwargs), context_stack) for path in paths]\n ^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/spec.py", line 1338, in open\n f = self._open(\n ^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 210, in _open\n return LocalFileOpener(path, mode, fs=self, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 387, in __init__\n self._open()\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 392, in _open\n self.f = open(self.path, mode=self.mode)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n'

2026-03-15 07:24:29,217 - distributed.worker - ERROR - Compute Failed Key: ('read_parquet-2395db18cffca8e4c4883a7125373810', 117) State: executing Task: <Task ('read_parquet-2395db18cffca8e4c4883a7125373810', 117) <dask.dataframe.io.parquet.core.ParquetFunctionWra(...)> Exception: "FileNotFoundError(2, 'No such file or directory')" Traceback: ' File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 82, in __call__\n return read_parquet_part(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 184, in read_parquet_part\n func(\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 572, in read_partition\n arrow_table = cls._read_table(\n ^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 1704, in _read_table\n arrow_table = _read_table_from_path(\n ^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 255, in _read_table_from_path\n with _open_input_files(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/utils.py", line 221, in _open_input_files\n return [_set_context(fs.open(path, **kwargs), context_stack) for path in paths]\n ^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/spec.py", line 1338, in open\n f = self._open(\n ^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 210, in _open\n return LocalFileOpener(path, mode, fs=self, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 387, in __init__\n self._open()\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 392, in _open\n self.f = open(self.path, mode=self.mode)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n'

2026-03-15 07:24:29,212 - distributed.worker - ERROR - Compute Failed Key: ('read_parquet-2395db18cffca8e4c4883a7125373810', 481) State: executing Task: <Task ('read_parquet-2395db18cffca8e4c4883a7125373810', 481) <dask.dataframe.io.parquet.core.ParquetFunctionWra(...)> Exception: "FileNotFoundError(2, 'No such file or directory')" Traceback: ' File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 82, in __call__\n return read_parquet_part(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 184, in read_parquet_part\n func(\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 572, in read_partition\n arrow_table = cls._read_table(\n ^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 1704, in _read_table\n arrow_table = _read_table_from_path(\n ^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 255, in _read_table_from_path\n with _open_input_files(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/utils.py", line 221, in _open_input_files\n return [_set_context(fs.open(path, **kwargs), context_stack) for path in paths]\n ^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/spec.py", line 1338, in open\n f = self._open(\n ^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 210, in _open\n return LocalFileOpener(path, mode, fs=self, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 387, in __init__\n self._open()\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 392, in _open\n self.f = open(self.path, mode=self.mode)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n'

2026-03-15 07:24:29,209 - distributed.worker - ERROR - Compute Failed Key: ('read_parquet-2395db18cffca8e4c4883a7125373810', 365) State: executing Task: <Task ('read_parquet-2395db18cffca8e4c4883a7125373810', 365) <dask.dataframe.io.parquet.core.ParquetFunctionWra(...)> Exception: "FileNotFoundError(2, 'No such file or directory')" Traceback: ' File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 82, in __call__\n return read_parquet_part(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 184, in read_parquet_part\n func(\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 572, in read_partition\n arrow_table = cls._read_table(\n ^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 1704, in _read_table\n arrow_table = _read_table_from_path(\n ^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 255, in _read_table_from_path\n with _open_input_files(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/utils.py", line 221, in _open_input_files\n return [_set_context(fs.open(path, **kwargs), context_stack) for path in paths]\n ^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/spec.py", line 1338, in open\n f = self._open(\n ^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 210, in _open\n return LocalFileOpener(path, mode, fs=self, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 387, in __init__\n self._open()\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 392, in _open\n self.f = open(self.path, mode=self.mode)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n'

2026-03-15 07:24:29,203 - distributed.worker - ERROR - Compute Failed Key: ('read_parquet-2395db18cffca8e4c4883a7125373810', 122) State: executing Task: <Task ('read_parquet-2395db18cffca8e4c4883a7125373810', 122) <dask.dataframe.io.parquet.core.ParquetFunctionWra(...)> Exception: "FileNotFoundError(2, 'No such file or directory')" Traceback: ' File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 82, in __call__\n return read_parquet_part(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 184, in read_parquet_part\n func(\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 572, in read_partition\n arrow_table = cls._read_table(\n ^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 1704, in _read_table\n arrow_table = _read_table_from_path(\n ^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 255, in _read_table_from_path\n with _open_input_files(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/utils.py", line 221, in _open_input_files\n return [_set_context(fs.open(path, **kwargs), context_stack) for path in paths]\n ^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/spec.py", line 1338, in open\n f = self._open(\n ^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 210, in _open\n return LocalFileOpener(path, mode, fs=self, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 387, in __init__\n self._open()\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 392, in _open\n self.f = open(self.path, mode=self.mode)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n'

2026-03-15 07:24:11,927 - distributed.worker - ERROR - Compute Failed Key: ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 85) State: executing Task: <Task ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 85) <dask.dataframe.io.parquet.core.ParquetFunctionWra(...)> Exception: "FileNotFoundError(2, 'No such file or directory')" Traceback: ' File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 82, in __call__\n return read_parquet_part(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 184, in read_parquet_part\n func(\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 572, in read_partition\n arrow_table = cls._read_table(\n ^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 1704, in _read_table\n arrow_table = _read_table_from_path(\n ^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 255, in _read_table_from_path\n with _open_input_files(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/utils.py", line 221, in _open_input_files\n return [_set_context(fs.open(path, **kwargs), context_stack) for path in paths]\n ^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/spec.py", line 1338, in open\n f = self._open(\n ^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 210, in _open\n return LocalFileOpener(path, mode, fs=self, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 387, in __init__\n self._open()\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 392, in _open\n self.f = open(self.path, mode=self.mode)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n'

2026-03-15 07:24:11,924 - distributed.worker - ERROR - Compute Failed Key: ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 309) State: executing Task: <Task ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 309) <dask.dataframe.io.parquet.core.ParquetFunctionWra(...)> Exception: "FileNotFoundError(2, 'No such file or directory')" Traceback: ' File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 82, in __call__\n return read_parquet_part(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 184, in read_parquet_part\n func(\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 572, in read_partition\n arrow_table = cls._read_table(\n ^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 1704, in _read_table\n arrow_table = _read_table_from_path(\n ^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 255, in _read_table_from_path\n with _open_input_files(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/utils.py", line 221, in _open_input_files\n return [_set_context(fs.open(path, **kwargs), context_stack) for path in paths]\n ^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/spec.py", line 1338, in open\n f = self._open(\n ^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 210, in _open\n return LocalFileOpener(path, mode, fs=self, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 387, in __init__\n self._open()\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 392, in _open\n self.f = open(self.path, mode=self.mode)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n'

2026-03-15 07:24:11,924 - distributed.worker - ERROR - Compute Failed Key: ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 220) State: executing Task: <Task ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 220) <dask.dataframe.io.parquet.core.ParquetFunctionWra(...)> Exception: "FileNotFoundError(2, 'No such file or directory')" Traceback: ' File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 82, in __call__\n return read_parquet_part(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 184, in read_parquet_part\n func(\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 572, in read_partition\n arrow_table = cls._read_table(\n ^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 1704, in _read_table\n arrow_table = _read_table_from_path(\n ^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 255, in _read_table_from_path\n with _open_input_files(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/utils.py", line 221, in _open_input_files\n return [_set_context(fs.open(path, **kwargs), context_stack) for path in paths]\n ^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/spec.py", line 1338, in open\n f = self._open(\n ^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 210, in _open\n return LocalFileOpener(path, mode, fs=self, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 387, in __init__\n self._open()\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 392, in _open\n self.f = open(self.path, mode=self.mode)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n'

2026-03-15 07:24:11,919 - distributed.worker - ERROR - Compute Failed Key: ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 201) State: executing Task: <Task ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 201) <dask.dataframe.io.parquet.core.ParquetFunctionWra(...)> Exception: "FileNotFoundError(2, 'No such file or directory')" Traceback: ' File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 82, in __call__\n return read_parquet_part(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 184, in read_parquet_part\n func(\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 572, in read_partition\n arrow_table = cls._read_table(\n ^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 1704, in _read_table\n arrow_table = _read_table_from_path(\n ^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 255, in _read_table_from_path\n with _open_input_files(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/utils.py", line 221, in _open_input_files\n return [_set_context(fs.open(path, **kwargs), context_stack) for path in paths]\n ^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/spec.py", line 1338, in open\n f = self._open(\n ^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 210, in _open\n return LocalFileOpener(path, mode, fs=self, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 387, in __init__\n self._open()\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 392, in _open\n self.f = open(self.path, mode=self.mode)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n'

2026-03-15 07:24:11,919 - distributed.worker - ERROR - Compute Failed Key: ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 328) State: executing Task: <Task ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 328) <dask.dataframe.io.parquet.core.ParquetFunctionWra(...)> Exception: "FileNotFoundError(2, 'No such file or directory')" Traceback: ' File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 82, in __call__\n return read_parquet_part(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 184, in read_parquet_part\n func(\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 572, in read_partition\n arrow_table = cls._read_table(\n ^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 1704, in _read_table\n arrow_table = _read_table_from_path(\n ^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 255, in _read_table_from_path\n with _open_input_files(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/utils.py", line 221, in _open_input_files\n return [_set_context(fs.open(path, **kwargs), context_stack) for path in paths]\n ^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/spec.py", line 1338, in open\n f = self._open(\n ^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 210, in _open\n return LocalFileOpener(path, mode, fs=self, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 387, in __init__\n self._open()\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 392, in _open\n self.f = open(self.path, mode=self.mode)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n'

2026-03-15 07:24:11,912 - distributed.worker - ERROR - Compute Failed Key: ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 444) State: executing Task: <Task ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 444) <dask.dataframe.io.parquet.core.ParquetFunctionWra(...)> Exception: "FileNotFoundError(2, 'No such file or directory')" Traceback: ' File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 82, in __call__\n return read_parquet_part(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 184, in read_parquet_part\n func(\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 572, in read_partition\n arrow_table = cls._read_table(\n ^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 1704, in _read_table\n arrow_table = _read_table_from_path(\n ^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 255, in _read_table_from_path\n with _open_input_files(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/utils.py", line 221, in _open_input_files\n return [_set_context(fs.open(path, **kwargs), context_stack) for path in paths]\n ^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/spec.py", line 1338, in open\n f = self._open(\n ^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 210, in _open\n return LocalFileOpener(path, mode, fs=self, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 387, in __init__\n self._open()\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 392, in _open\n self.f = open(self.path, mode=self.mode)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n'

2026-03-15 07:21:14,799 - distributed.worker - ERROR - Compute Failed Key: ('read_parquet-8966918c2c258d0f3de779f8a5fd24b5', 458) State: executing Task: <Task ('read_parquet-8966918c2c258d0f3de779f8a5fd24b5', 458) <dask.dataframe.io.parquet.core.ParquetFunctionWra(...)> Exception: "FileNotFoundError(2, 'No such file or directory')" Traceback: ' File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 82, in __call__\n return read_parquet_part(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 184, in read_parquet_part\n func(\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 572, in read_partition\n arrow_table = cls._read_table(\n ^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 1704, in _read_table\n arrow_table = _read_table_from_path(\n ^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 255, in _read_table_from_path\n with _open_input_files(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/utils.py", line 221, in _open_input_files\n return [_set_context(fs.open(path, **kwargs), context_stack) for path in paths]\n ^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/spec.py", line 1338, in open\n f = self._open(\n ^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 210, in _open\n return LocalFileOpener(path, mode, fs=self, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 387, in __init__\n self._open()\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 392, in _open\n self.f = open(self.path, mode=self.mode)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n'

2026-03-15 07:21:14,798 - distributed.worker - ERROR - Compute Failed Key: ('read_parquet-8966918c2c258d0f3de779f8a5fd24b5', 337) State: executing Task: <Task ('read_parquet-8966918c2c258d0f3de779f8a5fd24b5', 337) <dask.dataframe.io.parquet.core.ParquetFunctionWra(...)> Exception: "FileNotFoundError(2, 'No such file or directory')" Traceback: ' File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 82, in __call__\n return read_parquet_part(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 184, in read_parquet_part\n func(\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 572, in read_partition\n arrow_table = cls._read_table(\n ^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 1704, in _read_table\n arrow_table = _read_table_from_path(\n ^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 255, in _read_table_from_path\n with _open_input_files(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/utils.py", line 221, in _open_input_files\n return [_set_context(fs.open(path, **kwargs), context_stack) for path in paths]\n ^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/spec.py", line 1338, in open\n f = self._open(\n ^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 210, in _open\n return LocalFileOpener(path, mode, fs=self, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 387, in __init__\n self._open()\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 392, in _open\n self.f = open(self.path, mode=self.mode)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n'

2026-03-15 07:21:14,798 - distributed.worker - ERROR - Compute Failed Key: ('read_parquet-8966918c2c258d0f3de779f8a5fd24b5', 323) State: executing Task: <Task ('read_parquet-8966918c2c258d0f3de779f8a5fd24b5', 323) <dask.dataframe.io.parquet.core.ParquetFunctionWra(...)> Exception: "FileNotFoundError(2, 'No such file or directory')" Traceback: ' File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 82, in __call__\n return read_parquet_part(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 184, in read_parquet_part\n func(\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 572, in read_partition\n arrow_table = cls._read_table(\n ^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 1704, in _read_table\n arrow_table = _read_table_from_path(\n ^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 255, in _read_table_from_path\n with _open_input_files(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/utils.py", line 221, in _open_input_files\n return [_set_context(fs.open(path, **kwargs), context_stack) for path in paths]\n ^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/spec.py", line 1338, in open\n f = self._open(\n ^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 210, in _open\n return LocalFileOpener(path, mode, fs=self, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 387, in __init__\n self._open()\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 392, in _open\n self.f = open(self.path, mode=self.mode)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n'

2026-03-15 07:17:43,078 - distributed.worker - ERROR - Compute Failed Key: ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 309) State: executing Task: <Task ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 309) <dask.dataframe.io.parquet.core.ParquetFunctionWra(...)> Exception: "FileNotFoundError(2, 'No such file or directory')" Traceback: ' File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 82, in __call__\n return read_parquet_part(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 184, in read_parquet_part\n func(\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 572, in read_partition\n arrow_table = cls._read_table(\n ^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 1704, in _read_table\n arrow_table = _read_table_from_path(\n ^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 255, in _read_table_from_path\n with _open_input_files(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/utils.py", line 221, in _open_input_files\n return [_set_context(fs.open(path, **kwargs), context_stack) for path in paths]\n ^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/spec.py", line 1338, in open\n f = self._open(\n ^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 210, in _open\n return LocalFileOpener(path, mode, fs=self, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 387, in __init__\n self._open()\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 392, in _open\n self.f = open(self.path, mode=self.mode)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n'

2026-03-15 07:17:43,078 - distributed.worker - ERROR - Compute Failed Key: ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 328) State: executing Task: <Task ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 328) <dask.dataframe.io.parquet.core.ParquetFunctionWra(...)> Exception: "FileNotFoundError(2, 'No such file or directory')" Traceback: ' File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 82, in __call__\n return read_parquet_part(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 184, in read_parquet_part\n func(\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 572, in read_partition\n arrow_table = cls._read_table(\n ^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 1704, in _read_table\n arrow_table = _read_table_from_path(\n ^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 255, in _read_table_from_path\n with _open_input_files(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/utils.py", line 221, in _open_input_files\n return [_set_context(fs.open(path, **kwargs), context_stack) for path in paths]\n ^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/spec.py", line 1338, in open\n f = self._open(\n ^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 210, in _open\n return LocalFileOpener(path, mode, fs=self, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 387, in __init__\n self._open()\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 392, in _open\n self.f = open(self.path, mode=self.mode)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n'

2026-03-15 07:17:43,074 - distributed.worker - ERROR - Compute Failed Key: ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 201) State: executing Task: <Task ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 201) <dask.dataframe.io.parquet.core.ParquetFunctionWra(...)> Exception: "FileNotFoundError(2, 'No such file or directory')" Traceback: ' File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 82, in __call__\n return read_parquet_part(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 184, in read_parquet_part\n func(\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 572, in read_partition\n arrow_table = cls._read_table(\n ^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 1704, in _read_table\n arrow_table = _read_table_from_path(\n ^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 255, in _read_table_from_path\n with _open_input_files(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/utils.py", line 221, in _open_input_files\n return [_set_context(fs.open(path, **kwargs), context_stack) for path in paths]\n ^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/spec.py", line 1338, in open\n f = self._open(\n ^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 210, in _open\n return LocalFileOpener(path, mode, fs=self, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 387, in __init__\n self._open()\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 392, in _open\n self.f = open(self.path, mode=self.mode)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n'

2026-03-15 07:17:43,070 - distributed.worker - ERROR - Compute Failed Key: ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 444) State: executing Task: <Task ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 444) <dask.dataframe.io.parquet.core.ParquetFunctionWra(...)> Exception: "FileNotFoundError(2, 'No such file or directory')" Traceback: ' File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 82, in __call__\n return read_parquet_part(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 184, in read_parquet_part\n func(\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 572, in read_partition\n arrow_table = cls._read_table(\n ^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 1704, in _read_table\n arrow_table = _read_table_from_path(\n ^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 255, in _read_table_from_path\n with _open_input_files(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/utils.py", line 221, in _open_input_files\n return [_set_context(fs.open(path, **kwargs), context_stack) for path in paths]\n ^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/spec.py", line 1338, in open\n f = self._open(\n ^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 210, in _open\n return LocalFileOpener(path, mode, fs=self, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 387, in __init__\n self._open()\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 392, in _open\n self.f = open(self.path, mode=self.mode)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n'

2026-03-15 07:17:43,069 - distributed.worker - ERROR - Compute Failed Key: ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 85) State: executing Task: <Task ('read_parquet-d002924f5c8ac6995f77a96974b4a56a', 85) <dask.dataframe.io.parquet.core.ParquetFunctionWra(...)> Exception: "FileNotFoundError(2, 'No such file or directory')" Traceback: ' File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 82, in __call__\n return read_parquet_part(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/core.py", line 184, in read_parquet_part\n func(\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 572, in read_partition\n arrow_table = cls._read_table(\n ^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 1704, in _read_table\n arrow_table = _read_table_from_path(\n ^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/parquet/arrow.py", line 255, in _read_table_from_path\n with _open_input_files(\n ^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/dask/dataframe/io/utils.py", line 221, in _open_input_files\n return [_set_context(fs.open(path, **kwargs), context_stack) for path in paths]\n ^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/spec.py", line 1338, in open\n f = self._open(\n ^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 210, in _open\n return LocalFileOpener(path, mode, fs=self, **kwargs)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 387, in __init__\n self._open()\n File "/opt/conda/lib/python3.12/site-packages/fsspec/implementations/local.py", line 392, in _open\n self.f = open(self.path, mode=self.mode)\n ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n'

2026-02-20 11:06:20,506 - distributed.worker - INFO - -------------------------------------------------

2026-02-20 11:06:20,506 - distributed.worker - INFO - Registered to: tcp://simple-scheduler.dask-operator.svc.cluster.local:8786

2026-02-20 11:06:20,505 - distributed.worker - INFO - Starting Worker plugin shuffle

2026-02-20 11:06:20,478 - distributed.worker - INFO - -------------------------------------------------

2026-02-20 11:06:20,478 - distributed.worker - INFO - Local Directory: /mnt/scratch/dask-scratch-space/worker-4smrdgu8

2026-02-20 11:06:20,478 - distributed.worker - INFO - Memory: 70.00 GiB

2026-02-20 11:06:20,478 - distributed.worker - INFO - Threads: 5

2026-02-20 11:06:20,478 - distributed.worker - INFO - -------------------------------------------------

2026-02-20 11:06:20,478 - distributed.worker - INFO - Waiting to connect to: tcp://simple-scheduler.dask-operator.svc.cluster.local:8786

2026-02-20 11:06:20,478 - distributed.worker - INFO - dashboard at: 172.18.196.134:8788

2026-02-20 11:06:20,478 - distributed.worker - INFO - Worker name: simple-default-worker-ecf89bf466

2026-02-20 11:06:20,478 - distributed.worker - INFO - Listening to: tcp://172.18.196.134:34867

2026-02-20 11:06:20,477 - distributed.worker - INFO - Start worker at: tcp://172.18.196.134:34867