code: def pre_execute_callback_example(
      a_pipeline, a_node, current_param_override
  ):
      # type (PipelineController, PipelineController.Node, dict) -> bool
      print(
          "Cloning Task id={} with parameters: {}".format(
              a_node.base_task_id, current_param_override
          )
      )
      # if we want to skip this node (and subtree of this node) we return False
      # return True to continue DAG execution
      return True
  
label_desc: Use image node_id 1 for calling a global function with example usage: pre_execute_callback_example(a_pipeline, a_node, current_param_override) and returns: True