code: def task_complete_check_wrapper(
      run_func: Callable, complete_check_func: Callable
  ):
      @functools.wraps(run_func)
      def wrapper(*args, **kwargs):
          if complete_check_func():
              logger.warning(
                  f"{run_func.__name__} is skipped because the task is already completed."
              )
              return
          return run_func(*args, **kwargs)
  
      return wrapper
  
label_desc: Use image node_id 1 for calling a global function with example usage: task_complete_check_wrapper(run_func, complete_check_func) and returns: wrapper, run_func