code: def managed_cluster_restarts(
      managed_cluster_session: ManagedCluster, request: Any
  ) -> Iterator[
      ManagedCluster
  ]:  # check if priority scheduler or not using config.
      config = str(DEVCLUSTER_REATTACH_ON_CONFIG_PATH)
      # port number is same for both reattach on and off config files so you can use either.
      set_master_port(config)
      nodeid = request.node.nodeid
      managed_cluster_session.log_marker(
          f"pytest [{now_ts()}] {nodeid} setup\n"
      )
      yield managed_cluster_session
      managed_cluster_session.log_marker(
          f"pytest [{now_ts()}] {nodeid} teardown\n"
      )
  
imports: import json
  import os
  import subprocess
  import time
  from typing import Any, Dict, Iterator, List, Union, cast
  import pytest
  from tests import config
  from .abstract_cluster import Cluster
  from .test_users import logged_in_user
  from .utils import now_ts, set_master_port
label_desc: Use image node_id 5 for calling a global function with example usage: managed_cluster_restarts(managed_cluster_session, request) without return types