Function runAction

worker/src/temporal/workflow-runner.ts:83–456

(
      actionRef: string,
      schedulerContext: WorkflowSchedulerRunContext,
    )

  try {
    const runAction = async (
      actionRef: string,
      schedulerContext: WorkflowSchedulerRunContext,
    ): Promise<{ activePorts?: string[] | undefined } | null> => {
      console.log(
        `🎯 [WORKFLOW RUNNER] runAction called for: ${actionRef} (triggered by: ${schedulerContext.triggeredBy || 'root'})`,
      );

      const action = actionsByRef.get(actionRef);
      if (!action) {
        throw new NotFoundError(`Action not found: ${actionRef}`, {
          resourceType: 'action',
          resourceId: actionRef,
          details: { runId },
        });
      }

      const { triggeredBy, failure } = schedulerContext;

      const entry = componentRegistry.getMetadata(action.componentId);
      if (!entry) {
        throw new NotFoundError(`Component not registered: ${action.componentId}`, {
          resourceType: 'component',
          resourceId: action.componentId,
          details: { actionRef, runId },
        });
      }
      const component = entry.definition;
      const inputPorts = entry.inputs ?? [];
      const outputPorts = entry.outputs ?? [];

      const nodeMetadata = definition.nodes?.[action.ref];
      const streamId = nodeMetadata?.streamId ?? nodeMetadata?.groupId ?? action.ref;
      const joinStrategy = nodeMetadata?.joinStrategy ?? schedulerContext.joinStrategy;

      // Record trace event
      options.trace?.record({
        type: 'NODE_STARTED',
        runId,
        nodeRef: action.ref,
        timestamp: new Date().toISOString(),
        level: 'info',
        context: {
          runId,
          componentRef: action.ref,
          streamId,
          joinStrategy,
          triggeredBy,
          failure,
        },
      });

      const { inputs, params, warnings, manualOverrides } = buildActionPayload(action, results, {
        componentMetadata: { inputs: inputPorts },
      });

      for (const override of manualOverrides) {
        options.trace?.record({