[thehabbos007]

🌟 Purpose

Adds the hash-integrations-engine crate and its Workspace, a DuckDB file owned by one thread that runs an integration's SQL. The SQL comes from definitions, so the workspace runs only single SELECT statements, with file access, extensions and setting changes turned off.

🔍 Changes

• Select::check allows one SELECT statement, checked with json_serialize_sql, and only the table functions range, generate_series and unnest.
• Workspace::open locks <database>.lock, since DuckDB lets two connections in one process open the same file.
• Rows::readable refuses TIME_NS columns, which panic in the duckdb crate.
• Dropping a request's future cancels it: a queued request is skipped and a running one is interrupted. Callers set time limits with tokio::time::timeout.
• StatementError splits InvalidQuery, InvalidData and Failed by DuckDB's error type.
• Setting, QueryErrorType and DataErrorType take their names from their variants (type_info), as in BE-929: Parse pipelines from YAML #9984.
• A failure nobody awaits logs only its top-level message, since DuckDB messages can quote row values.

⚠️ Known issues

• DuckDB clears an interrupt when a statement starts, so a thread repeats the interrupt every 1 ms until the request ends. DuckDB's pending-query API would remove the thread, but the duckdb crate doesn't expose it.
• query holds every row in memory until the sink planner streams them.
• from_duckdb reads the error type from the message prefix (Binder Error: …), since the duckdb crate drops it. A renamed type falls back to Failed.
• serde_json refuses queries nested more than 128 levels deep, about 40 subqueries.

[codecov]

Codecov Report

❌ Patch coverage is 91.36276% with 45 lines in your changes missing coverage. Please review.
✅ Project coverage is 68.09%. Comparing base (8b1cbc2) to head (4461400).
⚠️ Report is 9 commits behind head on main.

Files with missing lines	Patch %	Lines
.../@local/integrations/engine/src/workspace/error.rs	77.14%	15 Missing and 1 partial ⚠️
...al/integrations/engine/src/workspace/connection.rs	90.44%	12 Missing and 3 partials ⚠️
...cal/integrations/engine/src/workspace/interrupt.rs	88.23%	8 Missing and 2 partials ⚠️
...bs/@local/integrations/engine/src/workspace/mod.rs	96.72%	1 Missing and 1 partial ⚠️
.../@local/integrations/engine/src/workspace/reply.rs	87.50%	2 Missing ⚠️

Additional details and impacted files

@@            Coverage Diff             @@
##             main   #10001      +/-   ##
==========================================
+ Coverage   68.03%   68.09%   +0.05%     
==========================================
  Files        2006     2016      +10     
  Lines      206233   206740     +507     
  Branches     8796     8811      +15     
==========================================
+ Hits       140312   140776     +464     
- Misses      64253    64290      +37     
- Partials     1668     1674       +6     

Flag	Coverage Δ
hash-integrations-engine	91.36% <91.36%> (?)

Flags with carried forward coverage won't be shown. Click here to find out more.

☔ View full report in Codecov by Harness.
📢 Have feedback on the report? Share it here.

🚀 New features to boost your workflow:

• ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.
• 📦 JS Bundle Analysis: Save yourself from yourself by tracking and limiting bundle sizes in JS merges.

[codspeed]

Merging this PR will degrade performance by 15.93%

2 warnings

⚠️ Unable to measure the execution of 6 benchmarks

These benchmarks measured no execution time, so their results are not comparable and count as unchanged. This usually happens when the compiler removes the code under test.

Prevent compiler optimizations

See affected benchmarks

⚠️ Base and head ran on different runner types

Some benchmarks with significant performance changes were compared across different runner types, so the changes might not come from the code. Run base and head on the same runner type, or use CodSpeed Macro Runners for more stable results.

Learn more about Macro Runners

Open the report in CodSpeed to investigate

❌ 2 regressed benchmarks
✅ 96 untouched benchmarks

Warning

Please fix the performance issues or acknowledge them on CodSpeed.

Performance Changes

	Benchmark	BASE	HEAD	Efficiency
❌	bit_matrix/dense/iter_row[64]	137.2 ns	166.4 ns	-17.53%
❌	bit_matrix/dense/iter_row[200]	174.7 ns	203.9 ns	-14.31%

