code: def construct_test_classpath(env):
      test_jar_patterns = [
          "flink-python/target/test-dependencies/*",
          "flink-python/target/artifacts/testDataStream.jar",
          "flink-python/target/flink-python*-tests.jar",
      ]
      test_jars = []
  
      # Connector tests need to add specific jars to the gateway classpath
      if "FLINK_TEST_LIBS" in env:
          test_jars += glob.glob(env["FLINK_TEST_LIBS"])
      else:
          flink_source_root = _find_flink_source_root()
          for pattern in test_jar_patterns:
              pattern = pattern.replace("/", os.path.sep)
              test_jars += glob.glob(
                  os.path.join(flink_source_root, pattern)
              )
      return os.path.pathsep.join(test_jars)
  
imports: import argparse
  import getpass
  import glob
  import os
  import platform
  import signal
  import socket
  import sys
  from collections import namedtuple
  from string import Template
  from subprocess import Popen, PIPE
  from pyflink.find_flink_home import _find_flink_home, _find_flink_source_root
label_desc: Use image node_id 9 for calling a global function with example usage: construct_test_classpath(env) and returns: os