code: def dquery(nRals, single_node_sql, distrubuted_sql):
      if int(nRals) == 1:
          return single_node_sql
      else:
          return distrubuted_sql
  
imports: import copy
  import os
  from blazingsql import BlazingContext, DataType
  from dask.distributed import Client
  from dask_cuda import LocalCUDACluster
  from dask_cuda.utils import CPUAffinity, get_cpu_affinity
  from Configuration import ExecutionMode
  from Configuration import Settings
  from DataBase import createSchema
label_desc: Use image node_id 1 for calling a global function with example usage: dquery(nRals, single_node_sql, distrubuted_sql) and returns: single_node_sql, distrubuted_sql