Tip

Investigate this regression by commenting @codspeedbot fix this regression on this PR, or directly use the CodSpeed MCP with your agent.

---

_{Comparing asa/hash-integrations/04-engine-workspace (4461400) with main (edc93ea)¹}

Footnotes

1. No successful run was found on main (58a33de) during the generation of this report, so edc93ea was used instead as the comparison base. There might be some changes unrelated to this pull request in this report. ↩

[vercel]

The latest updates on your projects. Learn more about Vercel for GitHub.

Project	Deployment	Actions	Updated
hash	Ready	Preview	Oct 21, 2026 12:03pm UTC
petrinaut	Ready	Preview	Oct 21, 2026 12:03pm UTC
petrinaut-docs	Ready	Preview	Oct 21, 2026 12:03pm UTC

1 Skipped Deployment

Project	Deployment	Actions	Updated
hashdotdesign-tokens	Ignored	Preview	Oct 21, 2026 12:03pm UTC

[github-actions]

Benchmark results

hash-graph-benches – Integrations

policy_resolution_large

Function	Value	Mean	Flame graphs
resolve_policies_for_actor	user: empty, selectivity: high, policies: 2002	$$16.8 \mathrm{ms} \pm 110 \mathrm{μs}\left({\color{gray}-3.746 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: empty, selectivity: low, policies: 1	$$2.17 \mathrm{ms} \pm 21.8 \mathrm{μs}\left({\color{gray}-0.221 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: empty, selectivity: medium, policies: 1002	$$8.27 \mathrm{ms} \pm 94.1 \mathrm{μs}\left({\color{lightgreen}-5.159 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: seeded, selectivity: high, policies: 3314	$$29.0 \mathrm{ms} \pm 250 \mathrm{μs}\left({\color{gray}-1.091 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: seeded, selectivity: low, policies: 1	$$9.94 \mathrm{ms} \pm 94.1 \mathrm{μs}\left({\color{lightgreen}-9.421 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: seeded, selectivity: medium, policies: 1527	$$16.6 \mathrm{ms} \pm 209 \mathrm{μs}\left({\color{gray}-2.569 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: system, selectivity: high, policies: 2078	$$17.7 \mathrm{ms} \pm 115 \mathrm{μs}\left({\color{gray}-2.926 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: system, selectivity: low, policies: 1	$$2.37 \mathrm{ms} \pm 25.5 \mathrm{μs}\left({\color{gray}-0.188 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: system, selectivity: medium, policies: 1033	$$9.31 \mathrm{ms} \pm 121 \mathrm{μs}\left({\color{gray}-2.456 \mathrm{\%}}\right) $$	Flame Graph

policy_resolution_medium

Function	Value	Mean	Flame graphs
resolve_policies_for_actor	user: empty, selectivity: high, policies: 102	$$2.30 \mathrm{ms} \pm 17.5 \mathrm{μs}\left({\color{gray}-0.019 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: empty, selectivity: low, policies: 1	$$1.94 \mathrm{ms} \pm 17.6 \mathrm{μs}\left({\color{gray}2.86 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: empty, selectivity: medium, policies: 52	$$2.13 \mathrm{ms} \pm 16.0 \mathrm{μs}\left({\color{gray}-0.537 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: seeded, selectivity: high, policies: 269	$$3.18 \mathrm{ms} \pm 20.3 \mathrm{μs}\left({\color{gray}-1.179 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: seeded, selectivity: low, policies: 1	$$2.25 \mathrm{ms} \pm 24.6 \mathrm{μs}\left({\color{gray}2.01 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: seeded, selectivity: medium, policies: 108	$$2.56 \mathrm{ms} \pm 20.4 \mathrm{μs}\left({\color{gray}-2.583 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: system, selectivity: high, policies: 133	$$2.76 \mathrm{ms} \pm 34.5 \mathrm{μs}\left({\color{gray}3.67 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: system, selectivity: low, policies: 1	$$2.18 \mathrm{ms} \pm 13.7 \mathrm{μs}\left({\color{gray}2.08 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: system, selectivity: medium, policies: 63	$$2.59 \mathrm{ms} \pm 25.5 \mathrm{μs}\left({\color{gray}-1.100 \mathrm{\%}}\right) $$	Flame Graph

policy_resolution_none

Function	Value	Mean	Flame graphs
resolve_policies_for_actor	user: empty, selectivity: high, policies: 2	$$1.77 \mathrm{ms} \pm 17.4 \mathrm{μs}\left({\color{gray}4.34 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: empty, selectivity: low, policies: 1	$$1.71 \mathrm{ms} \pm 10.4 \mathrm{μs}\left({\color{gray}0.039 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: empty, selectivity: medium, policies: 2	$$1.80 \mathrm{ms} \pm 26.5 \mathrm{μs}\left({\color{gray}0.029 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: system, selectivity: high, policies: 8	$$1.95 \mathrm{ms} \pm 10.3 \mathrm{μs}\left({\color{gray}2.28 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: system, selectivity: low, policies: 1	$$1.83 \mathrm{ms} \pm 12.8 \mathrm{μs}\left({\color{gray}-2.044 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: system, selectivity: medium, policies: 3	$$1.98 \mathrm{ms} \pm 12.9 \mathrm{μs}\left({\color{gray}-1.303 \mathrm{\%}}\right) $$	Flame Graph

policy_resolution_small

Function	Value	Mean	Flame graphs
resolve_policies_for_actor	user: empty, selectivity: high, policies: 52	$$1.91 \mathrm{ms} \pm 11.2 \mathrm{μs}\left({\color{gray}-2.751 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: empty, selectivity: low, policies: 1	$$1.77 \mathrm{ms} \pm 12.3 \mathrm{μs}\left({\color{gray}-0.335 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: empty, selectivity: medium, policies: 26	$$1.86 \mathrm{ms} \pm 13.0 \mathrm{μs}\left({\color{gray}-1.819 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: seeded, selectivity: high, policies: 94	$$2.15 \mathrm{ms} \pm 12.8 \mathrm{μs}\left({\color{gray}-1.674 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: seeded, selectivity: low, policies: 1	$$1.99 \mathrm{ms} \pm 15.2 \mathrm{μs}\left({\color{gray}2.56 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: seeded, selectivity: medium, policies: 27	$$2.13 \mathrm{ms} \pm 24.5 \mathrm{μs}\left({\color{gray}0.794 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: system, selectivity: high, policies: 66	$$2.11 \mathrm{ms} \pm 18.4 \mathrm{μs}\left({\color{gray}-1.655 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: system, selectivity: low, policies: 1	$$1.92 \mathrm{ms} \pm 9.94 \mathrm{μs}\left({\color{gray}-2.119 \mathrm{\%}}\right) $$	Flame Graph
resolve_policies_for_actor	user: system, selectivity: medium, policies: 29	$$2.03 \mathrm{ms} \pm 17.3 \mathrm{μs}\left({\color{gray}-2.936 \mathrm{\%}}\right) $$	Flame Graph

read_scaling_complete

Function	Value	Mean	Flame graphs
entity_by_id;one_depth	1 entities	$$21.4 \mathrm{ms} \pm 219 \mathrm{μs}\left({\color{gray}-2.945 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id;one_depth	10 entities	$$44.4 \mathrm{ms} \pm 313 \mathrm{μs}\left({\color{gray}0.085 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id;one_depth	25 entities	$$25.7 \mathrm{ms} \pm 263 \mathrm{μs}\left({\color{gray}2.43 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id;one_depth	5 entities	$$24.9 \mathrm{ms} \pm 202 \mathrm{μs}\left({\color{gray}-2.779 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id;one_depth	50 entities	$$29.2 \mathrm{ms} \pm 191 \mathrm{μs}\left({\color{gray}-0.258 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id;two_depth	1 entities	$$22.7 \mathrm{ms} \pm 131 \mathrm{μs}\left({\color{gray}3.92 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id;two_depth	10 entities	$$231 \mathrm{ms} \pm 1.01 \mathrm{ms}\left({\color{gray}-0.066 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id;two_depth	25 entities	$$56.4 \mathrm{ms} \pm 487 \mathrm{μs}\left({\color{gray}-1.556 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id;two_depth	5 entities	$$44.4 \mathrm{ms} \pm 346 \mathrm{μs}\left({\color{gray}-3.183 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id;two_depth	50 entities	$$164 \mathrm{ms} \pm 1.00 \mathrm{ms}\left({\color{lightgreen}-5.284 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id;zero_depth	1 entities	$$6.79 \mathrm{ms} \pm 65.0 \mathrm{μs}\left({\color{lightgreen}-9.247 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id;zero_depth	10 entities	$$7.04 \mathrm{ms} \pm 73.2 \mathrm{μs}\left({\color{gray}-4.521 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id;zero_depth	25 entities	$$7.23 \mathrm{ms} \pm 56.3 \mathrm{μs}\left({\color{gray}-4.580 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id;zero_depth	5 entities	$$6.99 \mathrm{ms} \pm 82.3 \mathrm{μs}\left({\color{lightgreen}-7.500 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id;zero_depth	50 entities	$$7.09 \mathrm{ms} \pm 70.7 \mathrm{μs}\left({\color{gray}-2.571 \mathrm{\%}}\right) $$	Flame Graph

read_scaling_linkless

Function	Value	Mean	Flame graphs
entity_by_id	1 entities	$$7.04 \mathrm{ms} \pm 48.3 \mathrm{μs}\left({\color{gray}0.577 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id	10 entities	$$7.09 \mathrm{ms} \pm 47.9 \mathrm{μs}\left({\color{gray}-2.783 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id	100 entities	$$6.79 \mathrm{ms} \pm 62.9 \mathrm{μs}\left({\color{lightgreen}-5.957 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id	1000 entities	$$7.15 \mathrm{ms} \pm 68.6 \mathrm{μs}\left({\color{gray}-0.827 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id	10000 entities	$$7.38 \mathrm{ms} \pm 77.8 \mathrm{μs}\left({\color{lightgreen}-6.284 \mathrm{\%}}\right) $$	Flame Graph

representative_read_entity

Function	Value	Mean	Flame graphs
entity_by_id	entity type ID: https://blockprotocol.org/@alice/types/entity-type/block/v/1	$$7.16 \mathrm{ms} \pm 69.2 \mathrm{μs}\left({\color{gray}-4.859 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id	entity type ID: https://blockprotocol.org/@alice/types/entity-type/book/v/1	$$6.81 \mathrm{ms} \pm 52.3 \mathrm{μs}\left({\color{lightgreen}-12.594 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id	entity type ID: https://blockprotocol.org/@alice/types/entity-type/building/v/1	$$7.52 \mathrm{ms} \pm 75.6 \mathrm{μs}\left({\color{gray}0.793 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id	entity type ID: https://blockprotocol.org/@alice/types/entity-type/organization/v/1	$$7.22 \mathrm{ms} \pm 41.1 \mathrm{μs}\left({\color{lightgreen}-6.945 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id	entity type ID: https://blockprotocol.org/@alice/types/entity-type/page/v/2	$$7.28 \mathrm{ms} \pm 46.7 \mathrm{μs}\left({\color{gray}-0.911 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id	entity type ID: https://blockprotocol.org/@alice/types/entity-type/person/v/1	$$6.96 \mathrm{ms} \pm 49.5 \mathrm{μs}\left({\color{gray}-4.715 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id	entity type ID: https://blockprotocol.org/@alice/types/entity-type/playlist/v/1	$$7.38 \mathrm{ms} \pm 60.8 \mathrm{μs}\left({\color{gray}-2.870 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id	entity type ID: https://blockprotocol.org/@alice/types/entity-type/song/v/1	$$7.34 \mathrm{ms} \pm 81.8 \mathrm{μs}\left({\color{gray}-2.925 \mathrm{\%}}\right) $$	Flame Graph
entity_by_id	entity type ID: https://blockprotocol.org/@alice/types/entity-type/uk-address/v/1	$$7.15 \mathrm{ms} \pm 66.5 \mathrm{μs}\left({\color{gray}0.714 \mathrm{\%}}\right) $$	Flame Graph

representative_read_entity_type

Function	Value	Mean	Flame graphs
get_entity_type_by_id	Account ID: bf5a9ef5-dc3b-43cf-a291-6210c0321eba	$$5.23 \mathrm{ms} \pm 70.5 \mathrm{μs}\left({\color{gray}-0.397 \mathrm{\%}}\right) $$	Flame Graph

representative_read_multiple_entities

Function	Value	Mean	Flame graphs
entity_by_property	traversal_paths=0	0	$$38.6 \mathrm{ms} \pm 376 \mathrm{μs}\left({\color{gray}-3.089 \mathrm{\%}}\right) $$
entity_by_property	traversal_paths=255	1,resolve_depths=inherit:1;values:255;properties:255;links:127;link_dests:126;type:true	$$71.9 \mathrm{ms} \pm 434 \mathrm{μs}\left({\color{gray}-0.809 \mathrm{\%}}\right) $$
entity_by_property	traversal_paths=2	1,resolve_depths=inherit:0;values:0;properties:0;links:0;link_dests:0;type:false	$$43.7 \mathrm{ms} \pm 282 \mathrm{μs}\left({\color{gray}0.105 \mathrm{\%}}\right) $$
entity_by_property	traversal_paths=2	1,resolve_depths=inherit:0;values:0;properties:0;links:1;link_dests:0;type:true	$$50.0 \mathrm{ms} \pm 442 \mathrm{μs}\left({\color{gray}1.73 \mathrm{\%}}\right) $$
entity_by_property	traversal_paths=2	1,resolve_depths=inherit:0;values:0;properties:2;links:1;link_dests:0;type:true	$$56.6 \mathrm{ms} \pm 648 \mathrm{μs}\left({\color{gray}-0.169 \mathrm{\%}}\right) $$
entity_by_property	traversal_paths=2	1,resolve_depths=inherit:0;values:2;properties:2;links:1;link_dests:0;type:true	$$58.9 \mathrm{ms} \pm 377 \mathrm{μs}\left({\color{gray}-1.436 \mathrm{\%}}\right) $$
link_by_source_by_property	traversal_paths=0	0	$$29.6 \mathrm{ms} \pm 284 \mathrm{μs}\left({\color{gray}0.605 \mathrm{\%}}\right) $$
link_by_source_by_property	traversal_paths=255	1,resolve_depths=inherit:1;values:255;properties:255;links:127;link_dests:126;type:true	$$46.4 \mathrm{ms} \pm 351 \mathrm{μs}\left({\color{gray}-3.979 \mathrm{\%}}\right) $$
link_by_source_by_property	traversal_paths=2	1,resolve_depths=inherit:0;values:0;properties:0;links:0;link_dests:0;type:false	$$34.9 \mathrm{ms} \pm 298 \mathrm{μs}\left({\color{gray}2.76 \mathrm{\%}}\right) $$
link_by_source_by_property	traversal_paths=2	1,resolve_depths=inherit:0;values:0;properties:0;links:1;link_dests:0;type:true	$$41.2 \mathrm{ms} \pm 477 \mathrm{μs}\left({\color{gray}-2.091 \mathrm{\%}}\right) $$
link_by_source_by_property	traversal_paths=2	1,resolve_depths=inherit:0;values:0;properties:2;links:1;link_dests:0;type:true	$$39.5 \mathrm{ms} \pm 253 \mathrm{μs}\left({\color{lightgreen}-11.385 \mathrm{\%}}\right) $$
link_by_source_by_property	traversal_paths=2	1,resolve_depths=inherit:0;values:2;properties:2;links:1;link_dests:0;type:true	$$39.8 \mathrm{ms} \pm 404 \mathrm{μs}\left({\color{lightgreen}-9.771 \mathrm{\%}}\right) $$

scenarios

Function	Value	Mean	Flame graphs
full_test	query-limited	$$75.9 \mathrm{ms} \pm 423 \mathrm{μs}\left({\color{red}8.31 \mathrm{\%}}\right) $$	Flame Graph
full_test	query-unlimited	$$80.9 \mathrm{ms} \pm 467 \mathrm{μs}\left({\color{red}6.08 \mathrm{\%}}\right) $$	Flame Graph
linked_queries	query-limited	$$15.6 \mathrm{ms} \pm 154 \mathrm{μs}\left({\color{gray}4.26 \mathrm{\%}}\right) $$	Flame Graph
linked_queries	query-unlimited	$$306 \mathrm{ms} \pm 951 \mathrm{μs}\left({\color{lightgreen}-5.955 \mathrm{\%}}\right) $$	Flame Graph