code: def test_set_get_restart_strategy(self):
      self.env.set_restart_strategy(RestartStrategies.no_restart())
  
      restart_strategy = self.env.get_restart_strategy()
  
      self.assertEqual(restart_strategy, RestartStrategies.no_restart())
  
imports: import datetime
  import decimal
  import glob
  import os
  import shutil
  import tempfile
  import time
  import uuid
  from pyflink.common import Configuration, ExecutionConfig, RestartStrategies
  from pyflink.common.typeinfo import Types
  from pyflink.datastream import StreamExecutionEnvironment, CheckpointConfig, CheckpointingMode, MemoryStateBackend, TimeCharacteristic, SlotSharingGroup
  from pyflink.datastream.connectors.kafka import FlinkKafkaConsumer
  from pyflink.datastream.execution_mode import RuntimeExecutionMode
  from pyflink.datastream.formats.json import JsonRowDeserializationSchema
  from pyflink.datastream.functions import SourceFunction
  from pyflink.datastream.slot_sharing_group import MemorySize
  from pyflink.datastream.tests.test_util import DataStreamTestSinkFunction
  from pyflink.find_flink_home import _find_flink_source_root
  from pyflink.java_gateway import get_gateway
  from pyflink.table import DataTypes, StreamTableEnvironment, EnvironmentSettings
  from pyflink.testing.test_case_utils import PyFlinkTestCase, exec_insert_table
  from pyflink.util.java_utils import get_j_env_configuration
label_desc: Use image node_id 6 for calling the StreamExecutionEnvironmentTests obj's underlying member method code with example usage: obj.test_set_get_restart_strategy() without return types