Assembly build request · workflow contract

name	required	type / hint
`assembly_id`	required	integer
`qty`	required	integer
`location_id`	required	integer
`reason`	optional	string

3 · Context loaded D1 queries run before fan-out

name

assembly

tables

assemblies

returns

row

SELECT
  id, itemid, displayname, quantityavailable
  FROM assemblies
  WHERE id = ?

name

current_bom

tables

assembly_bom

returns

rows

SELECT
  item_code, qty, uom, estimated_cost
  FROM assembly_bom
  WHERE assembly_id = ?

name

on_hand

tables

inventory_balance · assembly_bom

returns

rows

SELECT
  item_code, quantityavailable
  FROM inventory_balance
  WHERE location_id = ?
  AND item_code IN (SELECT item_code
  FROM assembly_bom
  WHERE assembly_id = ?)

name

cost_rollup

tables

assembly_cost_rollup

returns

row

SELECT
  computed_at, total_cost
  FROM assembly_cost_rollup
  WHERE assembly_id = ?
  ORDER BY computed_at DESC
  LIMIT 1

check	rule	severity
`assembly_exists`	`assembly_id IN (SELECT id FROM assemblies)`	block
`qty_positive`	`qty > 0`	block
`location_valid`	`location_id IN (SELECT id FROM locations WHERE active=1)`	block
`components_on_hand`	`every BOM line.on_hand >= qty * bom.qty`	warn

6 · Fan-out targets 10 total · 3 real · 7 stub

#1`snapshot_cost` d1_write STUB

table

assembly_cost_rollup

operation

insert

stub — not yet implemented in src/lib/workflow_runner.ts (kind d1_write hits the placeholder branch). Documented intent only.

INSERT INTO assembly_cost_rollup (assembly_id, total_cost, computed_at, source)
  VALUES (?,?,datetime('now'),'build_request')

#2`draft_proposal` stage_proposed_action REAL

action_type

assembly_build

entity_type

assembly

#3`hitl_approve` stage_proposed_action REAL

action_type

assembly_build_approval

entity_type

workflow_run

#4`ns_push_build` ns_push STUB

NS record_type

assemblybuild

queue

NS_PUSH_QUEUE

on_failure

retry_3_then_alert

stub — not yet implemented in src/lib/workflow_runner.ts (kind ns_push hits the placeholder branch). Documented intent only.

#5`d1_inventory_decrement` d1_write STUB

table

inventory_balance

operation

update

stub — not yet implemented in src/lib/workflow_runner.ts (kind d1_write hits the placeholder branch). Documented intent only.

UPDATE inventory_balance
  SET quantityavailable = quantityavailable - ?
  WHERE item_code = ?
  AND location_id = ?

#6`d1_inventory_increment` d1_write STUB

table

inventory_balance

operation

update

stub — not yet implemented in src/lib/workflow_runner.ts (kind d1_write hits the placeholder branch). Documented intent only.

UPDATE inventory_balance
  SET quantityavailable = quantityavailable + ?
  WHERE item_code = (SELECT itemid
  FROM assemblies
  WHERE id=?)
  AND location_id = ?

#7`kv_invalidate_assembly` kv_invalidate REAL

keys

assembly:?assembly_id
inventory:item:?assembly_id

#8`variance_flag` flag STUB

table

proposed_actions

field

action_type

value

build_cost_variance

condition (if)

abs((actual_cost - estimated_cost)/estimated_cost) > 0.05

stub — not yet implemented in src/lib/workflow_runner.ts (kind flag hits the placeholder branch). Documented intent only.

#9`refresh_quotes` http_call STUB

method

POST

path

/api/quotes/refresh-by-assembly

condition (if)

open_quotes_touching_assembly > 0

stub — not yet implemented in src/lib/workflow_runner.ts (kind http_call hits the placeholder branch). Documented intent only.

#10`reflexion_write` d1_write STUB

table

reflexion_log

operation

insert

stub — not yet implemented in src/lib/workflow_runner.ts (kind d1_write hits the placeholder branch). Documented intent only.

INSERT INTO reflexion_log (workflow_run_id, entity_type, entity_id, outcome, tags)
  VALUES (?,'assembly',?,?,'assembly_build')

id	action	source
`runner_log_run`	INSERT into `workflow_run_log` (run_id, workflow_type, status, started_at, completed_at, summary_json)	runner automatic
`runner_reflexion`	INSERT into `reflexion_log` (tags=`assembly_build_request`, run_id, narrative)	runner automatic (reflexion_enabled=1)
`log_run`	INSERT workflow_run_log	declared in contract
`reflexion`	INSERT reflexion_log with tags=assembly_build	declared in contract
`event_completed`	FIRE event workflow.completed (workflow_type=assembly_build_request)	declared in contract

8 · Verify checks written to `workflow_verify_results`

name

build_recorded_in_d1

when_to_run

