code: def test_sync_execute(config):
      session = new_session(
          backend=config["backend"],
          n_cpu=2,
          web=False,
          use_uvloop=False,
      )
  
      # web not started
      assert session._session.client.web_address is None
      assert session.get_web_endpoint() is None
  
      with session:
          raw = np.random.RandomState(0).rand(10, 5)
          a = mt.tensor(raw, chunk_size=5).sum(axis=1)
          b = a.execute(show_progress=False)
          assert b is a
          result = a.fetch()
          np.testing.assert_array_equal(result, raw.sum(axis=1))
  
          c = b + 1
          c.execute(show_progress=False)
          result = c.fetch()
          np.testing.assert_array_equal(result, raw.sum(axis=1) + 1)
  
          c = mt.tensor(raw, chunk_size=5).sum()
          d = session.execute(c)
          assert d is c
          assert abs(session.fetch(d) - raw.sum()) < 0.001
  
          with tempfile.TemporaryDirectory() as tempdir:
              file_path = os.path.join(tempdir, "test.csv")
              pdf = pd.DataFrame(
                  np.random.RandomState(0).rand(100, 10),
                  columns=[f"col{i}" for i in range(10)],
              )
              pdf.to_csv(file_path, index=False)
  
              df = md.read_csv(
                  file_path,
                  chunk_bytes=os.stat(file_path).st_size / 5,
                  incremental_index=True,
              )
              result = df.sum(axis=1).execute().fetch()
              expected = pd.read_csv(file_path).sum(axis=1)
              pd.testing.assert_series_equal(result, expected)
  
              df = md.read_csv(
                  file_path,
                  chunk_bytes=os.stat(file_path).st_size / 5,
                  incremental_index=True,
              )
              result = df.head(10).execute().fetch()
              expected = pd.read_csv(file_path).head(10)
              pd.testing.assert_frame_equal(result, expected)
  
      for worker_pool in session._session.client._cluster._worker_pools:
          _assert_storage_cleaned(
              session.session_id,
              worker_pool.external_address,
              StorageLevel.MEMORY,
          )
  
      session.stop_server()
      assert get_default_async_session() is None
  
imports: import asyncio
  import copy
  import gc
  import os
  import subprocess
  import sys
  import threading
  import tempfile
  import textwrap
  import time
  import uuid
  import weakref
  import numpy
  import pandas
  import psutil
  import pytest
  from ....None import dataframe
  from ....None import tensor
  from ....None import remote
  from ....config import option_context
  from ....core.context import get_context
  from ....lib.aio import new_isolation
  from ....storage import StorageLevel
  from ....services.storage import StorageAPI
  from ....services.task.supervisor.task import TaskProcessor
  from ....session import get_default_async_session, get_default_session, clear_default_session, new_session, execute, fetch, fetch_infos, stop_server, AsyncSession, ExecutionInfo, Profiling, Progress, _execute_with_progress
  from ....tensor.arithmetic.add import TensorAdd
  from ....tests.core import mock, check_dict_structure_same, DICT_NOT_EMPTY
  from ..local import new_cluster, _load_config
  from ..session import _IsolatedWebSession
  from ..tests.session import new_test_session
  from .modules.utils import cleanup_third_party_modules_output, get_output_filenames
label_desc: Use image node_id 3 for calling a global function with example usage: test_sync_execute(config) without return types