code: def get_drill_query(query):
      new_query = query
      for table_name in get_table_occurrences(query):
          # for concurrent test and tables from sql tests
          enum_list = list(map(lambda c: c.name, DataType))
          a = ["_" + e for e in enum_list]
          a.remove("_UNDEFINED")
          for dtyp in a:
              new_query = new_query.replace(str(dtyp), "")
  
          # patch the tables
          new_query = replace_all(
              new_query,
              {
                  table_name: " dfs.tmp.`%(table)s` "
                  % {"table": table_name}
              },
          )
      return new_query
  
imports: import json
  import logging
  import os
  import re
  import time
  import yaml
  import numpy
  import pandas
  import blazingsql
  from blazingsql import DataType
  from BlazingLogging import loggingHandler
  from Configuration import ExecutionMode
  from Configuration import Settings
  from DataBase import createSchema
label_desc: Use image node_id 30 for calling a global function with example usage: get_drill_query(query) and returns: new_query