Method load_async

xarray/core/dataarray.py:1179–1214

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

(self, **kwargs)

        return self

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

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

        Unlike ``.compute``, the original dataarray 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.compute``.

        Returns
        -------
        object : Dataarray
            Same object but with lazy data and coordinates as in-memory arrays.

        See Also
        --------
        dask.compute
        DataArray.compute
        DataArray.load
        Dataset.load_async
        Variable.load_async
        """
        temp_ds = self._to_temp_dataset()
        ds = await temp_ds.load_async(**kwargs)
        new = self._from_temp_dataset(ds)
        self._variable = new._variable
        self._coords = new._coords
        return self

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