fix: pass node props through graph execution pipeline

- tick_execution SQL now includes 'props' in job payload alongside 'inputs'
- compute-worker converts props array [{name,type,value}] to flat object for impl()
- const/string, const/number, const/boolean now work end-to-end in graph execution
- graph node failures no longer retry (return instead of re-throw after failGraphExecution)
- add Export/Import JSON graph buttons to FlowsPanel toolbar for debugging

Author: pyramation

job/compute-worker/src/index.ts

@@ -35,8 +35,8 @@ export { TtlCache } from './cache';
 export type { ComputeLogEntry } from './compute-log';
 export { ComputeLogTracker } from './compute-log';
 export { FunctionDiscovery } from './discovery';
-export { executeInline, getInlineImpl, listInlineNodes } from './inline';
 export type { InlineImplFn, InlineNodeDef } from './inline';
+export { executeInline, getInlineImpl, listInlineNodes } from './inline';
 export { InvocationTracker } from './invocation';
 export { ComputeModuleLoader } from './module-loader';
 export type { ComputeRequestOptions, ComputeRequestResult } from './req';
@@ -330,6 +330,15 @@ export default class ComputeWorker {
     // Inline nodes use inputs directly; props come from the graph node definition
     const inputs = graphNode ? (payload.inputs as Record<string, unknown>) : (payload as Record<string, unknown>);
 
+    // Convert props from array format [{name, type, value}, ...] to flat {name: value}
+    const propsArray = (graphNode && Array.isArray(payload.props)) ? payload.props : [];
+    const props: Record<string, unknown> = {};
+    for (const p of propsArray) {
+      if (p && typeof p === 'object' && 'name' in p) {
+        props[p.name as string] = p.value;
+      }
+    }
+
     await this.setJobGUCs(job);
 
     const { id: invocationId } = await this.tracker.create({
@@ -343,7 +352,7 @@ export default class ComputeWorker {
 
     const reqStart = process.hrtime();
     try {
-      const result = await executeInline(functionName, inputs, {});
+      const result = await executeInline(functionName, inputs, props);
 
       const elapsed = process.hrtime(reqStart);
       const ms = Math.round((elapsed[0] * 1e9 + elapsed[1]) / 1e6);
@@ -400,6 +409,9 @@ export default class ComputeWorker {
         } catch (graphErr) {
           log.error('Failed to mark graph execution as failed', graphErr);
         }
+        // Don't re-throw for graph nodes — execution is already marked failed.
+        // Re-throwing would cause the job queue to retry with the same permanent error.
+        return;
       }
       throw err;
     }
@@ -538,6 +550,9 @@ export default class ComputeWorker {
         } catch (graphErr) {
           log.error('Failed to mark graph execution as failed', graphErr);
         }
+        // Don't re-throw for graph nodes — execution is already marked failed.
+        // Re-throwing would cause the job queue to retry with the same permanent error.
+        return;
       }
       throw err;
     }

pgpm/constructive-compute/deploy/schemas/constructive_compute_private/procedures/platform_tick_execution/procedure.sql

@@ -178,7 +178,7 @@ BEGIN
       payload
     )
     VALUES
-      (v_exec.database_id, (('fbp:eval:' || v_graph.context) || ':') || v_node_type, (json_build_object('execution_id', v_exec.id, 'node_name', v_node_name, 'node_type', v_node_type, 'inputs', v_inputs))::json);
+      (v_exec.database_id, (('fbp:eval:' || v_graph.context) || ':') || v_node_type, (json_build_object('execution_id', v_exec.id, 'node_name', v_node_name, 'node_type', v_node_type, 'inputs', v_inputs, 'props', v_node->'props'))::json);
     v_jobs_enqueued := v_jobs_enqueued + 1;
   END LOOP;
   UPDATE "constructive_compute_private".platform_function_graph_executions SET

pgpm/constructive-compute/sql/constructive-compute--0.0.1.sql

@@ -389,7 +389,7 @@ BEGIN
       payload
     )
     VALUES
-      (v_exec.database_id, v_node_type, (json_build_object('execution_id', v_exec.id, 'node_name', v_node_name, 'node_type', v_node_type, 'inputs', v_inputs))::json);
+      (v_exec.database_id, v_node_type, (json_build_object('execution_id', v_exec.id, 'node_name', v_node_name, 'node_type', v_node_type, 'inputs', v_inputs, 'props', v_node->'props'))::json);
     v_jobs_enqueued := v_jobs_enqueued + 1;
   END LOOP;
   UPDATE "constructive_compute_private".platform_function_graph_executions SET

www/src/components/FlowsPanel.tsx

@@ -13,7 +13,7 @@ import {
 import type { NodeDefinitionWithImpl } from '@fbp/evaluator';
 import type { Graph, NodeDefinition, Node } from '@fbp/types';
 import { compute } from '@constructive-functions/constructive-functions-hooks';
-import { RefreshCw, Save, Trash2, Plus, Play, Zap, ChevronDown, ChevronRight, Cloud, Server } from 'lucide-react';
+import { RefreshCw, Save, Trash2, Plus, Play, Zap, ChevronDown, ChevronRight, Cloud, Server, Download, Upload } from 'lucide-react';
 
 const DATABASE_ID = '00000000-0000-0000-0000-000000000000';
 const BOUNDARY_NAMES = ['graph/input', 'graph/output', 'graph/prop'];
@@ -908,6 +908,36 @@ export function FlowsPanel() {
     e.dataTransfer.effectAllowed = 'copy';
   }, []);
 
+  const handleExportGraph = useCallback(() => {
+    const graph = graphRef.current;
+    const blob = new Blob([JSON.stringify(graph, null, 2)], { type: 'application/json' });
+    const url = URL.createObjectURL(blob);
+    const a = document.createElement('a');
+    a.href = url;
+    a.download = `${flowName.trim() || 'graph'}.json`;
+    a.click();
+    URL.revokeObjectURL(url);
+  }, [flowName]);
+
+  const handleImportGraph = useCallback(() => {
+    const input = document.createElement('input');
+    input.type = 'file';
+    input.accept = '.json';
+    input.onchange = async (e) => {
+      const file = (e.target as HTMLInputElement).files?.[0];
+      if (!file) return;
+      try {
+        const text = await file.text();
+        const graph = JSON.parse(text) as Graph;
+        setCurrentGraph(graph);
+        if (graph.name) setFlowName(graph.name);
+      } catch (err) {
+        console.error('Failed to import graph:', err);
+      }
+    };
+    input.click();
+  }, []);
+
   const toggleCategory = useCallback((cat: string) => {
     setCollapsedCategories(prev => {
       const next = new Set(prev);
@@ -969,6 +999,20 @@ export function FlowsPanel() {
             <Trash2 size={14} />
           </button>
         )}
+        <button
+          onClick={handleExportGraph}
+          className="flex items-center gap-1 px-2 py-1.5 rounded-md text-sm text-zinc-400 hover:text-zinc-200 hover:bg-zinc-800 transition-colors"
+          title="Export graph as JSON"
+        >
+          <Download size={14} />
+        </button>
+        <button
+          onClick={handleImportGraph}
+          className="flex items-center gap-1 px-2 py-1.5 rounded-md text-sm text-zinc-400 hover:text-zinc-200 hover:bg-zinc-800 transition-colors"
+          title="Import graph from JSON"
+        >
+          <Upload size={14} />
+        </button>
         {saveStatus && (
           <span className={`text-xs ${saveStatus.startsWith('Error') ? 'text-red-400' : 'text-green-400'}`}>
             {saveStatus}