text: import importlib
  import os
  
  testdir = os.path.dirname(os.path.realpath("__file__"))
  srcdir = 'src/main/python/daggit'
  abs_path = os.path.join(testdir, srcdir)
  
  
  def get_op_callable(operator, module_path=None):
      if module_path:
          module = importlib.import_module(module_path)
          return getattr(module, operator)
      else:
          operator_full_path = operator.split('.')
          operator_name = operator_full_path.pop(-1)
          operator_module = '.'.join(operator_full_path)
          module_path_list = []
          for root, dirs, _ in os.walk(abs_path):
              if len(dirs) > 0:
                  if "operators" in dirs:
                      operator_dir = os.path.join(root, "operators")
                      module_path_list.append(
                          operator_dir[operator_dir.find("daggit"):].replace("/", "."))
          for path in module_path_list:
              try:
                  module = importlib.import_module(path + '.' + operator_module)
              except BaseException:
                  continue
          return getattr(module, operator_name)
  