code: def test_add_python_file(self):
      python_file_dir = os.path.join(
          self.tempdir, "python_file_dir_" + str(uuid.uuid4())
      )
      os.mkdir(python_file_dir)
      python_file_path = os.path.join(
          python_file_dir, "test_dependency_manage_lib.py"
      )
      with open(python_file_path, "w") as f:
          f.write(
              "def add_two(a):\n    raise Exception('This function should not be called!')"
          )
      self.t_env.add_python_file(python_file_path)
  
      python_file_dir_with_higher_priority = os.path.join(
          self.tempdir, "python_file_dir_" + str(uuid.uuid4())
      )
      os.mkdir(python_file_dir_with_higher_priority)
      python_file_path_higher_priority = os.path.join(
          python_file_dir_with_higher_priority,
          "test_dependency_manage_lib.py",
      )
      with open(python_file_path_higher_priority, "w") as f:
          f.write("def add_two(a):\n    return a + 2")
      self.t_env.add_python_file(python_file_path_higher_priority)
  
      def plus_two(i):
          from test_dependency_manage_lib import add_two
  
          return add_two(i)
  
      self.t_env.create_temporary_system_function(
          "add_two",
          udf(plus_two, DataTypes.BIGINT(), DataTypes.BIGINT()),
      )
      sink_table_ddl = """
          CREATE TABLE Results(a BIGINT, b BIGINT) WITH ('connector'='test-sink')
          """
      self.t_env.execute_sql(sink_table_ddl)
      t = self.t_env.from_elements([(1, 2), (2, 5), (3, 1)], ["a", "b"])
      t.select(expr.call("add_two", t.a), t.a).execute_insert(
          "Results"
      ).wait()
  
      actual = source_sink_utils.results()
      self.assert_equals(actual, ["+I[3, 1]", "+I[4, 2]", "+I[5, 3]"])
  
imports: import os
  import shutil
  import sys
  import unittest
  import uuid
  from pyflink.table import DataTypes, TableEnvironment, EnvironmentSettings
  from pyflink.table import expressions
  from pyflink.table.udf import udf
  from pyflink.testing import source_sink_utils
  from pyflink.testing.test_case_utils import PyFlinkTestCase
label_desc: Use image node_id 1 for calling the DependencyTests obj's underlying member method code with example usage: obj.test_add_python_file() and returns: add_two