Method startNodeExecution

backend/src/build-system/context.ts:288–339

* Starts the execution of a specific node in the build sequence. * The node will be executed if it's eligible (i.e., not completed or pending). * @param node The node to execute. * @returns A promise resolving to the result of the node execution.

(
    node: BuildNode,
  )

   * @returns A promise resolving to the result of the node execution.
   */
  private startNodeExecution<T extends BuildHandler>(
    node: BuildNode,
  ): Promise<BuildResult<ExtractHandlerType<T>>> {
    const handlerName = node.handler.name;

    // If the node is already completed, pending, or failed, skip execution
    if (
      this.executionState.completed.has(handlerName) ||
      this.executionState.pending.has(handlerName) ||
      this.executionState.failed.has(handlerName)
    ) {
      this.logger.debug(`Node ${handlerName} already executed or in progress`);
      return;
    }

    // Mark the node as pending execution
    this.executionState.pending.add(handlerName);

    // Start monitoring node execution
    this.monitor.startNodeExecution(handlerName, this.sequence.id);

    // Execute the node handler and update the execution state accordingly
    const executionPromise = this.invokeNodeHandler<ExtractHandlerType<T>>(node)
      .then((result) => {
        // Mark the node as completed and update the state
        this.executionState.completed.add(handlerName);
        this.executionState.pending.delete(handlerName);
        // Store the result of the node execution
        this.setNodeData(node.handler, result.data);
        // End monitoring for successful execution
        this.monitor.endNodeExecution(handlerName, this.sequence.id, true);
        return result;
      })
      .catch((error) => {
        // Mark the node as failed in case of an error
        this.executionState.failed.add(handlerName);
        this.executionState.pending.delete(handlerName);
        this.logger.error(`[Node Failed] ${handlerName}:`, error);
        // End monitoring for failed execution
        this.monitor.endNodeExecution(
          handlerName,
          this.sequence.id,
          false,
          error,
        );
        throw error;
      });

    // Track the running node execution promise
    this.runningNodes.set(handlerName, executionPromise);
    return executionPromise;
  }

  /**
   * Executes the entire build sequence by iterating over all nodes in the sequence.