Method _execute_node

scrapegraphai/graphs/base_graph.py:198–220

Executes a single node and returns execution information.

(self, current_node, state, llm_model, llm_model_name)

            return None

    def _execute_node(self, current_node, state, llm_model, llm_model_name):
        """Executes a single node and returns execution information."""
        curr_time = time.time()

        with self.callback_manager.exclusive_get_callback(
            llm_model, llm_model_name
        ) as cb:
            result = current_node.execute(state)
            node_exec_time = time.time() - curr_time

            cb_data = None
            if cb is not None:
                cb_data = {
                    "node_name": current_node.node_name,
                    "total_tokens": cb.total_tokens,
                    "prompt_tokens": cb.prompt_tokens,
                    "completion_tokens": cb.completion_tokens,
                    "successful_requests": cb.successful_requests,
                    "total_cost_USD": cb.total_cost,
                    "exec_time": node_exec_time,
                }

        return result, node_exec_time, cb_data

    def _get_next_node(self, current_node, result):
        """Determines the next node to execute based on current node type and result."""