15 min after run

expected

row

SELECT
  id
  FROM transactions
  WHERE type='Build'
  AND assembly_id=?
  AND created_at > datetime('now','-15 minutes')

name

inventory_credited

when_to_run

15 min after run

expected

increased by ?qty

SELECT
  quantityavailable
  FROM inventory_balance
  WHERE item_code=(SELECT itemid
  FROM assemblies
  WHERE id=?)
  AND location_id=?

name

ns_push_applied

when_to_run

30 min after run

expected

applied

SELECT
  status
  FROM ns_pending_pushes
  WHERE record_type='assemblybuild'
  AND payload_json LIKE '%assembly_id?%'

10 · What changes when this workflow runs aggregated side effects

system	table / resource	action	status	source
D1	`proposed_actions`	INSERT (action_type=assembly_build)	REAL	fan-out #2 (draft_proposal)
D1	`proposed_actions`	INSERT (action_type=assembly_build_approval)	REAL	fan-out #3 (hitl_approve)
KV (CACHE)	`assembly:?assembly_id, inventory:item:?assembly_id`	invalidate	REAL	fan-out #7 (kv_invalidate_assembly)
D1	`workflow_run_log`	INSERT (run summary)	REAL	runner automatic
D1	`reflexion_log`	INSERT (tags=assembly_build_request)	REAL	runner automatic
Event	`workflow.completed (or workflow.failed)`	fire	REAL	runner automatic
D1	`workflow_verify_results`	INSERT pending × 3	REAL	runner verify staging
D1	`assembly_cost_rollup`	insert	STUB	fan-out #1 (snapshot_cost)
NetSuite (via NS_PUSH_QUEUE)	`assemblybuild`	push	STUB	fan-out #4 (ns_push_build)
D1	`inventory_balance`	update	STUB	fan-out #5 (d1_inventory_decrement)
D1	`inventory_balance`	update	STUB	fan-out #6 (d1_inventory_increment)
D1	`proposed_actions`	set action_type=build_cost_variance	STUB	fan-out #8 (variance_flag)
Worker HTTP	`POST /api/quotes/refresh-by-assembly`	invoke	STUB	fan-out #9 (refresh_quotes)
D1	`reflexion_log`	insert	STUB	fan-out #10 (reflexion_write)

Assembly build request risk 2 · lowmanual_or_eventreflexion on

0 · Visual flow Assembly build request — 10 fan-out targets, 3 verify checks

1 · Trigger FIRES WHEN…

2 · Inputs required

3 · Context loaded D1 queries run before fan-out

4 · Preconditions checked before any fan-out

5 · HITL gate

6 · Fan-out targets 10 total · 3 real · 7 stub

#1`snapshot_cost` d1_write STUB

#2`draft_proposal` stage_proposed_action REAL

#3`hitl_approve` stage_proposed_action REAL

#4`ns_push_build` ns_push STUB

#5`d1_inventory_decrement` d1_write STUB

#6`d1_inventory_increment` d1_write STUB

#7`kv_invalidate_assembly` kv_invalidate REAL

#8`variance_flag` flag STUB

#9`refresh_quotes` http_call STUB

#10`reflexion_write` d1_write STUB

7 · Post actions declared + runner-automatic

8 · Verify checks written to `workflow_verify_results`

9 · Retry policy

10 · What changes when this workflow runs aggregated side effects

0 · Visual flow Assembly build request — 10 fan-out targets, 3 verify checks

1 · Trigger FIRES WHEN…

2 · Inputs required

3 · Context loaded D1 queries run before fan-out

4 · Preconditions checked before any fan-out

5 · HITL gate

6 · Fan-out targets 10 total · 3 real · 7 stub

#1snapshot_cost d1_write STUB

#2draft_proposal stage_proposed_action REAL

#3hitl_approve stage_proposed_action REAL

#4ns_push_build ns_push STUB

#5d1_inventory_decrement d1_write STUB

#6d1_inventory_increment d1_write STUB

#7kv_invalidate_assembly kv_invalidate REAL

#8variance_flag flag STUB

#9refresh_quotes http_call STUB

#10reflexion_write d1_write STUB

7 · Post actions declared + runner-automatic

8 · Verify checks written to workflow_verify_results

9 · Retry policy

10 · What changes when this workflow runs aggregated side effects

#1`snapshot_cost` d1_write STUB

#2`draft_proposal` stage_proposed_action REAL

#3`hitl_approve` stage_proposed_action REAL

#4`ns_push_build` ns_push STUB

#5`d1_inventory_decrement` d1_write STUB

#6`d1_inventory_increment` d1_write STUB

#7`kv_invalidate_assembly` kv_invalidate REAL

#8`variance_flag` flag STUB

#9`refresh_quotes` http_call STUB

#10`reflexion_write` d1_write STUB

8 · Verify checks written to `workflow_verify_results`