Method load_async

xarray/core/variable.py:1025–1056

Trigger and await asynchronous loading of data into memory and return this variable. Data will be computed and/or loaded from disk or a remote source. Unlike ``.compute``, the original variable is modified and returned. Only works when opening data lazily from IO storage b

(self, **kwargs)

        return self

    async def load_async(self, **kwargs) -> Self:
        """Trigger and await asynchronous loading of data into memory and return this variable.

        Data will be computed and/or loaded from disk or a remote source.

        Unlike ``.compute``, the original variable is modified and returned.

        Only works when opening data lazily from IO storage backends which support lazy asynchronous loading.
        Otherwise will raise a NotImplementedError.

        Note users are expected to limit concurrency themselves - xarray does not internally limit concurrency in any way.

        Parameters
        ----------
        **kwargs : dict
            Additional keyword arguments passed on to ``dask.array.compute``.

        Returns
        -------
        object : Variable
            Same object but with lazy data as an in-memory array.

        See Also
        --------
        dask.array.compute
        Variable.load
        Variable.compute
        DataArray.load_async
        Dataset.load_async
        """
        self._data = await async_to_duck_array(self._data, **kwargs)
        return self

    def compute(self, **kwargs) -> Self:
        """Trigger loading data into memory and return a new variable.