code: def test_rolling_sync(client):
      df = make_time_dataframe()
      ddf = dd.from_pandas(df, npartitions=10)
      ddf.A.rolling(2).mean().compute()
  
file_path: distributed/distributed/tests/test_dask_collections.py
imports: from __future__ import annotations
  import pytest
  from packaging.version import parse
  from pandas.testing import assert_frame_equal, assert_index_equal, assert_series_equal
  import dask
  import dask.bag
  import dask.dataframe
  from distributed.client import wait
  from distributed.nanny import Nanny
  from distributed.utils_test import gen_cluster
label_desc: Use image node_id 5 for calling a global function with example usage: test_rolling_sync(client) without return types