code: def _get_tileable_chunk_data(sync_session, tileable):
      @enter_mode(build=True)
      async def _async_fetch():
          tuples = []
          async_session = sync_session._session
          meta_api = async_session._meta_api
  
          t, indexes = async_session._get_to_fetch_tileable(tileable)
          fetcher = Fetcher.create(
              MARS_CI_BACKEND,
              get_storage_api=async_session._get_storage_api,
          )
  
          get_metas = []
          for chunk in t.chunks:
              get_metas.append(
                  meta_api.get_chunk_meta.delay(
                      chunk.key, fields=fetcher.required_meta_keys
                  )
              )
          metas = await meta_api.get_chunk_meta.batch(*get_metas)
  
          for chunk, meta in zip(t.chunks, metas):
              await fetcher.append(chunk.key, meta)
          all_data = await fetcher.get()
  
          for chunk, data in zip(t.chunks, all_data):
              tuples.append((t, chunk, data))
          return tuples
  
      future = asyncio.run_coroutine_threadsafe(
          _async_fetch(), sync_session._isolation.loop
      )
      return future.result(120 if "CI" in os.environ else None)
  
file_path: mars/mars/learn/ensemble/tests/test_bagging.py
imports: import asyncio
  import os
  import numpy
  import pandas
  import pytest
  from sklearn.datasets import make_classification, make_regression
  from sklearn.linear_model import LinearRegression, LogisticRegression
  from sklearn.svm import SVC
  from ....None import tensor, dataframe, execute
  from ....conftest import MARS_CI_BACKEND
  from ....core import enter_mode
  from ....services.task.execution.api import Fetcher
  from .._bagging import _extract_bagging_io, BaggingSample, BaggingSampleReindex, BaggingClassifier, BaggingRegressor
label_desc: Use image node_id 1 for calling a global function with example usage: _get_tileable_chunk_data(sync_session, tileable) and returns: future, tuples