Skip to content

refactor(storage): migrate TinyFlows stores to TinyStorageDrivers v2 - #171

Merged
senamakel merged 18 commits into
mainfrom
tsd-v2-canonical
Oct 22, 2026
Merged

senamakel merged 18 commits into
mainfrom
tsd-v2-canonical

Conversation

@senamakel

@senamakel senamakel commented Oct 22, 2026 •

Copy link
Copy Markdown
Member

What changed

  • Move TinyFlows persistence to host-provided TinyStorageDrivers v2 ports, with owner-local schemas and migrations for workflow, catalog, schedule, and adaptive records.
  • Add TinyFlows-owned shared storage helpers, remove the legacy SQLite/filesystem importer, and preserve old schedule/catalog data through owner migrations.
  • Pin the canonical TinyStorageDrivers v2.1.0 source at 05eaada962decbab33bafa4763d2bd1a67f6b456. Keep Cargo's TinyBus source at 0de2d283f35cbbff08efad6fbe05537ffb74611b, which matches TSD 2.1.0's TinyBus source and keeps its bus types unified. Update the vendored TinyBus release-tooling gitlink to current main 2b2ac165505bdf3dc19c26e0b93c54fb4257bd3c (feat: host extractions (cron store, dedup settle, authoring report, agent prompt helpers, summary, referenced compat) #100).
  • Keep the workspace compatible with its declared Rust 1.88 MSRV and collapse two existing Clippy findings in the dedup settle helper.
  • Split migration execution, lease acquisition, checkpoint lineage tests, and JSON extraction into focused modules under the repository's 500-line source and test limits.
  • Preserve an imported cron job's body created_ms when editing the job, so existing run identity remains stable.

Validation

  • cargo +1.88.0 check --workspace --all-features --locked — passed with TSD's TinyBus source pin.
  • cargo clippy --workspace --all-targets --all-features --locked -- -D warnings — passed.
  • cargo +1.88.0 fmt --all -- --check and git diff --check — passed.
  • cargo test -p tinyflows-storage --all-features --locked — passed (18 unit tests and 3 doctests).
  • cargo test -p tinyflows-drivers --all-features --locked -- --test-threads=1 — passed (418 tests). The added imported-job identity regression test failed before the fix and passes after it.
  • cargo test -p tinyflows --all-features --locked nodes::integration::agent_prompt — passed (47 tests).
  • cargo test -p tinyflows-module --all-features --locked -- --test-threads=1 — passed (136 unit tests and 5 release workflow tests).
  • cargo build --manifest-path vendor/tinybus/Cargo.toml -p tinybus --all-features --bin tinybus --locked — passed at the updated vendored TinyBus gitlink.
  • scripts/verify-module-artifact.sh with the built module copied to a private artifact directory — 35/35 passed. The shared build directory is group-writable, so the module loader correctly refuses to load from it directly.
  • The full parallel cargo test --workspace --all-features --locked run had two actor-recovery test failures. Both passed individually; a serialized rerun of the actor-recovery tests also passed (3/3). The full tinyflows-module suite passed with test threads set to one.

Release note

Canonical TinyStorageDrivers main contains v2.1.0 at the pinned revision, but the canonical repository has not published a v2 release/tag yet. This PR pins the exact canonical commit; a tagged v2 release is still needed for consumers that require release pins.

Closes senamakel#39
Part of tinyhumansai/openhuman#8131

senamakel and others added 8 commits October 22, 2026 14:12
Move the key, schema, blocking, and primitive (kv, counters, leases, repo)
helpers out of tinyflows-drivers into a new tinyflows-storage crate so the
storage ports can be shared without linking engine crates. The retired
tinyflows-import crate is folded into tinyflows-module, and CI now checks
the workspace at its MSRV and enforces that storage port users stay
engine-free.

Auto-committed-on: cuttlefish
Co-authored-by: Medulla <medulla@tinyhumans.ai>
Repoint the tinystoragedrivers dependencies at the tinyhumansai fork and
upgrade them from the v2.0.1 tag to 2.1.0, pinned by revision. The
previous senamakel source is no longer the canonical one.

Auto-committed-on: cuttlefish
Co-authored-by: Medulla <medulla@tinyhumans.ai>
Bump the tinystoragedrivers crates from 2.0.1 to 2.1.0 and move them to the tinyhumansai fork, and update tinybus to 0.1.6. The lockfile also picks up the new transitive dependencies these versions require, including nix, zstd, and updated getrandom and sha2 releases.

Auto-committed-on: cuttlefish
Co-authored-by: Medulla <medulla@tinyhumans.ai>
Reverted the lockfile to the previously pinned versions, lowering syn, aws-lc-rs, cc, hyper, libc and others and dropping the futures-macro and nix entries. This restores the dependency set that was in place before the last update.

Auto-committed-on: cuttlefish
Co-authored-by: Medulla <medulla@tinyhumans.ai>
Regenerate Cargo.lock after replacing the tinystoragedrivers-core dependency with the split tinystoragedrivers-api, types, testkit and busproxy crates, and after dropping the tinyflows-import crate. The lockfile also picks up new tinybus revisions and the futures-macro, nix and zip 9.0.5 packages they pull in.

Auto-committed-on: cuttlefish
Co-authored-by: Medulla <medulla@tinyhumans.ai>
The comment above the tinystoragedrivers-api dependency described the pin as a git tag, but the dependency is pinned by revision. Updated the wording so the comment matches how the crate is actually vendored and patched.

Auto-committed-on: cuttlefish
Co-authored-by: Medulla <medulla@tinyhumans.ai>
Update the workspace patch entries and the storage dev-dependency to
point at the same tinybus revision, so the unpublished module APIs come
from one consistent commit.

Auto-committed-on: cuttlefish
Co-authored-by: Medulla <medulla@tinyhumans.ai>
Consolidates the tinybus dependency on the 0.1.6 revision, removing the
duplicate 0.1.5 git checkouts that were still pinned in the lockfile. The
now-unused zip 2.4.2, arbitrary, derive_arbitrary, crossbeam-utils and
zopfli entries fall away as a result.

Auto-committed-on: cuttlefish
Co-authored-by: Medulla <medulla@tinyhumans.ai>
@chatgpt-codex-connector

chatgpt-codex-connector Bot commented Oct 22, 2026 •

Copy link
Copy Markdown

Codex Review Summary

This comment shows the latest Codex review activity on this pull request.

Review Status Commit Review trigger
📝 Code Review ✅ Completed 2026-10-22T15:16:50.984472Z 888858a New commits
ℹ️ About Codex in GitHub

Your team has set up Codex to review pull requests in this repo. Reviews are triggered when you

  • Open a pull request for review
  • Mark a draft as ready
  • Comment "@codex review" or "@codex security review".

Codex reacts with 👀 while any review is running, comments if it has suggestions, and reacts with 👍 once all reviews finish with no findings.

@coderabbitai

coderabbitai Bot commented Oct 22, 2026 •

Copy link
Copy Markdown

Warning

Review limit reached

  • Run on-demand review

This review includes 241 billable files and costs up to $60.25.

View limit details

Learn how review limits work.

Review configuration:

⚙️ Run configuration
  • Source mode: Auto
  • Repository: Unavailable
  • Branch: Unavailable
  • File: No configuration file from this repository applied
  • Commit: Unavailable
  • Layers: Organization UI
  • Review profile: CHILL
  • Plan: Advanced
  • Run ID: e35946d0-d6c2-4674-874d-e55054e83960
📥 Commits

Reviewing files that changed from the base of the PR and between 9b5c028 and 104f6da.

⛔ Files ignored due to path filters: 4
  • Cargo.lock is excluded by !**/*.lock
  • crates/tinyflows-import/tests/fixtures/catalog/flows.db is excluded by !**/*.db
  • crates/tinyflows-import/tests/fixtures/checkpoints/checkpoints.db is excluded by !**/*.db
  • crates/tinyflows-import/tests/fixtures/cron/jobs.db is excluded by !**/*.db
📒 Files selected for processing: 241
  • .github/workflows/ci.yml
  • CLAUDE.md
  • Cargo.toml
  • crates/tinyflows-adaptive/Cargo.toml
  • crates/tinyflows-adaptive/README.md
  • crates/tinyflows-adaptive/docs/api.md
  • crates/tinyflows-adaptive/src/drivers/ledger/mod.rs
  • crates/tinyflows-adaptive/src/drivers/ledger/trait_impl.rs
  • crates/tinyflows-adaptive/src/drivers/ledger_tests.rs
  • crates/tinyflows-adaptive/src/drivers/migrate.rs
  • crates/tinyflows-adaptive/src/drivers/migrate_tests.rs
  • crates/tinyflows-adaptive/src/drivers/mod.rs
  • crates/tinyflows-adaptive/src/drivers/vault.rs
  • crates/tinyflows-adaptive/src/drivers/vault_tests.rs
  • crates/tinyflows-adaptive/src/storage.rs
  • crates/tinyflows-adaptive/src/storage_tests.rs
  • crates/tinyflows-adaptive/tests/driver/driver_part_01_tests.rs
  • crates/tinyflows-adaptive/tests/support/driver_store.rs
  • crates/tinyflows-bus/src/schedule/mod.rs
  • crates/tinyflows-catalog/src/build_registry.rs
  • crates/tinyflows-catalog/src/import/n8n/expr.rs
  • crates/tinyflows-catalog/src/import/n8n/node_mapping.rs
  • crates/tinyflows-copilot/src/tools/draft_edit.rs
  • crates/tinyflows-drivers/Cargo.toml
  • crates/tinyflows-drivers/README.md
  • crates/tinyflows-drivers/src/catalog/definitions.rs
  • crates/tinyflows-drivers/src/catalog/definitions_tests.rs
  • crates/tinyflows-drivers/src/catalog/drafts.rs
  • crates/tinyflows-drivers/src/catalog/drafts_tests.rs
  • crates/tinyflows-drivers/src/catalog/import.rs
  • crates/tinyflows-drivers/src/catalog/kv.rs
  • crates/tinyflows-drivers/src/catalog/kv_tests.rs
  • crates/tinyflows-drivers/src/catalog/lineage.rs
  • crates/tinyflows-drivers/src/catalog/lineage_tests.rs
  • crates/tinyflows-drivers/src/catalog/migrate.rs
  • crates/tinyflows-drivers/src/catalog/migrate_tests.rs
  • crates/tinyflows-drivers/src/catalog/mod.rs
  • crates/tinyflows-drivers/src/catalog/revisions.rs
  • crates/tinyflows-drivers/src/catalog/revisions_gap_tests.rs
  • crates/tinyflows-drivers/src/catalog/runs.rs
  • crates/tinyflows-drivers/src/catalog/runs_lifecycle_tests.rs
  • crates/tinyflows-drivers/src/catalog/runs_recovery.rs
  • crates/tinyflows-drivers/src/catalog/runs_recovery_lease_tests.rs
  • crates/tinyflows-drivers/src/catalog/runs_replace_tests.rs
  • crates/tinyflows-drivers/src/catalog/state.rs
  • crates/tinyflows-drivers/src/catalog/state_tests.rs
  • crates/tinyflows-drivers/src/catalog/suggestions.rs
  • crates/tinyflows-drivers/src/catalog/test_support.rs
  • crates/tinyflows-drivers/src/checkpoint.rs
  • crates/tinyflows-drivers/src/checkpoint_import_tests.rs
  • crates/tinyflows-drivers/src/checkpoint_layout.rs
  • crates/tinyflows-drivers/src/checkpoint_layout_tests.rs
  • crates/tinyflows-drivers/src/checkpoint_lineage_tests.rs
  • crates/tinyflows-drivers/src/checkpoint_tests.rs
  • crates/tinyflows-drivers/src/ids.rs
  • crates/tinyflows-drivers/src/lib.rs
  • crates/tinyflows-drivers/src/schedule/admission.rs
  • crates/tinyflows-drivers/src/schedule/admission_tests.rs
  • crates/tinyflows-drivers/src/schedule/claim_removal_tests.rs
  • crates/tinyflows-drivers/src/schedule/claims.rs
  • crates/tinyflows-drivers/src/schedule/claims/acquisition.rs
  • crates/tinyflows-drivers/src/schedule/claims/completion.rs
  • crates/tinyflows-drivers/src/schedule/claims_compaction_tests.rs
  • crates/tinyflows-drivers/src/schedule/claims_safety_tests.rs
  • crates/tinyflows-drivers/src/schedule/claims_tests.rs
  • crates/tinyflows-drivers/src/schedule/codec.rs
  • crates/tinyflows-drivers/src/schedule/codec_tests.rs
  • crates/tinyflows-drivers/src/schedule/import.rs
  • crates/tinyflows-drivers/src/schedule/import_tests.rs
  • crates/tinyflows-drivers/src/schedule/jobs.rs
  • crates/tinyflows-drivers/src/schedule/manual_claim_fence_tests.rs
  • crates/tinyflows-drivers/src/schedule/manual_claim_tests.rs
  • crates/tinyflows-drivers/src/schedule/migrate.rs
  • crates/tinyflows-drivers/src/schedule/migrate_tests.rs
  • crates/tinyflows-drivers/src/schedule/migrated_job_identity_tests.rs
  • crates/tinyflows-drivers/src/schedule/mod.rs
  • crates/tinyflows-drivers/src/schedule/mod_tests.rs
  • crates/tinyflows-drivers/src/schedule/policy.rs
  • crates/tinyflows-drivers/src/schedule/removal.rs
  • crates/tinyflows-drivers/src/schedule/removal_claims_tests.rs
  • crates/tinyflows-drivers/src/schedule/runs.rs
  • crates/tinyflows-drivers/src/schedule/runs_sweep_tests.rs
  • crates/tinyflows-drivers/src/schedule/runs_tests.rs
  • crates/tinyflows-drivers/src/schedule/runtime.rs
  • crates/tinyflows-drivers/src/schedule/test_support.rs
  • crates/tinyflows-drivers/src/state_store.rs
  • crates/tinyflows-drivers/src/state_store_tests.rs
  • crates/tinyflows-drivers/src/storage/kv_import.rs
  • crates/tinyflows-drivers/src/storage/kv_import_tests.rs
  • crates/tinyflows-drivers/src/storage/mod.rs
  • crates/tinyflows-drivers/src/store/authoring_tests.rs
  • crates/tinyflows-drivers/src/store/concurrency_tests.rs
  • crates/tinyflows-drivers/src/store/definitions.rs
  • crates/tinyflows-drivers/src/store/history.rs
  • crates/tinyflows-drivers/src/store/history_tests.rs
  • crates/tinyflows-drivers/src/store/import.rs
  • crates/tinyflows-drivers/src/store/import_tests.rs
  • crates/tinyflows-drivers/src/store/locks.rs
  • crates/tinyflows-drivers/src/store/locks_tests.rs
  • crates/tinyflows-drivers/src/store/migrate.rs
  • crates/tinyflows-drivers/src/store/migrate_tests.rs
  • crates/tinyflows-drivers/src/store/mod.rs
  • crates/tinyflows-drivers/src/store/mod_tests.rs
  • crates/tinyflows-drivers/src/store/notes.rs
  • crates/tinyflows-drivers/src/store/notes_tests.rs
  • crates/tinyflows-drivers/src/store/proposals.rs
  • crates/tinyflows-drivers/src/store/proposals_tests.rs
  • crates/tinyflows-drivers/src/store/runs.rs
  • crates/tinyflows-drivers/src/store/runs_tests.rs
  • crates/tinyflows-drivers/src/store/test_support.rs
  • crates/tinyflows-import/Cargo.toml
  • crates/tinyflows-import/src/catalog.rs
  • crates/tinyflows-import/src/catalog_tests.rs
  • crates/tinyflows-import/src/checkpoint_reader.rs
  • crates/tinyflows-import/src/checkpoint_reader_tests.rs
  • crates/tinyflows-import/src/checkpoints.rs
  • crates/tinyflows-import/src/checkpoints_tests.rs
  • crates/tinyflows-import/src/cron.rs
  • crates/tinyflows-import/src/cron_tests.rs
  • crates/tinyflows-import/src/flow_reader.rs
  • crates/tinyflows-import/src/flow_reader_tests.rs
  • crates/tinyflows-import/src/legacy_batch_tests.rs
  • crates/tinyflows-import/src/legacy_cron.rs
  • crates/tinyflows-import/src/legacy_db.rs
  • crates/tinyflows-import/src/legacy_db_tests.rs
  • crates/tinyflows-import/src/lib.rs
  • crates/tinyflows-import/src/report.rs
  • crates/tinyflows-import/src/report_tests.rs
  • crates/tinyflows-import/src/state.rs
  • crates/tinyflows-import/src/state_tests.rs
  • crates/tinyflows-import/src/test_support.rs
  • crates/tinyflows-import/src/workflow_store.rs
  • crates/tinyflows-import/src/workflow_store_tests.rs
  • crates/tinyflows-import/tests/catalog_feature_contract_tests.rs
  • crates/tinyflows-import/tests/fixtures/README.md
  • crates/tinyflows-import/tests/fixtures/catalog/drafts/draft-1.json
  • crates/tinyflows-import/tests/fixtures/catalog/drafts/draft-2.json
  • crates/tinyflows-import/tests/fixtures/checkpoints/file/%52un%20%54wo%2F%55pper.jsonl
  • crates/tinyflows-import/tests/fixtures/checkpoints/file/run-1.jsonl
  • crates/tinyflows-import/tests/fixtures/checkpoints/file/run-1.writes.jsonl
  • crates/tinyflows-import/tests/fixtures/expected.json
  • crates/tinyflows-import/tests/fixtures/file-state/23f934e93be1ce4552c02f0afd23f913129e848ae8b554dc159dae21eb02b10e/46a4eebd20d881ecfc0ecb54f6d8346524fadb143726d256b1a045303fc67717.json
  • crates/tinyflows-import/tests/fixtures/file-state/23f934e93be1ce4552c02f0afd23f913129e848ae8b554dc159dae21eb02b10e/704c85b17a4304aa541a0fbb7a5eca7c7f0a67801f7693eb2b8ccba347c58f11.json
  • crates/tinyflows-import/tests/fixtures/workflow-store/state/definitions/3854983f88763a4631f806cfdedde1b4d5dff5f5194b6fdd75998417f9f4d845/revisions/retired/1791849384244-000000000002-d32c0dd55d3aa699292153bc11572798.json
  • crates/tinyflows-import/tests/fixtures/workflow-store/state/definitions/3854983f88763a4631f806cfdedde1b4d5dff5f5194b6fdd75998417f9f4d845/revisions/sweep/1791849384244-000000000000-e8ec8f20403e6ee93f6db7acc1a07b98.json
  • crates/tinyflows-import/tests/fixtures/workflow-store/state/definitions/3854983f88763a4631f806cfdedde1b4d5dff5f5194b6fdd75998417f9f4d845/revisions/sweep/1791849384244-000000000001-cf5377d354cea8a5b39a7e89513802ec.json
  • crates/tinyflows-import/tests/fixtures/workflow-store/state/journal/sweep.json
  • crates/tinyflows-import/tests/fixtures/workflow-store/state/proposals/0000000000005-000000000000-83da8a7edd825c2bce8cd7392068472f.json
  • crates/tinyflows-import/tests/fixtures/workflow-store/state/runs/run-a.json
  • crates/tinyflows-import/tests/fixtures/workflow-store/state/runs/run-b.json
  • crates/tinyflows-import/tests/fixtures/workflow-store/state/runs/run-c.json
  • crates/tinyflows-import/tests/fixtures/workflow-store/workflows/deploy.json
  • crates/tinyflows-import/tests/fixtures/workflow-store/workflows/sweep.json
  • crates/tinyflows-module/Cargo.toml
  • crates/tinyflows-module/README.md
  • crates/tinyflows-module/src/caps.rs
  • crates/tinyflows-module/src/caps_tests/scope_tests.rs
  • crates/tinyflows-module/src/catalog_documents.rs
  • crates/tinyflows-module/src/catalog_documents_tests.rs
  • crates/tinyflows-module/src/catalog_extended_operations_tests.rs
  • crates/tinyflows-module/src/catalog_extended_ops.rs
  • crates/tinyflows-module/src/catalog_legacy_batch.rs
  • crates/tinyflows-module/src/catalog_legacy_checkpoint.rs
  • crates/tinyflows-module/src/catalog_legacy_import.rs
  • crates/tinyflows-module/src/catalog_migrations.rs
  • crates/tinyflows-module/src/catalog_service.rs
  • crates/tinyflows-module/src/catalog_service_migration_tests.rs
  • crates/tinyflows-module/src/catalog_service_tests.rs
  • crates/tinyflows-module/src/lib.rs
  • crates/tinyflows-module/src/run_manager/cancellation.rs
  • crates/tinyflows-module/src/run_manager/dedup_settlement_tests.rs
  • crates/tinyflows-module/src/run_manager/events_persistence_test_support.rs
  • crates/tinyflows-module/src/run_manager/preparation.rs
  • crates/tinyflows-module/src/run_manager/resume.rs
  • crates/tinyflows-module/src/run_manager/sweeps.rs
  • crates/tinyflows-module/src/run_manager_actor_recovery_tests.rs
  • crates/tinyflows-module/src/run_manager_tests.rs
  • crates/tinyflows-module/src/schedule_clock_tests.rs
  • crates/tinyflows-module/src/schedule_documents.rs
  • crates/tinyflows-module/src/schedule_documents_tests.rs
  • crates/tinyflows-module/src/schedule_manual_worker_lifecycle_service_tests.rs
  • crates/tinyflows-module/src/schedule_manual_worker_service_tests.rs
  • crates/tinyflows-module/src/schedule_members_tests.rs
  • crates/tinyflows-module/src/schedule_service_tests.rs
  • crates/tinyflows-module/src/schedule_store.rs
  • crates/tinyflows-module/src/schedule_store_tests.rs
  • crates/tinyflows-module/tests/fixtures/storage/README.md
  • crates/tinyflows-module/tests/fixtures/storage/cron-job-v0.8.28.json
  • crates/tinyflows-module/tests/fixtures/storage/cron-job-v0.8.8.json
  • crates/tinyflows-module/tests/fixtures/storage/generators/generate_v0.8.28.rs
  • crates/tinyflows-module/tests/fixtures/storage/generators/generate_v0.8.8.rs
  • crates/tinyflows-module/tests/module_artifact_tests.rs
  • crates/tinyflows-module/tests/run_artifact/document_callback.rs
  • crates/tinyflows-module/tests/run_artifact/support.rs
  • crates/tinyflows-module/tests/support/catalog_legacy_import_artifact_tests.rs
  • crates/tinyflows-module/tests/support/document_callbacks.rs
  • crates/tinyflows-module/tests/support/manual_worker_artifact_tests.rs
  • crates/tinyflows-module/tests/support/schedule_v4_artifact.rs
  • crates/tinyflows-module/tests/support/schedule_v4_delivery_artifact.rs
  • crates/tinyflows-module/tests/support/schedule_v4_manual_artifact.rs
  • crates/tinyflows-module/tests/support/schedule_v4_recovery_artifact.rs
  • crates/tinyflows-module/tests/support/scheduler_stop_artifact_tests.rs
  • crates/tinyflows-module/tests/support/storage_migration_artifact_tests.rs
  • crates/tinyflows-schedule/src/posix_weekday.rs
  • crates/tinyflows-schedule/src/validation.rs
  • crates/tinyflows-storage/Cargo.toml
  • crates/tinyflows-storage/src/blocking.rs
  • crates/tinyflows-storage/src/blocking_tests.rs
  • crates/tinyflows-storage/src/key.rs
  • crates/tinyflows-storage/src/key_tests.rs
  • crates/tinyflows-storage/src/lib.rs
  • crates/tinyflows-storage/src/primitives/counters.rs
  • crates/tinyflows-storage/src/primitives/counters_tests.rs
  • crates/tinyflows-storage/src/primitives/kv.rs
  • crates/tinyflows-storage/src/primitives/kv_tests.rs
  • crates/tinyflows-storage/src/primitives/leases.rs
  • crates/tinyflows-storage/src/primitives/leases/acquire_with.rs
  • crates/tinyflows-storage/src/primitives/leases_tests.rs
  • crates/tinyflows-storage/src/primitives/mod.rs
  • crates/tinyflows-storage/src/primitives/repo.rs
  • crates/tinyflows-storage/src/primitives/repo_tests.rs
  • crates/tinyflows-storage/src/schema.rs
  • crates/tinyflows-storage/src/schema/migrations.rs
  • crates/tinyflows-storage/src/schema_tests.rs
  • crates/tinyflows/Cargo.toml
  • crates/tinyflows/src/caps/host/script_tests/script_tests_part_01_tests.rs
  • crates/tinyflows/src/migrate.rs
  • crates/tinyflows/src/nodes/control_flow/dedup_settle.rs
  • crates/tinyflows/src/nodes/integration/agent.rs
  • crates/tinyflows/src/nodes/integration/agent_prompt.rs
  • crates/tinyflows/src/nodes/integration/agent_prompt/json_extract.rs
  • crates/tinyflows/src/nodes/integration/approval.rs
  • crates/tinyflows/src/nodes/integration/schema.rs
  • crates/tinyflows/src/preflight_inputs.rs
  • crates/tinyflows/src/validate/node_config.rs
  • crates/tinyflows/tests/interception_e2e_tests.rs
  • docs/storage-crate-split.md
  • docs/tinyflows-bus-design.md
  • scripts/check-legacy-import-modes.sh
  • scripts/check-storage-engine-free.sh
  • vendor/tinybus
  • Autofix · Keep fixing CodeRabbit findings and required CI, and resolving merge conflicts

Comment @coderabbitai help to get the list of available commands.

@chatgpt-codex-connector chatgpt-codex-connector Bot left a comment

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

💡 Codex Review

Here are some automated review suggestions for this pull request.

Reviewed commit: 0d1a349d3a

ℹ️ About Codex in GitHub

Your team has set up Codex to review pull requests in this repo. Reviews are triggered when you

  • Open a pull request for review
  • Mark a draft as ready
  • Comment "@codex review".

If Codex has suggestions, it will comment; otherwise it will react with 👍.

Codex can also answer questions or update the PR. Try commenting "@codex address that feedback".

Comment thread crates/tinyflows-storage/src/schema.rs Outdated
Comment thread crates/tinyflows-storage/src/primitives/leases.rs
@tinysweeper

tinysweeper Bot commented Oct 22, 2026 •

Copy link
Copy Markdown

Tiny Sweeper review

Findings

No active actionable findings.

Notes

Unverified note — critique

  • medium: Keep the engine MSRV at 1.85 as the repository requires (crates/tinyflows/Cargo.toml:5)
    Problem: The repository's own instruction file states, word for word: "Use Rust 2024 edition, MSRV 1.85." This diff raises the `tinyflows` engine package's `rust-version` to 1.88, which bre
    Suggested fix:
    rust-version = "1.85"
    

Unverified note — critique

  • medium: Workspace MSRV bump to 1.88 breaks the documented 1.85 policy (Cargo.toml:27)
    Problem: The repository's own instruction file states, word for word: "Use Rust 2024 edition, MSRV 1.85." This line changes the workspace `rust-version` that every member inherits (`rust-ve
    Suggested fix:
    No concrete fix was supplied.
  • medium: Pin the new toolchain action to a commit SHA (.github/workflows/ci.yml:23)
    Problem: `dtolnay/rust-toolchain@1.88.0` is a mutable tag, not a commit SHA or a released version, so the workflow runs whatever that tag points to when CI starts — a compromised or retagge
    Suggested fix:
    No concrete fix was supplied.

Verdict: Incomplete · Priority: medium
Coverage: Reviewed 59 of 245 files; not reviewed: Cargo.lock, crates/tinyflows…, and 49 additional unreviewed files; not reviewed (large PR): CLAUDE.md, crates/tinyflows…, and 133 additional unreviewed files.

Diagnostics and supporting details

Full summary

Pull request purpose (title): refactor(storage): migrate TinyFlows stores to TinyStorageDrivers v2. Tiny Sweeper completed its review; deterministic results follow.

Unreviewed paths

  • CLAUDE.md
  • Cargo.lock
  • crates/tinyflows-adaptive/README.md
  • crates/tinyflows-adaptive/docs/api.md
  • crates/tinyflows-adaptive/src/drivers/ledger/mod.rs
  • crates/tinyflows-adaptive/src/drivers/ledger_tests.rs
  • crates/tinyflows-adaptive/src/drivers/migrate.rs
  • crates/tinyflows-adaptive/src/drivers/migrate_tests.rs
  • crates/tinyflows-adaptive/src/drivers/mod.rs
  • crates/tinyflows-adaptive/src/drivers/vault_tests.rs
  • crates/tinyflows-adaptive/src/storage.rs
  • crates/tinyflows-adaptive/src/storage_tests.rs
  • crates/tinyflows-adaptive/tests/driver/driver_part_01_tests.rs
  • crates/tinyflows-adaptive/tests/support/driver_store.rs
  • crates/tinyflows-bus/src/schedule/mod.rs
  • crates/tinyflows-catalog/src/build_registry.rs
  • crates/tinyflows-catalog/src/import/n8n/expr.rs
  • crates/tinyflows-catalog/src/import/n8n/node_mapping.rs
  • crates/tinyflows-copilot/src/tools/draft_edit.rs
  • crates/tinyflows-drivers/README.md
  • crates/tinyflows-drivers/src/catalog/definitions_tests.rs
  • crates/tinyflows-drivers/src/catalog/drafts_tests.rs
  • crates/tinyflows-drivers/src/catalog/import.rs
  • crates/tinyflows-drivers/src/catalog/kv_tests.rs
  • crates/tinyflows-drivers/src/catalog/migrate.rs
  • crates/tinyflows-drivers/src/catalog/migrate_tests.rs
  • crates/tinyflows-drivers/src/catalog/mod.rs
  • crates/tinyflows-drivers/src/catalog/revisions_gap_tests.rs
  • crates/tinyflows-drivers/src/catalog/runs_lifecycle_tests.rs
  • crates/tinyflows-drivers/src/catalog/runs_recovery_lease_tests.rs
  • crates/tinyflows-drivers/src/catalog/runs_replace_tests.rs
  • crates/tinyflows-drivers/src/catalog/test_support.rs
  • crates/tinyflows-drivers/src/checkpoint.rs
  • crates/tinyflows-drivers/src/checkpoint_import_tests.rs
  • crates/tinyflows-drivers/src/checkpoint_layout_tests.rs
  • crates/tinyflows-drivers/src/checkpoint_lineage_tests.rs
  • crates/tinyflows-drivers/src/checkpoint_tests.rs
  • crates/tinyflows-drivers/src/lib.rs
  • crates/tinyflows-drivers/src/schedule/admission.rs
  • crates/tinyflows-drivers/src/schedule/admission_tests.rs
  • crates/tinyflows-drivers/src/schedule/claim_removal_tests.rs
  • crates/tinyflows-drivers/src/schedule/claims_compaction_tests.rs
  • crates/tinyflows-drivers/src/schedule/claims_safety_tests.rs
  • crates/tinyflows-drivers/src/schedule/claims_tests.rs
  • crates/tinyflows-drivers/src/schedule/codec.rs
  • crates/tinyflows-drivers/src/schedule/import.rs
  • crates/tinyflows-drivers/src/schedule/import_tests.rs
  • crates/tinyflows-drivers/src/schedule/jobs.rs
  • crates/tinyflows-drivers/src/schedule/manual_claim_fence_tests.rs
  • crates/tinyflows-drivers/src/schedule/manual_claim_tests.rs
  • crates/tinyflows-drivers/src/schedule/migrate.rs
  • crates/tinyflows-drivers/src/schedule/migrate_tests.rs
  • crates/tinyflows-drivers/src/schedule/migrated_job_identity_tests.rs
  • crates/tinyflows-drivers/src/schedule/mod.rs
  • crates/tinyflows-drivers/src/schedule/mod_tests.rs
  • crates/tinyflows-drivers/src/schedule/removal_claims_tests.rs
  • crates/tinyflows-drivers/src/schedule/runs.rs
  • crates/tinyflows-drivers/src/schedule/runs_tests.rs
  • crates/tinyflows-drivers/src/schedule/test_support.rs
  • crates/tinyflows-drivers/src/state_store_tests.rs
  • crates/tinyflows-drivers/src/storage/kv_import.rs
  • crates/tinyflows-drivers/src/storage/kv_import_tests.rs
  • crates/tinyflows-drivers/src/storage/mod.rs
  • crates/tinyflows-drivers/src/store/concurrency_tests.rs
  • crates/tinyflows-drivers/src/store/history_tests.rs
  • crates/tinyflows-drivers/src/store/import.rs
  • crates/tinyflows-drivers/src/store/import_tests.rs
  • crates/tinyflows-drivers/src/store/locks_tests.rs
  • crates/tinyflows-drivers/src/store/migrate.rs
  • crates/tinyflows-drivers/src/store/migrate_tests.rs
  • crates/tinyflows-drivers/src/store/mod_tests.rs
  • crates/tinyflows-drivers/src/store/notes_tests.rs
  • crates/tinyflows-drivers/src/store/proposals_tests.rs
  • crates/tinyflows-drivers/src/store/runs_tests.rs
  • crates/tinyflows-drivers/src/store/test_support.rs
  • crates/tinyflows-import/Cargo.toml
  • crates/tinyflows-import/src/catalog.rs
  • crates/tinyflows-import/src/catalog_tests.rs
  • crates/tinyflows-import/src/checkpoint_reader.rs
  • crates/tinyflows-import/src/checkpoint_reader_tests.rs
  • crates/tinyflows-import/src/checkpoints.rs
  • crates/tinyflows-import/src/checkpoints_tests.rs
  • crates/tinyflows-import/src/cron.rs
  • crates/tinyflows-import/src/cron_tests.rs
  • crates/tinyflows-import/src/flow_reader.rs
  • crates/tinyflows-import/src/flow_reader_tests.rs
  • crates/tinyflows-import/src/legacy_batch_tests.rs
  • crates/tinyflows-import/src/legacy_cron.rs
  • crates/tinyflows-import/src/legacy_db.rs
  • crates/tinyflows-import/src/legacy_db_tests.rs
  • crates/tinyflows-import/src/lib.rs
  • crates/tinyflows-import/src/report.rs
  • crates/tinyflows-import/src/report_tests.rs
  • crates/tinyflows-import/src/state.rs
  • crates/tinyflows-import/src/state_tests.rs
  • crates/tinyflows-import/src/test_support.rs
  • crates/tinyflows-import/src/workflow_store.rs
  • crates/tinyflows-import/src/workflow_store_tests.rs
  • crates/tinyflows-import/tests/catalog_feature_contract_tests.rs
  • crates/tinyflows-import/tests/fixtures/README.md
  • crates/tinyflows-import/tests/fixtures/catalog/drafts/draft-1.json
  • crates/tinyflows-import/tests/fixtures/catalog/drafts/draft-2.json
  • crates/tinyflows-import/tests/fixtures/catalog/flows.db
  • crates/tinyflows-import/tests/fixtures/checkpoints/checkpoints.db
  • crates/tinyflows-import/tests/fixtures/checkpoints/file/%52un%20%54wo%2F%55pper.jsonl
  • crates/tinyflows-import/tests/fixtures/checkpoints/file/run-1.jsonl
  • crates/tinyflows-import/tests/fixtures/checkpoints/file/run-1.writes.jsonl
  • crates/tinyflows-import/tests/fixtures/cron/jobs.db
  • crates/tinyflows-import/tests/fixtures/expected.json
  • crates/tinyflows-import/tests/fixtures/file-state/23f934e93be1ce4552c02f0afd23f913129e848ae8b554dc159dae21eb02b10e/46a4eebd20d881ecfc0ecb54f6d8346524fadb143726d256b1a045303fc67717.json
  • crates/tinyflows-import/tests/fixtures/file-state/23f934e93be1ce4552c02f0afd23f913129e848ae8b554dc159dae21eb02b10e/704c85b17a4304aa541a0fbb7a5eca7c7f0a67801f7693eb2b8ccba347c58f11.json
  • crates/tinyflows-import/tests/fixtures/workflow-store/state/definitions/3854983f88763a4631f806cfdedde1b4d5dff5f5194b6fdd75998417f9f4d845/revisions/retired/1791849384244-000000000002-d32c0dd55d3aa699292153bc11572798.json
  • crates/tinyflows-import/tests/fixtures/workflow-store/state/definitions/3854983f88763a4631f806cfdedde1b4d5dff5f5194b6fdd75998417f9f4d845/revisions/sweep/1791849384244-000000000000-e8ec8f20403e6ee93f6db7acc1a07b98.json
  • crates/tinyflows-import/tests/fixtures/workflow-store/state/definitions/3854983f88763a4631f806cfdedde1b4d5dff5f5194b6fdd75998417f9f4d845/revisions/sweep/1791849384244-000000000001-cf5377d354cea8a5b39a7e89513802ec.json
  • crates/tinyflows-import/tests/fixtures/workflow-store/state/journal/sweep.json
  • crates/tinyflows-import/tests/fixtures/workflow-store/state/proposals/0000000000005-000000000000-83da8a7edd825c2bce8cd7392068472f.json
  • crates/tinyflows-import/tests/fixtures/workflow-store/state/runs/run-a.json
  • crates/tinyflows-import/tests/fixtures/workflow-store/state/runs/run-b.json
  • crates/tinyflows-import/tests/fixtures/workflow-store/state/runs/run-c.json
  • crates/tinyflows-import/tests/fixtures/workflow-store/workflows/deploy.json
  • crates/tinyflows-import/tests/fixtures/workflow-store/workflows/sweep.json
  • crates/tinyflows-module/README.md
  • crates/tinyflows-module/src/caps_tests/scope_tests.rs
  • crates/tinyflows-module/src/catalog_documents.rs
  • crates/tinyflows-module/src/catalog_documents_tests.rs
  • crates/tinyflows-module/src/catalog_legacy_batch.rs
  • crates/tinyflows-module/src/catalog_legacy_checkpoint.rs
  • crates/tinyflows-module/src/catalog_legacy_import.rs
  • crates/tinyflows-module/src/catalog_migrations.rs
  • crates/tinyflows-module/src/catalog_service_migration_tests.rs
  • crates/tinyflows-module/src/catalog_service_tests.rs
  • crates/tinyflows-module/src/lib.rs
  • crates/tinyflows-module/src/run_manager/dedup_settlement_tests.rs
  • crates/tinyflows-module/src/run_manager/events_persistence_test_support.rs
  • crates/tinyflows-module/src/run_manager_actor_recovery_tests.rs
  • crates/tinyflows-module/src/run_manager_tests.rs
  • crates/tinyflows-module/src/schedule_clock_tests.rs
  • crates/tinyflows-module/src/schedule_documents.rs
  • crates/tinyflows-module/src/schedule_documents_tests.rs
  • crates/tinyflows-module/src/schedule_manual_worker_lifecycle_service_tests.rs
  • crates/tinyflows-module/src/schedule_manual_worker_service_tests.rs
  • crates/tinyflows-module/src/schedule_members_tests.rs
  • crates/tinyflows-module/src/schedule_service_tests.rs
  • crates/tinyflows-module/src/schedule_store.rs
  • crates/tinyflows-module/src/schedule_store_tests.rs
  • crates/tinyflows-module/tests/fixtures/storage/README.md
  • crates/tinyflows-module/tests/fixtures/storage/cron-job-v0.8.28.json
  • crates/tinyflows-module/tests/fixtures/storage/cron-job-v0.8.8.json
  • crates/tinyflows-module/tests/fixtures/storage/generators/generate_v0.8.28.rs
  • crates/tinyflows-module/tests/fixtures/storage/generators/generate_v0.8.8.rs
  • crates/tinyflows-module/tests/module_artifact_tests.rs
  • crates/tinyflows-module/tests/run_artifact/support.rs
  • crates/tinyflows-module/tests/support/catalog_legacy_import_artifact_tests.rs
  • crates/tinyflows-module/tests/support/document_callbacks.rs
  • crates/tinyflows-module/tests/support/manual_worker_artifact_tests.rs
  • crates/tinyflows-module/tests/support/scheduler_stop_artifact_tests.rs
  • crates/tinyflows-schedule/src/posix_weekday.rs
  • crates/tinyflows-schedule/src/validation.rs
  • crates/tinyflows-storage/src/blocking.rs
  • crates/tinyflows-storage/src/blocking_tests.rs
  • crates/tinyflows-storage/src/key.rs
  • crates/tinyflows-storage/src/key_tests.rs
  • crates/tinyflows-storage/src/lib.rs
  • crates/tinyflows-storage/src/primitives/counters.rs
  • crates/tinyflows-storage/src/primitives/counters_tests.rs
  • crates/tinyflows-storage/src/primitives/leases.rs
  • crates/tinyflows-storage/src/primitives/leases/acquire_with.rs
  • crates/tinyflows-storage/src/primitives/leases_tests.rs
  • crates/tinyflows-storage/src/primitives/mod.rs
  • crates/tinyflows-storage/src/schema.rs
  • crates/tinyflows/src/caps/host/script_tests/script_tests_part_01_tests.rs
  • crates/tinyflows/src/migrate.rs
  • crates/tinyflows/src/nodes/control_flow/dedup_settle.rs
  • crates/tinyflows/src/nodes/integration/agent.rs
  • crates/tinyflows/src/nodes/integration/agent_prompt.rs
  • crates/tinyflows/src/nodes/integration/agent_prompt/json_extract.rs
  • crates/tinyflows/src/nodes/integration/approval.rs
  • crates/tinyflows/src/nodes/integration/schema.rs
  • crates/tinyflows/src/preflight_inputs.rs
  • crates/tinyflows/src/validate/node_config.rs
  • crates/tinyflows/tests/interception_e2e_tests.rs
  • docs/storage-crate-split.md
  • docs/tinyflows-bus-design.md
  • scripts/check-legacy-import-modes.sh
  • scripts/check-storage-engine-free.sh
  • vendor/tinybus

Partial review reasons

  • critique: CLAUDE.md — not selected by the large-review budget
  • security: CLAUDE.md — not selected by the large-review budget
  • critique: crates/tinyflows-adaptive/README.md — not selected by the large-review budget
  • critique: crates/tinyflows-adaptive/docs/api.md — not selected by the large-review budget
  • critique: crates/tinyflows-adaptive/src/drivers/ledger/mod.rs — not selected by the large-review budget
  • security: crates/tinyflows-adaptive/src/drivers/ledger/mod.rs — not selected by the large-review budget
  • critique: crates/tinyflows-adaptive/src/drivers/ledger_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-adaptive/src/drivers/ledger_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-adaptive/src/drivers/migrate.rs — not selected by the large-review budget
  • security: crates/tinyflows-adaptive/src/drivers/migrate.rs — not selected by the large-review budget
  • critique: crates/tinyflows-adaptive/src/drivers/migrate_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-adaptive/src/drivers/migrate_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-adaptive/src/drivers/mod.rs — not selected by the large-review budget
  • security: crates/tinyflows-adaptive/src/drivers/mod.rs — not selected by the large-review budget
  • critique: crates/tinyflows-adaptive/src/drivers/vault_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-adaptive/src/drivers/vault_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-adaptive/src/storage.rs — not selected by the large-review budget
  • security: crates/tinyflows-adaptive/src/storage.rs — not selected by the large-review budget
  • critique: crates/tinyflows-adaptive/src/storage_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-adaptive/src/storage_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-adaptive/tests/driver/driver_part_01_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-adaptive/tests/driver/driver_part_01_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-adaptive/tests/support/driver_store.rs — not selected by the large-review budget
  • security: crates/tinyflows-adaptive/tests/support/driver_store.rs — not selected by the large-review budget
  • critique: crates/tinyflows-bus/src/schedule/mod.rs — not selected by the large-review budget
  • security: crates/tinyflows-bus/src/schedule/mod.rs — not selected by the large-review budget
  • critique: crates/tinyflows-catalog/src/build_registry.rs — not selected by the large-review budget
  • security: crates/tinyflows-catalog/src/build_registry.rs — not selected by the large-review budget
  • critique: crates/tinyflows-catalog/src/import/n8n/expr.rs — not selected by the large-review budget
  • security: crates/tinyflows-catalog/src/import/n8n/expr.rs — not selected by the large-review budget
  • critique: crates/tinyflows-catalog/src/import/n8n/node_mapping.rs — not selected by the large-review budget
  • security: crates/tinyflows-catalog/src/import/n8n/node_mapping.rs — not selected by the large-review budget
  • critique: crates/tinyflows-copilot/src/tools/draft_edit.rs — not selected by the large-review budget
  • security: crates/tinyflows-copilot/src/tools/draft_edit.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/README.md — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/catalog/definitions_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/catalog/definitions_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/catalog/drafts_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/catalog/drafts_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/catalog/import.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/catalog/import.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/catalog/kv_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/catalog/kv_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/catalog/migrate.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/catalog/migrate.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/catalog/migrate_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/catalog/migrate_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/catalog/mod.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/catalog/mod.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/catalog/revisions_gap_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/catalog/revisions_gap_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/catalog/runs_lifecycle_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/catalog/runs_lifecycle_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/catalog/runs_recovery_lease_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/catalog/runs_recovery_lease_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/catalog/runs_replace_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/catalog/runs_replace_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/catalog/test_support.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/catalog/test_support.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/checkpoint.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/checkpoint.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/checkpoint_import_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/checkpoint_import_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/checkpoint_layout_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/checkpoint_layout_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/checkpoint_lineage_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/checkpoint_lineage_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/checkpoint_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/checkpoint_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/lib.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/lib.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/admission.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/admission.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/admission_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/admission_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/claim_removal_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/claim_removal_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/claims_compaction_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/claims_compaction_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/claims_safety_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/claims_safety_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/claims_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/claims_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/codec.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/codec.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/import.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/import.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/import_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/import_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/jobs.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/jobs.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/manual_claim_fence_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/manual_claim_fence_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/manual_claim_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/manual_claim_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/migrate.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/migrate.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/migrate_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/migrate_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/migrated_job_identity_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/migrated_job_identity_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/mod.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/mod.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/mod_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/mod_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/removal_claims_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/removal_claims_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/runs.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/runs.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/runs_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/runs_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/schedule/test_support.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/schedule/test_support.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/state_store_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/state_store_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/storage/kv_import.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/storage/kv_import.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/storage/kv_import_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/storage/kv_import_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/storage/mod.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/storage/mod.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/store/concurrency_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/store/concurrency_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/store/history_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/store/history_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/store/import.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/store/import.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/store/import_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/store/import_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/store/locks_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/store/locks_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/store/migrate.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/store/migrate.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/store/migrate_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/store/migrate_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/store/mod_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/store/mod_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/store/notes_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/store/notes_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/store/proposals_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/store/proposals_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/store/runs_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/store/runs_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-drivers/src/store/test_support.rs — not selected by the large-review budget
  • security: crates/tinyflows-drivers/src/store/test_support.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/README.md — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/caps_tests/scope_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/caps_tests/scope_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/catalog_documents.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/catalog_documents.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/catalog_documents_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/catalog_documents_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/catalog_legacy_batch.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/catalog_legacy_batch.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/catalog_legacy_import.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/catalog_legacy_import.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/catalog_migrations.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/catalog_migrations.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/catalog_service_migration_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/catalog_service_migration_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/catalog_service_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/catalog_service_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/lib.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/lib.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/run_manager/dedup_settlement_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/run_manager/dedup_settlement_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/run_manager/events_persistence_test_support.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/run_manager/events_persistence_test_support.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/run_manager_actor_recovery_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/run_manager_actor_recovery_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/run_manager_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/run_manager_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/schedule_clock_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/schedule_clock_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/schedule_documents.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/schedule_documents.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/schedule_documents_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/schedule_documents_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/schedule_manual_worker_lifecycle_service_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/schedule_manual_worker_lifecycle_service_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/schedule_manual_worker_service_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/schedule_manual_worker_service_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/schedule_members_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/schedule_members_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/schedule_service_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/schedule_service_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/schedule_store.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/schedule_store.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/src/schedule_store_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/src/schedule_store_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/tests/fixtures/storage/README.md — not selected by the large-review budget
  • critique: crates/tinyflows-module/tests/fixtures/storage/cron-job-v0.8.28.json — not selected by the large-review budget
  • security: crates/tinyflows-module/tests/fixtures/storage/cron-job-v0.8.28.json — not selected by the large-review budget
  • critique: crates/tinyflows-module/tests/fixtures/storage/cron-job-v0.8.8.json — not selected by the large-review budget
  • security: crates/tinyflows-module/tests/fixtures/storage/cron-job-v0.8.8.json — not selected by the large-review budget
  • critique: crates/tinyflows-module/tests/fixtures/storage/generators/generate_v0.8.28.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/tests/fixtures/storage/generators/generate_v0.8.28.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/tests/fixtures/storage/generators/generate_v0.8.8.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/tests/fixtures/storage/generators/generate_v0.8.8.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/tests/module_artifact_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/tests/module_artifact_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/tests/run_artifact/support.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/tests/run_artifact/support.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/tests/support/catalog_legacy_import_artifact_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/tests/support/catalog_legacy_import_artifact_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/tests/support/document_callbacks.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/tests/support/document_callbacks.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/tests/support/manual_worker_artifact_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/tests/support/manual_worker_artifact_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-module/tests/support/scheduler_stop_artifact_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-module/tests/support/scheduler_stop_artifact_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-schedule/src/posix_weekday.rs — not selected by the large-review budget
  • security: crates/tinyflows-schedule/src/posix_weekday.rs — not selected by the large-review budget
  • critique: crates/tinyflows-schedule/src/validation.rs — not selected by the large-review budget
  • security: crates/tinyflows-schedule/src/validation.rs — not selected by the large-review budget
  • critique: crates/tinyflows-storage/src/blocking.rs — not selected by the large-review budget
  • security: crates/tinyflows-storage/src/blocking.rs — not selected by the large-review budget
  • critique: crates/tinyflows-storage/src/blocking_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-storage/src/blocking_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-storage/src/key.rs — not selected by the large-review budget
  • security: crates/tinyflows-storage/src/key.rs — not selected by the large-review budget
  • critique: crates/tinyflows-storage/src/key_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-storage/src/key_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-storage/src/lib.rs — not selected by the large-review budget
  • security: crates/tinyflows-storage/src/lib.rs — not selected by the large-review budget
  • critique: crates/tinyflows-storage/src/primitives/counters.rs — not selected by the large-review budget
  • security: crates/tinyflows-storage/src/primitives/counters.rs — not selected by the large-review budget
  • critique: crates/tinyflows-storage/src/primitives/counters_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows-storage/src/primitives/counters_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-storage/src/primitives/leases.rs — not selected by the large-review budget
  • critique: crates/tinyflows-storage/src/primitives/leases/acquire_with.rs — not selected by the large-review budget
  • security: crates/tinyflows-storage/src/primitives/leases/acquire_with.rs — not selected by the large-review budget
  • critique: crates/tinyflows-storage/src/primitives/leases_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows-storage/src/schema.rs — not selected by the large-review budget
  • security: crates/tinyflows-storage/src/schema.rs — not selected by the large-review budget
  • critique: crates/tinyflows/src/caps/host/script_tests/script_tests_part_01_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows/src/caps/host/script_tests/script_tests_part_01_tests.rs — not selected by the large-review budget
  • critique: crates/tinyflows/src/migrate.rs — not selected by the large-review budget
  • security: crates/tinyflows/src/migrate.rs — not selected by the large-review budget
  • critique: crates/tinyflows/src/nodes/control_flow/dedup_settle.rs — not selected by the large-review budget
  • security: crates/tinyflows/src/nodes/control_flow/dedup_settle.rs — not selected by the large-review budget
  • critique: crates/tinyflows/src/nodes/integration/agent.rs — not selected by the large-review budget
  • security: crates/tinyflows/src/nodes/integration/agent.rs — not selected by the large-review budget
  • critique: crates/tinyflows/src/nodes/integration/agent_prompt.rs — not selected by the large-review budget
  • security: crates/tinyflows/src/nodes/integration/agent_prompt.rs — not selected by the large-review budget
  • critique: crates/tinyflows/src/nodes/integration/agent_prompt/json_extract.rs — not selected by the large-review budget
  • security: crates/tinyflows/src/nodes/integration/agent_prompt/json_extract.rs — not selected by the large-review budget
  • critique: crates/tinyflows/src/nodes/integration/approval.rs — not selected by the large-review budget
  • security: crates/tinyflows/src/nodes/integration/approval.rs — not selected by the large-review budget
  • critique: crates/tinyflows/src/nodes/integration/schema.rs — not selected by the large-review budget
  • security: crates/tinyflows/src/nodes/integration/schema.rs — not selected by the large-review budget
  • critique: crates/tinyflows/src/preflight_inputs.rs — not selected by the large-review budget
  • security: crates/tinyflows/src/preflight_inputs.rs — not selected by the large-review budget
  • critique: crates/tinyflows/src/validate/node_config.rs — not selected by the large-review budget
  • security: crates/tinyflows/src/validate/node_config.rs — not selected by the large-review budget
  • critique: crates/tinyflows/tests/interception_e2e_tests.rs — not selected by the large-review budget
  • security: crates/tinyflows/tests/interception_e2e_tests.rs — not selected by the large-review budget
  • critique: docs/storage-crate-split.md — not selected by the large-review budget
  • critique: docs/tinyflows-bus-design.md — not selected by the large-review budget
  • critique: scripts/check-storage-engine-free.sh — not selected by the large-review budget
  • security: scripts/check-storage-engine-free.sh — not selected by the large-review budget

Review snapshot

Change surface Files Review signal Count
Production 102 Active findings 0
Tests 124 Noted findings 3
Documentation 9 Resolved findings 0
Configuration 8 Pending checks/questions 396

Completeness: Incomplete
Test assessment: Test coverage is assessed from changed tests and lane evidence; execution is not claimed without trusted check data.

Features

  • Added — Private tinyflows-storage helper on public TSD v2 contracts: Provides TinyFlows-owned Key, Repo (CAS with retry/jitter), Counters, Kv, Leases (including `acquire_with`), Blocking bridge, and Schema/Migrations on the public `tinystoragedrivers-api`/`tinystoragedrivers-types` vocabulary so storage behavior stays in an unpublishable helper; `Blocking` guards reentry and uses `block_in_place` only on multi-thread workers. (crates/tinyflows-storage/src/lib.rs, crates/tinyflows-storage/src/blocking.rs, crates/tinyflows-storage/src/primitives/repo.rs, crates/tinyflows-storage/src/primitives/leases/acquire_with.rs, crates/tinyflows-storage/src/schema/migrations.rs)
  • Removed — Retire tinyflows-import and its fixtures: The one-time SQLite/filesystem importer, its report type, readers, and fixtures are deleted; hosts own source discovery and decoding, while the module retains the semantic legacy-batch/checkpoint writers. (crates/tinyflows-import/src/lib.rs, crates/tinyflows-module/src/lib.rs pub mod caps;, crates/tinyflows-module/src/catalog_legacy_batch.rs pub async fn apply_legacy_batch(, crates/tinyflows-drivers/src/catalog/import.rs)
  • Internal refactor — Module splits and clippy let-chain collapses: Checkpoint lineage tests, JSON extraction (`json_extract`), and `acquire_with` move into focused modules, and nested `if let` blocks collapse into let-chains across the engine, catalog, schedule, and copilot with unchanged behavior. (crates/tinyflows-drivers/src/checkpoint.rs mod checkpoint_import;, crates/tinyflows/src/nodes/integration/agent_prompt/json_extract.rs, crates/tinyflows-storage/src/primitives/leases/acquire_with.rs, crates/tinyflows-catalog/src/import/n8n/expr.rs pub(super) fn translate_expr(raw: &str, warnings: &mut Vec<String>, n8n_name: &s)

Tests

  • regression_candidate — CI adds `dtolnay/rust-toolchain@1.88.0` for the MSRV job.: The tests lane reports this as adding an unpinned third-party action, a defect in this PR. (.github/workflows/ci.yml jobs:)

Before merge

  • Complete the critique review for crates/tinyflows-storage/src/primitives/leases.rs, crates/tinyflows-storage/src/primitives/leases_tests.rs, crates/tinyflows-storage/src/key.rs, crates/tinyflows-storage/src/key_tests.rs, crates/tinyflows-storage/src/schema.rs, crates/tinyflows-storage/src/blocking.rs, crates/tinyflows-storage/src/blocking_tests.rs, crates/tinyflows-adaptive/src/drivers/migrate.rs, crates/tinyflows-adaptive/src/drivers/migrate_tests.rs, crates/tinyflows-adaptive/src/drivers/mod.rs, crates/tinyflows-storage/src/primitives/counters.rs, crates/tinyflows-storage/src/primitives/counters_tests.rs, crates/tinyflows/src/nodes/integration/agent_prompt.rs, crates/tinyflows/src/nodes/integration/agent_prompt/json_extract.rs, crates/tinyflows-storage/src/primitives/leases/acquire_with.rs, crates/tinyflows-storage/src/lib.rs, crates/tinyflows-drivers/src/schedule/migrate.rs, crates/tinyflows-drivers/src/storage/mod.rs, crates/tinyflows-adaptive/src/storage.rs, crates/tinyflows-adaptive/src/storage_tests.rs, crates/tinyflows-drivers/src/storage/kv_import.rs, crates/tinyflows-drivers/src/lib.rs, crates/tinyflows/src/nodes/integration/agent.rs, crates/tinyflows-drivers/src/schedule/migrate_tests.rs, crates/tinyflows-drivers/src/store/test_support.rs, crates/tinyflows-drivers/src/schedule/test_support.rs, crates/tinyflows-drivers/src/store/migrate.rs, crates/tinyflows-drivers/src/store/migrate_tests.rs, crates/tinyflows-drivers/src/catalog/migrate_tests.rs, crates/tinyflows/src/preflight_inputs.rs, crates/tinyflows-drivers/src/catalog/test_support.rs, crates/tinyflows-drivers/src/checkpoint_lineage_tests.rs, crates/tinyflows-module/tests/fixtures/storage/README.md, crates/tinyflows-drivers/src/checkpoint_tests.rs, crates/tinyflows-drivers/src/schedule/manual_claim_fence_tests.rs, crates/tinyflows-module/src/schedule_documents_tests.rs, scripts/check-storage-engine-free.sh, crates/tinyflows-drivers/src/schedule/migrated_job_identity_tests.rs, crates/tinyflows-drivers/src/schedule/admission.rs, crates/tinyflows-drivers/src/schedule/admission_tests.rs, crates/tinyflows-module/src/run_manager/events_persistence_test_support.rs, crates/tinyflows/src/nodes/integration/approval.rs, crates/tinyflows-catalog/src/import/n8n/expr.rs, crates/tinyflows-drivers/src/catalog/migrate.rs, crates/tinyflows/src/validate/node_config.rs, crates/tinyflows-module/tests/fixtures/storage/cron-job-v0.8.28.json, crates/tinyflows-drivers/src/schedule/runs_tests.rs, crates/tinyflows-module/src/catalog_documents_tests.rs, crates/tinyflows-module/tests/fixtures/storage/generators/generate_v0.8.28.rs, docs/storage-crate-split.md, crates/tinyflows-drivers/README.md, crates/tinyflows-copilot/src/tools/draft_edit.rs, crates/tinyflows-module/tests/fixtures/storage/generators/generate_v0.8.8.rs, crates/tinyflows-catalog/src/build_registry.rs, crates/tinyflows-module/src/catalog_service_tests.rs, crates/tinyflows/src/nodes/integration/schema.rs, crates/tinyflows-drivers/src/schedule/codec.rs, crates/tinyflows-module/tests/fixtures/storage/cron-job-v0.8.8.json, crates/tinyflows/src/nodes/control_flow/dedup_settle.rs, crates/tinyflows-drivers/src/storage/kv_import_tests.rs, crates/tinyflows-module/src/catalog_migrations.rs, crates/tinyflows-module/src/schedule_documents.rs, crates/tinyflows-module/src/schedule_service_tests.rs, crates/tinyflows-module/src/catalog_documents.rs, crates/tinyflows-module/src/schedule_store.rs, crates/tinyflows-module/src/schedule_store_tests.rs, crates/tinyflows-module/README.md, crates/tinyflows-module/tests/support/document_callbacks.rs, crates/tinyflows-adaptive/src/drivers/vault_tests.rs, crates/tinyflows-drivers/src/schedule/jobs.rs, crates/tinyflows-drivers/src/schedule/mod.rs, crates/tinyflows-module/src/run_manager_tests.rs, crates/tinyflows-drivers/src/schedule/claims_tests.rs, crates/tinyflows-drivers/src/schedule/runs.rs, docs/tinyflows-bus-design.md, crates/tinyflows-drivers/src/checkpoint_layout_tests.rs, crates/tinyflows-module/src/schedule_manual_worker_service_tests.rs, crates/tinyflows/tests/interception_e2e_tests.rs, crates/tinyflows-drivers/src/schedule/import.rs, crates/tinyflows-drivers/src/schedule/import_tests.rs, crates/tinyflows-catalog/src/import/n8n/node_mapping.rs, crates/tinyflows-drivers/src/catalog/mod.rs, crates/tinyflows-module/src/schedule_members_tests.rs, crates/tinyflows/src/migrate.rs, crates/tinyflows-adaptive/src/drivers/ledger_tests.rs, crates/tinyflows-drivers/src/catalog/runs_recovery_lease_tests.rs, crates/tinyflows-drivers/src/catalog/runs_replace_tests.rs, crates/tinyflows-module/src/catalog_service_migration_tests.rs, crates/tinyflows-module/src/run_manager/dedup_settlement_tests.rs, crates/tinyflows-module/src/run_manager_actor_recovery_tests.rs, crates/tinyflows-module/tests/module_artifact_tests.rs, crates/tinyflows-module/tests/support/manual_worker_artifact_tests.rs, crates/tinyflows-adaptive/tests/driver/driver_part_01_tests.rs, crates/tinyflows-adaptive/tests/support/driver_store.rs, crates/tinyflows-drivers/src/schedule/removal_claims_tests.rs, crates/tinyflows-module/src/catalog_legacy_batch.rs, crates/tinyflows-schedule/src/validation.rs, crates/tinyflows-drivers/src/store/import.rs, crates/tinyflows-drivers/src/store/import_tests.rs, crates/tinyflows-drivers/src/catalog/import.rs, crates/tinyflows-drivers/src/checkpoint.rs, crates/tinyflows-drivers/src/checkpoint_import_tests.rs, crates/tinyflows-drivers/src/schedule/mod_tests.rs, crates/tinyflows-drivers/src/store/proposals_tests.rs, crates/tinyflows-module/src/caps_tests/scope_tests.rs, crates/tinyflows-module/src/schedule_clock_tests.rs, crates/tinyflows-module/src/schedule_manual_worker_lifecycle_service_tests.rs, crates/tinyflows/src/caps/host/script_tests/script_tests_part_01_tests.rs, crates/tinyflows-adaptive/src/drivers/ledger/mod.rs, crates/tinyflows-drivers/src/catalog/definitions_tests.rs, crates/tinyflows-module/src/catalog_legacy_import.rs, CLAUDE.md, crates/tinyflows-drivers/src/catalog/revisions_gap_tests.rs, crates/tinyflows-drivers/src/schedule/claims_compaction_tests.rs, crates/tinyflows-drivers/src/state_store_tests.rs, crates/tinyflows-drivers/src/store/locks_tests.rs, crates/tinyflows-drivers/src/store/mod_tests.rs, crates/tinyflows-drivers/src/store/notes_tests.rs, crates/tinyflows-drivers/src/store/runs_tests.rs, crates/tinyflows-module/tests/run_artifact/support.rs, crates/tinyflows-module/tests/support/catalog_legacy_import_artifact_tests.rs, crates/tinyflows-module/tests/support/scheduler_stop_artifact_tests.rs, crates/tinyflows-adaptive/README.md, crates/tinyflows-adaptive/docs/api.md, crates/tinyflows-bus/src/schedule/mod.rs, crates/tinyflows-drivers/src/catalog/drafts_tests.rs, crates/tinyflows-drivers/src/catalog/kv_tests.rs, crates/tinyflows-drivers/src/catalog/runs_lifecycle_tests.rs, crates/tinyflows-drivers/src/schedule/claim_removal_tests.rs, crates/tinyflows-drivers/src/schedule/claims_safety_tests.rs, crates/tinyflows-drivers/src/schedule/manual_claim_tests.rs, crates/tinyflows-drivers/src/store/concurrency_tests.rs, crates/tinyflows-drivers/src/store/history_tests.rs, crates/tinyflows-module/src/lib.rs, crates/tinyflows-schedule/src/posix_weekday.rs.
  • Complete the security review for crates/tinyflows-storage/src/key.rs, crates/tinyflows-storage/src/key_tests.rs, crates/tinyflows-storage/src/schema.rs, crates/tinyflows-storage/src/blocking.rs, crates/tinyflows-storage/src/blocking_tests.rs, crates/tinyflows-adaptive/src/drivers/migrate.rs, crates/tinyflows-adaptive/src/drivers/migrate_tests.rs, crates/tinyflows-adaptive/src/drivers/mod.rs, crates/tinyflows-storage/src/primitives/counters.rs, crates/tinyflows-storage/src/primitives/counters_tests.rs, crates/tinyflows/src/nodes/integration/agent_prompt.rs, crates/tinyflows/src/nodes/integration/agent_prompt/json_extract.rs, crates/tinyflows-storage/src/primitives/leases/acquire_with.rs, crates/tinyflows-storage/src/lib.rs, crates/tinyflows-drivers/src/schedule/migrate.rs, crates/tinyflows-drivers/src/storage/mod.rs, crates/tinyflows-adaptive/src/storage.rs, crates/tinyflows-adaptive/src/storage_tests.rs, crates/tinyflows-drivers/src/storage/kv_import.rs, crates/tinyflows-drivers/src/lib.rs, crates/tinyflows/src/nodes/integration/agent.rs, crates/tinyflows-drivers/src/schedule/migrate_tests.rs, crates/tinyflows-drivers/src/store/test_support.rs, crates/tinyflows-drivers/src/schedule/test_support.rs, crates/tinyflows-drivers/src/store/migrate.rs, crates/tinyflows-drivers/src/store/migrate_tests.rs, crates/tinyflows-drivers/src/catalog/migrate_tests.rs, crates/tinyflows/src/preflight_inputs.rs, crates/tinyflows-drivers/src/catalog/test_support.rs, crates/tinyflows-drivers/src/checkpoint_lineage_tests.rs, crates/tinyflows-drivers/src/checkpoint_tests.rs, crates/tinyflows-drivers/src/schedule/manual_claim_fence_tests.rs, crates/tinyflows-module/src/schedule_documents_tests.rs, scripts/check-storage-engine-free.sh, crates/tinyflows-drivers/src/schedule/migrated_job_identity_tests.rs, crates/tinyflows-drivers/src/schedule/admission.rs, crates/tinyflows-drivers/src/schedule/admission_tests.rs, crates/tinyflows-module/src/run_manager/events_persistence_test_support.rs, crates/tinyflows/src/nodes/integration/approval.rs, crates/tinyflows-catalog/src/import/n8n/expr.rs, crates/tinyflows-drivers/src/catalog/migrate.rs, crates/tinyflows/src/validate/node_config.rs, crates/tinyflows-module/tests/fixtures/storage/cron-job-v0.8.28.json, crates/tinyflows-drivers/src/schedule/runs_tests.rs, crates/tinyflows-module/src/catalog_documents_tests.rs, crates/tinyflows-module/tests/fixtures/storage/generators/generate_v0.8.28.rs, crates/tinyflows-copilot/src/tools/draft_edit.rs, crates/tinyflows-module/tests/fixtures/storage/generators/generate_v0.8.8.rs, crates/tinyflows-catalog/src/build_registry.rs, crates/tinyflows-module/src/catalog_service_tests.rs, crates/tinyflows/src/nodes/integration/schema.rs, crates/tinyflows-drivers/src/schedule/codec.rs, crates/tinyflows-module/tests/fixtures/storage/cron-job-v0.8.8.json, crates/tinyflows/src/nodes/control_flow/dedup_settle.rs, crates/tinyflows-drivers/src/storage/kv_import_tests.rs, crates/tinyflows-module/src/catalog_migrations.rs, crates/tinyflows-module/src/schedule_documents.rs, crates/tinyflows-module/src/schedule_service_tests.rs, crates/tinyflows-module/src/catalog_documents.rs, crates/tinyflows-module/src/schedule_store.rs, crates/tinyflows-module/src/schedule_store_tests.rs, crates/tinyflows-module/tests/support/document_callbacks.rs, crates/tinyflows-adaptive/src/drivers/vault_tests.rs, crates/tinyflows-drivers/src/schedule/jobs.rs, crates/tinyflows-drivers/src/schedule/mod.rs, crates/tinyflows-module/src/run_manager_tests.rs, crates/tinyflows-drivers/src/schedule/claims_tests.rs, crates/tinyflows-drivers/src/schedule/runs.rs, crates/tinyflows-drivers/src/checkpoint_layout_tests.rs, crates/tinyflows-module/src/schedule_manual_worker_service_tests.rs, crates/tinyflows/tests/interception_e2e_tests.rs, crates/tinyflows-drivers/src/schedule/import.rs, crates/tinyflows-drivers/src/schedule/import_tests.rs, crates/tinyflows-catalog/src/import/n8n/node_mapping.rs, crates/tinyflows-drivers/src/catalog/mod.rs, crates/tinyflows-module/src/schedule_members_tests.rs, crates/tinyflows/src/migrate.rs, crates/tinyflows-adaptive/src/drivers/ledger_tests.rs, crates/tinyflows-drivers/src/catalog/runs_recovery_lease_tests.rs, crates/tinyflows-drivers/src/catalog/runs_replace_tests.rs, crates/tinyflows-module/src/catalog_service_migration_tests.rs, crates/tinyflows-module/src/run_manager/dedup_settlement_tests.rs, crates/tinyflows-module/src/run_manager_actor_recovery_tests.rs, crates/tinyflows-module/tests/module_artifact_tests.rs, crates/tinyflows-module/tests/support/manual_worker_artifact_tests.rs, crates/tinyflows-adaptive/tests/driver/driver_part_01_tests.rs, crates/tinyflows-adaptive/tests/support/driver_store.rs, crates/tinyflows-drivers/src/schedule/removal_claims_tests.rs, crates/tinyflows-module/src/catalog_legacy_batch.rs, crates/tinyflows-schedule/src/validation.rs, crates/tinyflows-drivers/src/store/import.rs, crates/tinyflows-drivers/src/store/import_tests.rs, crates/tinyflows-drivers/src/catalog/import.rs, crates/tinyflows-drivers/src/checkpoint.rs, crates/tinyflows-drivers/src/checkpoint_import_tests.rs, crates/tinyflows-drivers/src/schedule/mod_tests.rs, crates/tinyflows-drivers/src/store/proposals_tests.rs, crates/tinyflows-module/src/caps_tests/scope_tests.rs, crates/tinyflows-module/src/schedule_clock_tests.rs, crates/tinyflows-module/src/schedule_manual_worker_lifecycle_service_tests.rs, crates/tinyflows/src/caps/host/script_tests/script_tests_part_01_tests.rs, crates/tinyflows-adaptive/src/drivers/ledger/mod.rs, crates/tinyflows-drivers/src/catalog/definitions_tests.rs, crates/tinyflows-module/src/catalog_legacy_import.rs, CLAUDE.md, crates/tinyflows-drivers/src/catalog/revisions_gap_tests.rs, crates/tinyflows-drivers/src/schedule/claims_compaction_tests.rs, crates/tinyflows-drivers/src/state_store_tests.rs, crates/tinyflows-drivers/src/store/locks_tests.rs, crates/tinyflows-drivers/src/store/mod_tests.rs, crates/tinyflows-drivers/src/store/notes_tests.rs, crates/tinyflows-drivers/src/store/runs_tests.rs, crates/tinyflows-module/tests/run_artifact/support.rs, crates/tinyflows-module/tests/support/catalog_legacy_import_artifact_tests.rs, crates/tinyflows-module/tests/support/scheduler_stop_artifact_tests.rs, crates/tinyflows-bus/src/schedule/mod.rs, crates/tinyflows-drivers/src/catalog/drafts_tests.rs, crates/tinyflows-drivers/src/catalog/kv_tests.rs, crates/tinyflows-drivers/src/catalog/runs_lifecycle_tests.rs, crates/tinyflows-drivers/src/schedule/claim_removal_tests.rs, crates/tinyflows-drivers/src/schedule/claims_safety_tests.rs, crates/tinyflows-drivers/src/schedule/manual_claim_tests.rs, crates/tinyflows-drivers/src/store/concurrency_tests.rs, crates/tinyflows-drivers/src/store/history_tests.rs, crates/tinyflows-module/src/lib.rs, crates/tinyflows-schedule/src/posix_weekday.rs.
  • Review uncovered paths: CLAUDE.md, crates/tinyflows-adaptive/README.md, crates/tinyflows-adaptive/docs/api.md, crates/tinyflows-adaptive/src/drivers/ledger/mod.rs, crates/tinyflows-adaptive/src/drivers/ledger_tests.rs, crates/tinyflows-adaptive/src/drivers/migrate.rs, crates/tinyflows-adaptive/src/drivers/migrate_tests.rs, crates/tinyflows-adaptive/src/drivers/mod.rs, crates/tinyflows-adaptive/src/drivers/vault_tests.rs, crates/tinyflows-adaptive/src/storage.rs, crates/tinyflows-adaptive/src/storage_tests.rs, crates/tinyflows-adaptive/tests/driver/driver_part_01_tests.rs, crates/tinyflows-adaptive/tests/support/driver_store.rs, crates/tinyflows-bus/src/schedule/mod.rs, crates/tinyflows-catalog/src/build_registry.rs, crates/tinyflows-catalog/src/import/n8n/expr.rs, crates/tinyflows-catalog/src/import/n8n/node_mapping.rs, crates/tinyflows-copilot/src/tools/draft_edit.rs, crates/tinyflows-drivers/README.md, crates/tinyflows-drivers/src/catalog/definitions_tests.rs, crates/tinyflows-drivers/src/catalog/drafts_tests.rs, crates/tinyflows-drivers/src/catalog/import.rs, crates/tinyflows-drivers/src/catalog/kv_tests.rs, crates/tinyflows-drivers/src/catalog/migrate.rs, crates/tinyflows-drivers/src/catalog/migrate_tests.rs, crates/tinyflows-drivers/src/catalog/mod.rs, crates/tinyflows-drivers/src/catalog/revisions_gap_tests.rs, crates/tinyflows-drivers/src/catalog/runs_lifecycle_tests.rs, crates/tinyflows-drivers/src/catalog/runs_recovery_lease_tests.rs, crates/tinyflows-drivers/src/catalog/runs_replace_tests.rs, crates/tinyflows-drivers/src/catalog/test_support.rs, crates/tinyflows-drivers/src/checkpoint.rs, crates/tinyflows-drivers/src/checkpoint_import_tests.rs, crates/tinyflows-drivers/src/checkpoint_layout_tests.rs, crates/tinyflows-drivers/src/checkpoint_lineage_tests.rs, crates/tinyflows-drivers/src/checkpoint_tests.rs, crates/tinyflows-drivers/src/lib.rs, crates/tinyflows-drivers/src/schedule/admission.rs, crates/tinyflows-drivers/src/schedule/admission_tests.rs, crates/tinyflows-drivers/src/schedule/claim_removal_tests.rs, crates/tinyflows-drivers/src/schedule/claims_compaction_tests.rs, crates/tinyflows-drivers/src/schedule/claims_safety_tests.rs, crates/tinyflows-drivers/src/schedule/claims_tests.rs, crates/tinyflows-drivers/src/schedule/codec.rs, crates/tinyflows-drivers/src/schedule/import.rs, crates/tinyflows-drivers/src/schedule/import_tests.rs, crates/tinyflows-drivers/src/schedule/jobs.rs, crates/tinyflows-drivers/src/schedule/manual_claim_fence_tests.rs, crates/tinyflows-drivers/src/schedule/manual_claim_tests.rs, crates/tinyflows-drivers/src/schedule/migrate.rs, crates/tinyflows-drivers/src/schedule/migrate_tests.rs, crates/tinyflows-drivers/src/schedule/migrated_job_identity_tests.rs, crates/tinyflows-drivers/src/schedule/mod.rs, crates/tinyflows-drivers/src/schedule/mod_tests.rs, crates/tinyflows-drivers/src/schedule/removal_claims_tests.rs, crates/tinyflows-drivers/src/schedule/runs.rs, crates/tinyflows-drivers/src/schedule/runs_tests.rs, crates/tinyflows-drivers/src/schedule/test_support.rs, crates/tinyflows-drivers/src/state_store_tests.rs, crates/tinyflows-drivers/src/storage/kv_import.rs, crates/tinyflows-drivers/src/storage/kv_import_tests.rs, crates/tinyflows-drivers/src/storage/mod.rs, crates/tinyflows-drivers/src/store/concurrency_tests.rs, crates/tinyflows-drivers/src/store/history_tests.rs, crates/tinyflows-drivers/src/store/import.rs, crates/tinyflows-drivers/src/store/import_tests.rs, crates/tinyflows-drivers/src/store/locks_tests.rs, crates/tinyflows-drivers/src/store/migrate.rs, crates/tinyflows-drivers/src/store/migrate_tests.rs, crates/tinyflows-drivers/src/store/mod_tests.rs, crates/tinyflows-drivers/src/store/notes_tests.rs, crates/tinyflows-drivers/src/store/proposals_tests.rs, crates/tinyflows-drivers/src/store/runs_tests.rs, crates/tinyflows-drivers/src/store/test_support.rs, crates/tinyflows-module/README.md, crates/tinyflows-module/src/caps_tests/scope_tests.rs, crates/tinyflows-module/src/catalog_documents.rs, crates/tinyflows-module/src/catalog_documents_tests.rs, crates/tinyflows-module/src/catalog_legacy_batch.rs, crates/tinyflows-module/src/catalog_legacy_import.rs, crates/tinyflows-module/src/catalog_migrations.rs, crates/tinyflows-module/src/catalog_service_migration_tests.rs, crates/tinyflows-module/src/catalog_service_tests.rs, crates/tinyflows-module/src/lib.rs, crates/tinyflows-module/src/run_manager/dedup_settlement_tests.rs, crates/tinyflows-module/src/run_manager/events_persistence_test_support.rs, crates/tinyflows-module/src/run_manager_actor_recovery_tests.rs, crates/tinyflows-module/src/run_manager_tests.rs, crates/tinyflows-module/src/schedule_clock_tests.rs, crates/tinyflows-module/src/schedule_documents.rs, crates/tinyflows-module/src/schedule_documents_tests.rs, crates/tinyflows-module/src/schedule_manual_worker_lifecycle_service_tests.rs, crates/tinyflows-module/src/schedule_manual_worker_service_tests.rs, crates/tinyflows-module/src/schedule_members_tests.rs, crates/tinyflows-module/src/schedule_service_tests.rs, crates/tinyflows-module/src/schedule_store.rs, crates/tinyflows-module/src/schedule_store_tests.rs, crates/tinyflows-module/tests/fixtures/storage/README.md, crates/tinyflows-module/tests/fixtures/storage/cron-job-v0.8.28.json, crates/tinyflows-module/tests/fixtures/storage/cron-job-v0.8.8.json, crates/tinyflows-module/tests/fixtures/storage/generators/generate_v0.8.28.rs, crates/tinyflows-module/tests/fixtures/storage/generators/generate_v0.8.8.rs, crates/tinyflows-module/tests/module_artifact_tests.rs, crates/tinyflows-module/tests/run_artifact/support.rs, crates/tinyflows-module/tests/support/catalog_legacy_import_artifact_tests.rs, crates/tinyflows-module/tests/support/document_callbacks.rs, crates/tinyflows-module/tests/support/manual_worker_artifact_tests.rs, crates/tinyflows-module/tests/support/scheduler_stop_artifact_tests.rs, crates/tinyflows-schedule/src/posix_weekday.rs, crates/tinyflows-schedule/src/validation.rs, crates/tinyflows-storage/src/blocking.rs, crates/tinyflows-storage/src/blocking_tests.rs, crates/tinyflows-storage/src/key.rs, crates/tinyflows-storage/src/key_tests.rs, crates/tinyflows-storage/src/lib.rs, crates/tinyflows-storage/src/primitives/counters.rs, crates/tinyflows-storage/src/primitives/counters_tests.rs, crates/tinyflows-storage/src/primitives/leases.rs, crates/tinyflows-storage/src/primitives/leases/acquire_with.rs, crates/tinyflows-storage/src/primitives/leases_tests.rs, crates/tinyflows-storage/src/schema.rs, crates/tinyflows/src/caps/host/script_tests/script_tests_part_01_tests.rs, crates/tinyflows/src/migrate.rs, crates/tinyflows/src/nodes/control_flow/dedup_settle.rs, crates/tinyflows/src/nodes/integration/agent.rs, crates/tinyflows/src/nodes/integration/agent_prompt.rs, crates/tinyflows/src/nodes/integration/agent_prompt/json_extract.rs, crates/tinyflows/src/nodes/integration/approval.rs, crates/tinyflows/src/nodes/integration/schema.rs, crates/tinyflows/src/preflight_inputs.rs, crates/tinyflows/src/validate/node_config.rs, crates/tinyflows/tests/interception_e2e_tests.rs, docs/storage-crate-split.md, docs/tinyflows-bus-design.md, scripts/check-storage-engine-free.sh.
Agent review details

critique

  • Conclusion: Neutral
  • Scope reviewed: incomplete; unanswered files: crates/tinyflows-storage/src/primitives/leases.rs, crates/tinyflows-storage/src/primitives/leases_tests.rs, crates/tinyflows-storage/src/key.rs, crates/tinyflows-storage/src/key_tests.rs, crates/tinyflows-storage/src/schema.rs, crates/tinyflows-storage/src/blocking.rs, crates/tinyflows-storage/src/blocking_tests.rs, crates/tinyflows-adaptive/src/drivers/migrate.rs, crates/tinyflows-adaptive/src/drivers/migrate_tests.rs, crates/tinyflows-adaptive/src/drivers/mod.rs, crates/tinyflows-storage/src/primitives/counters.rs, crates/tinyflows-storage/src/primitives/counters_tests.rs, crates/tinyflows/src/nodes/integration/agent_prompt.rs, crates/tinyflows/src/nodes/integration/agent_prompt/json_extract.rs, crates/tinyflows-storage/src/primitives/leases/acquire_with.rs, crates/tinyflows-storage/src/lib.rs, crates/tinyflows-drivers/src/schedule/migrate.rs, crates/tinyflows-drivers/src/storage/mod.rs, crates/tinyflows-adaptive/src/storage.rs, crates/tinyflows-adaptive/src/storage_tests.rs, crates/tinyflows-drivers/src/storage/kv_import.rs, crates/tinyflows-drivers/src/lib.rs, crates/tinyflows/src/nodes/integration/agent.rs, crates/tinyflows-drivers/src/schedule/migrate_tests.rs, crates/tinyflows-drivers/src/store/test_support.rs, crates/tinyflows-drivers/src/schedule/test_support.rs, crates/tinyflows-drivers/src/store/migrate.rs, crates/tinyflows-drivers/src/store/migrate_tests.rs, crates/tinyflows-drivers/src/catalog/migrate_tests.rs, crates/tinyflows/src/preflight_inputs.rs, crates/tinyflows-drivers/src/catalog/test_support.rs, crates/tinyflows-drivers/src/checkpoint_lineage_tests.rs, crates/tinyflows-module/tests/fixtures/storage/README.md, crates/tinyflows-drivers/src/checkpoint_tests.rs, crates/tinyflows-drivers/src/schedule/manual_claim_fence_tests.rs, crates/tinyflows-module/src/schedule_documents_tests.rs, scripts/check-storage-engine-free.sh, crates/tinyflows-drivers/src/schedule/migrated_job_identity_tests.rs, crates/tinyflows-drivers/src/schedule/admission.rs, crates/tinyflows-drivers/src/schedule/admission_tests.rs, crates/tinyflows-module/src/run_manager/events_persistence_test_support.rs, crates/tinyflows/src/nodes/integration/approval.rs, crates/tinyflows-catalog/src/import/n8n/expr.rs, crates/tinyflows-drivers/src/catalog/migrate.rs, crates/tinyflows/src/validate/node_config.rs, crates/tinyflows-module/tests/fixtures/storage/cron-job-v0.8.28.json, crates/tinyflows-drivers/src/schedule/runs_tests.rs, crates/tinyflows-module/src/catalog_documents_tests.rs, crates/tinyflows-module/tests/fixtures/storage/generators/generate_v0.8.28.rs, docs/storage-crate-split.md, crates/tinyflows-drivers/README.md, crates/tinyflows-copilot/src/tools/draft_edit.rs, crates/tinyflows-module/tests/fixtures/storage/generators/generate_v0.8.8.rs, crates/tinyflows-catalog/src/build_registry.rs, crates/tinyflows-module/src/catalog_service_tests.rs, crates/tinyflows/src/nodes/integration/schema.rs, crates/tinyflows-drivers/src/schedule/codec.rs, crates/tinyflows-module/tests/fixtures/storage/cron-job-v0.8.8.json, crates/tinyflows/src/nodes/control_flow/dedup_settle.rs, crates/tinyflows-drivers/src/storage/kv_import_tests.rs, crates/tinyflows-module/src/catalog_migrations.rs, crates/tinyflows-module/src/schedule_documents.rs, crates/tinyflows-module/src/schedule_service_tests.rs, crates/tinyflows-module/src/catalog_documents.rs, crates/tinyflows-module/src/schedule_store.rs, crates/tinyflows-module/src/schedule_store_tests.rs, crates/tinyflows-module/README.md, crates/tinyflows-module/tests/support/document_callbacks.rs, crates/tinyflows-adaptive/src/drivers/vault_tests.rs, crates/tinyflows-drivers/src/schedule/jobs.rs, crates/tinyflows-drivers/src/schedule/mod.rs, crates/tinyflows-module/src/run_manager_tests.rs, crates/tinyflows-drivers/src/schedule/claims_tests.rs, crates/tinyflows-drivers/src/schedule/runs.rs, docs/tinyflows-bus-design.md, crates/tinyflows-drivers/src/checkpoint_layout_tests.rs, crates/tinyflows-module/src/schedule_manual_worker_service_tests.rs, crates/tinyflows/tests/interception_e2e_tests.rs, crates/tinyflows-drivers/src/schedule/import.rs, crates/tinyflows-drivers/src/schedule/import_tests.rs, crates/tinyflows-catalog/src/import/n8n/node_mapping.rs, crates/tinyflows-drivers/src/catalog/mod.rs, crates/tinyflows-module/src/schedule_members_tests.rs, crates/tinyflows/src/migrate.rs, crates/tinyflows-adaptive/src/drivers/ledger_tests.rs, crates/tinyflows-drivers/src/catalog/runs_recovery_lease_tests.rs, crates/tinyflows-drivers/src/catalog/runs_replace_tests.rs, crates/tinyflows-module/src/catalog_service_migration_tests.rs, crates/tinyflows-module/src/run_manager/dedup_settlement_tests.rs, crates/tinyflows-module/src/run_manager_actor_recovery_tests.rs, crates/tinyflows-module/tests/module_artifact_tests.rs, crates/tinyflows-module/tests/support/manual_worker_artifact_tests.rs, crates/tinyflows-adaptive/tests/driver/driver_part_01_tests.rs, crates/tinyflows-adaptive/tests/support/driver_store.rs, crates/tinyflows-drivers/src/schedule/removal_claims_tests.rs, crates/tinyflows-module/src/catalog_legacy_batch.rs, crates/tinyflows-schedule/src/validation.rs, crates/tinyflows-drivers/src/store/import.rs, crates/tinyflows-drivers/src/store/import_tests.rs, crates/tinyflows-drivers/src/catalog/import.rs, crates/tinyflows-drivers/src/checkpoint.rs, crates/tinyflows-drivers/src/checkpoint_import_tests.rs, crates/tinyflows-drivers/src/schedule/mod_tests.rs, crates/tinyflows-drivers/src/store/proposals_tests.rs, crates/tinyflows-module/src/caps_tests/scope_tests.rs, crates/tinyflows-module/src/schedule_clock_tests.rs, crates/tinyflows-module/src/schedule_manual_worker_lifecycle_service_tests.rs, crates/tinyflows/src/caps/host/script_tests/script_tests_part_01_tests.rs, crates/tinyflows-adaptive/src/drivers/ledger/mod.rs, crates/tinyflows-drivers/src/catalog/definitions_tests.rs, crates/tinyflows-module/src/catalog_legacy_import.rs, CLAUDE.md, crates/tinyflows-drivers/src/catalog/revisions_gap_tests.rs, crates/tinyflows-drivers/src/schedule/claims_compaction_tests.rs, crates/tinyflows-drivers/src/state_store_tests.rs, crates/tinyflows-drivers/src/store/locks_tests.rs, crates/tinyflows-drivers/src/store/mod_tests.rs, crates/tinyflows-drivers/src/store/notes_tests.rs, crates/tinyflows-drivers/src/store/runs_tests.rs, crates/tinyflows-module/tests/run_artifact/support.rs, crates/tinyflows-module/tests/support/catalog_legacy_import_artifact_tests.rs, crates/tinyflows-module/tests/support/scheduler_stop_artifact_tests.rs, crates/tinyflows-adaptive/README.md, crates/tinyflows-adaptive/docs/api.md, crates/tinyflows-bus/src/schedule/mod.rs, crates/tinyflows-drivers/src/catalog/drafts_tests.rs, crates/tinyflows-drivers/src/catalog/kv_tests.rs, crates/tinyflows-drivers/src/catalog/runs_lifecycle_tests.rs, crates/tinyflows-drivers/src/schedule/claim_removal_tests.rs, crates/tinyflows-drivers/src/schedule/claims_safety_tests.rs, crates/tinyflows-drivers/src/schedule/manual_claim_tests.rs, crates/tinyflows-drivers/src/store/concurrency_tests.rs, crates/tinyflows-drivers/src/store/history_tests.rs, crates/tinyflows-module/src/lib.rs, crates/tinyflows-schedule/src/posix_weekday.rs
  • Lane summary: Reviewed 5 of 140 files — 135 not reviewed. Reviewed 5 files; 2 findings. 135 files were omitted: not selected by the large-review budget.

security

  • Conclusion: Neutral
  • Scope reviewed: incomplete; unanswered files: crates/tinyflows-storage/src/key.rs, crates/tinyflows-storage/src/key_tests.rs, crates/tinyflows-storage/src/schema.rs, crates/tinyflows-storage/src/blocking.rs, crates/tinyflows-storage/src/blocking_tests.rs, crates/tinyflows-adaptive/src/drivers/migrate.rs, crates/tinyflows-adaptive/src/drivers/migrate_tests.rs, crates/tinyflows-adaptive/src/drivers/mod.rs, crates/tinyflows-storage/src/primitives/counters.rs, crates/tinyflows-storage/src/primitives/counters_tests.rs, crates/tinyflows/src/nodes/integration/agent_prompt.rs, crates/tinyflows/src/nodes/integration/agent_prompt/json_extract.rs, crates/tinyflows-storage/src/primitives/leases/acquire_with.rs, crates/tinyflows-storage/src/lib.rs, crates/tinyflows-drivers/src/schedule/migrate.rs, crates/tinyflows-drivers/src/storage/mod.rs, crates/tinyflows-adaptive/src/storage.rs, crates/tinyflows-adaptive/src/storage_tests.rs, crates/tinyflows-drivers/src/storage/kv_import.rs, crates/tinyflows-drivers/src/lib.rs, crates/tinyflows/src/nodes/integration/agent.rs, crates/tinyflows-drivers/src/schedule/migrate_tests.rs, crates/tinyflows-drivers/src/store/test_support.rs, crates/tinyflows-drivers/src/schedule/test_support.rs, crates/tinyflows-drivers/src/store/migrate.rs, crates/tinyflows-drivers/src/store/migrate_tests.rs, crates/tinyflows-drivers/src/catalog/migrate_tests.rs, crates/tinyflows/src/preflight_inputs.rs, crates/tinyflows-drivers/src/catalog/test_support.rs, crates/tinyflows-drivers/src/checkpoint_lineage_tests.rs, crates/tinyflows-drivers/src/checkpoint_tests.rs, crates/tinyflows-drivers/src/schedule/manual_claim_fence_tests.rs, crates/tinyflows-module/src/schedule_documents_tests.rs, scripts/check-storage-engine-free.sh, crates/tinyflows-drivers/src/schedule/migrated_job_identity_tests.rs, crates/tinyflows-drivers/src/schedule/admission.rs, crates/tinyflows-drivers/src/schedule/admission_tests.rs, crates/tinyflows-module/src/run_manager/events_persistence_test_support.rs, crates/tinyflows/src/nodes/integration/approval.rs, crates/tinyflows-catalog/src/import/n8n/expr.rs, crates/tinyflows-drivers/src/catalog/migrate.rs, crates/tinyflows/src/validate/node_config.rs, crates/tinyflows-module/tests/fixtures/storage/cron-job-v0.8.28.json, crates/tinyflows-drivers/src/schedule/runs_tests.rs, crates/tinyflows-module/src/catalog_documents_tests.rs, crates/tinyflows-module/tests/fixtures/storage/generators/generate_v0.8.28.rs, crates/tinyflows-copilot/src/tools/draft_edit.rs, crates/tinyflows-module/tests/fixtures/storage/generators/generate_v0.8.8.rs, crates/tinyflows-catalog/src/build_registry.rs, crates/tinyflows-module/src/catalog_service_tests.rs, crates/tinyflows/src/nodes/integration/schema.rs, crates/tinyflows-drivers/src/schedule/codec.rs, crates/tinyflows-module/tests/fixtures/storage/cron-job-v0.8.8.json, crates/tinyflows/src/nodes/control_flow/dedup_settle.rs, crates/tinyflows-drivers/src/storage/kv_import_tests.rs, crates/tinyflows-module/src/catalog_migrations.rs, crates/tinyflows-module/src/schedule_documents.rs, crates/tinyflows-module/src/schedule_service_tests.rs, crates/tinyflows-module/src/catalog_documents.rs, crates/tinyflows-module/src/schedule_store.rs, crates/tinyflows-module/src/schedule_store_tests.rs, crates/tinyflows-module/tests/support/document_callbacks.rs, crates/tinyflows-adaptive/src/drivers/vault_tests.rs, crates/tinyflows-drivers/src/schedule/jobs.rs, crates/tinyflows-drivers/src/schedule/mod.rs, crates/tinyflows-module/src/run_manager_tests.rs, crates/tinyflows-drivers/src/schedule/claims_tests.rs, crates/tinyflows-drivers/src/schedule/runs.rs, crates/tinyflows-drivers/src/checkpoint_layout_tests.rs, crates/tinyflows-module/src/schedule_manual_worker_service_tests.rs, crates/tinyflows/tests/interception_e2e_tests.rs, crates/tinyflows-drivers/src/schedule/import.rs, crates/tinyflows-drivers/src/schedule/import_tests.rs, crates/tinyflows-catalog/src/import/n8n/node_mapping.rs, crates/tinyflows-drivers/src/catalog/mod.rs, crates/tinyflows-module/src/schedule_members_tests.rs, crates/tinyflows/src/migrate.rs, crates/tinyflows-adaptive/src/drivers/ledger_tests.rs, crates/tinyflows-drivers/src/catalog/runs_recovery_lease_tests.rs, crates/tinyflows-drivers/src/catalog/runs_replace_tests.rs, crates/tinyflows-module/src/catalog_service_migration_tests.rs, crates/tinyflows-module/src/run_manager/dedup_settlement_tests.rs, crates/tinyflows-module/src/run_manager_actor_recovery_tests.rs, crates/tinyflows-module/tests/module_artifact_tests.rs, crates/tinyflows-module/tests/support/manual_worker_artifact_tests.rs, crates/tinyflows-adaptive/tests/driver/driver_part_01_tests.rs, crates/tinyflows-adaptive/tests/support/driver_store.rs, crates/tinyflows-drivers/src/schedule/removal_claims_tests.rs, crates/tinyflows-module/src/catalog_legacy_batch.rs, crates/tinyflows-schedule/src/validation.rs, crates/tinyflows-drivers/src/store/import.rs, crates/tinyflows-drivers/src/store/import_tests.rs, crates/tinyflows-drivers/src/catalog/import.rs, crates/tinyflows-drivers/src/checkpoint.rs, crates/tinyflows-drivers/src/checkpoint_import_tests.rs, crates/tinyflows-drivers/src/schedule/mod_tests.rs, crates/tinyflows-drivers/src/store/proposals_tests.rs, crates/tinyflows-module/src/caps_tests/scope_tests.rs, crates/tinyflows-module/src/schedule_clock_tests.rs, crates/tinyflows-module/src/schedule_manual_worker_lifecycle_service_tests.rs, crates/tinyflows/src/caps/host/script_tests/script_tests_part_01_tests.rs, crates/tinyflows-adaptive/src/drivers/ledger/mod.rs, crates/tinyflows-drivers/src/catalog/definitions_tests.rs, crates/tinyflows-module/src/catalog_legacy_import.rs, CLAUDE.md, crates/tinyflows-drivers/src/catalog/revisions_gap_tests.rs, crates/tinyflows-drivers/src/schedule/claims_compaction_tests.rs, crates/tinyflows-drivers/src/state_store_tests.rs, crates/tinyflows-drivers/src/store/locks_tests.rs, crates/tinyflows-drivers/src/store/mod_tests.rs, crates/tinyflows-drivers/src/store/notes_tests.rs, crates/tinyflows-drivers/src/store/runs_tests.rs, crates/tinyflows-module/tests/run_artifact/support.rs, crates/tinyflows-module/tests/support/catalog_legacy_import_artifact_tests.rs, crates/tinyflows-module/tests/support/scheduler_stop_artifact_tests.rs, crates/tinyflows-bus/src/schedule/mod.rs, crates/tinyflows-drivers/src/catalog/drafts_tests.rs, crates/tinyflows-drivers/src/catalog/kv_tests.rs, crates/tinyflows-drivers/src/catalog/runs_lifecycle_tests.rs, crates/tinyflows-drivers/src/schedule/claim_removal_tests.rs, crates/tinyflows-drivers/src/schedule/claims_safety_tests.rs, crates/tinyflows-drivers/src/schedule/manual_claim_tests.rs, crates/tinyflows-drivers/src/store/concurrency_tests.rs, crates/tinyflows-drivers/src/store/history_tests.rs, crates/tinyflows-module/src/lib.rs, crates/tinyflows-schedule/src/posix_weekday.rs
  • Lane summary: Reviewed 8 of 134 files — 126 not reviewed. Reviewed 8 files; 0 findings. 126 files were omitted: not selected by the large-review budget. 7 files were not security-reviewed: crates/tinyflows-adaptive/README.md (prose or tabular data), crates/tinyflows-adaptive/docs/api.md (prose or tabular data), crates/tinyflows-drivers/README.md (prose or tabular data), crates/tinyflows-module/README.md (prose or tabular data), crates/tinyflows-module/tests/fixtures/storage/README.md (prose or tabular data), and 2 more.

tests

  • Conclusion: Success
  • Scope reviewed: all assigned evidence
  • Lane summary: The migration runner now writes body `created_ms` fields and relies on `TargetRecord::expires_ms`/`preserve_expiry_from` so a module document port never has to set host-only metadata; the changed tests pin the new contract (body creation time in `migrate_tests`, `dedup_ranks_migrated_jobs_by_their_body_creation_time`, `a_claimed_run_accepts_a_migrated_jobs_body_creation_time`, `editing_a_migrated_job_keeps_its_body_creation_identity`, and the module bridge tests asserting `created_ms` is refused before the callback). One defect stands out: the new CI job adds `dtolnay/rust-toolchain@1.88.0` as an unpinned third-party action, and a second is that the previously enforced schedule-read importer build/test/feature-boundary checks were deleted with no replacement gating the new helper's engine isolation as a required check. _The code index is behind this pull request (indexed at `ca20f759c38b`), so retrieved context may be out of date._

commits

  • Conclusion: Success
  • Scope reviewed: all assigned evidence
  • Positive: The commits lane is Answered and reports no sensitive content in committed files.
  • Lane summary: No sensitive content in committed files. _The code index is behind this pull request (indexed at `ca20f759c38b`), so retrieved context may be out of date._

description

  • Conclusion: Success
  • Scope reviewed: all assigned evidence
  • Lane summary: This revision matches its description: the import crate is retired, a new private `tinyflows-storage` helper sits on the public TSD v2.1.0 ports, all stores and the module's migration entry points move off `tinystoragedrivers-core`, imported cron jobs now carry `created_ms` in the body (host-only metadata is rejected by the module ports), MSRV rises to 1.88 with a matching CI job, and the incidental Clippy collapses and FTS module splits are called out. I found nothing in the diff that breaks for a reachable input. _The code index is behind this pull request (indexed at `ca20f759c38b`), so retrieved context may be out of date._
Evidence and run details
  • Models: ladder/vectors-oai3, deepseek-v4.1-flash
  • Spend: $0.004916
  • Tokens: 1388441 input · 10725 output · 247808 cached · 791 embedding
  • Updated: 2026-10-22T15:41:34Z
  • Continuity: summary cache chain restarted at the storage ceiling.
Head State Pass summary
0d1a349d3a4e incomplete 0 active finding(s), 0 resolved finding(s) (at 2026-10-22T14:49:28Z)
888858ac0410 incomplete 0 active finding(s), 0 resolved finding(s) (at 2026-10-22T15:16:20Z)
104f6da9a367 incomplete 0 active finding(s), 0 resolved finding(s) (at 2026-10-22T15:41:34Z)

tinysweeper 0.1.2

Flatten the nested if blocks in commit and park_for_retry into chained
let-expressions, which is the idiomatic form on the current Rust edition.
The lockfile also pins uuid and getrandom back to versions compatible with
the rest of the dependency graph.

Auto-committed-on: cuttlefish
Co-authored-by: Medulla <medulla@tinyhumans.ai>

@tinysweeper tinysweeper Bot left a comment

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

tinysweeper could not complete coverage (138 unanswered item(s)), so this is not an approval.

Diagnostics

Total spend: $0.0156

@tinysweeper tinysweeper Bot added the priority: p3 Whenever. Cosmetic, a nicety, or a cleanup with no user visible effect. label Oct 22, 2026
senamakel and others added 2 commits October 22, 2026 14:52
… submodules

The acquire_with implementation and the schema migration machinery were
extracted from leases.rs and schema.rs into dedicated submodules, leaving
the parent files to re-export them. This keeps the large, self-contained
routines in their own files without changing any behaviour.

Auto-committed-on: cuttlefish
Co-authored-by: Medulla <medulla@tinyhumans.ai>
Dropped imports that are no longer referenced in the schema module and
its migrations, and corrected the import list to pull in the types
actually used. Also removed a stray blank line in the lease acquisition
code.

Auto-committed-on: cuttlefish
Co-authored-by: Medulla <medulla@tinyhumans.ai>

@chatgpt-codex-connector chatgpt-codex-connector Bot left a comment

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

💡 Codex Review

Here are some automated review suggestions for this pull request.

Reviewed commit: e5d517097f

ℹ️ About Codex in GitHub

Your team has set up Codex to review pull requests in this repo. Reviews are triggered when you

  • Open a pull request for review
  • Mark a draft as ready
  • Comment "@codex review".

If Codex has suggestions, it will comment; otherwise it will react with 👍.

Codex can also answer questions or update the PR. Try commenting "@codex address that feedback".

Comment thread crates/tinyflows-drivers/src/schedule/codec.rs
senamakel and others added 2 commits October 22, 2026 14:54
Add a test asserting that updating a job which carries an imported
created_ms timestamp preserves that creation identity, so a run recorded
against the original timestamp is still accepted after the edit.

Auto-committed-on: cuttlefish
Co-authored-by: Medulla <medulla@tinyhumans.ai>
The updated job document now carries over the created_ms field from the previous document, so the original creation timestamp is not lost when a cron job is updated.

Auto-committed-on: cuttlefish
Co-authored-by: Medulla <medulla@tinyhumans.ai>

@chatgpt-codex-connector chatgpt-codex-connector Bot left a comment

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

💡 Codex Review

Here are some automated review suggestions for this pull request.

Reviewed commit: 93162c1f89

ℹ️ About Codex in GitHub

Your team has set up Codex to review pull requests in this repo. Reviews are triggered when you

  • Open a pull request for review
  • Mark a draft as ready
  • Comment "@codex review".

If Codex has suggestions, it will comment; otherwise it will react with 👍.

Codex can also answer questions or update the PR. Try commenting "@codex address that feedback".

Comment thread crates/tinyflows-drivers/src/checkpoint_tests.rs
Comment thread crates/tinyflows/src/nodes/integration/agent_prompt.rs Outdated
Comment thread crates/tinyflows-drivers/src/schedule/runs_tests.rs Outdated
senamakel and others added 5 commits October 22, 2026 15:12
…ed modules

Move lineage, migrated job identity, and JSON extraction tests into their own files and register them as separate test modules, keeping the existing suites focused and making the new coverage easier to find.

Auto-committed-on: cuttlefish
Co-authored-by: Medulla <medulla@tinyhumans.ai>
Auto-committed-on: cuttlefish
Co-authored-by: Medulla <medulla@tinyhumans.ai>
Update the vendored tinybus submodule to a newer commit.

Auto-committed-on: cuttlefish
Co-authored-by: Medulla <medulla@tinyhumans.ai>
Update the tinybus and tinybus-module git revisions in the workspace patch
section and the storage crate's dev-dependency to 2b2ac165, refreshing the
lockfile accordingly. This picks up the newer upstream commit while keeping
the unpublished module APIs pinned to a source available in non-recursive
clones.

Auto-committed-on: cuttlefish
Co-authored-by: Medulla <medulla@tinyhumans.ai>
Move the tinybus and tinybus-module patch entries to revision 0de2d283, which
collapses the duplicate tinybus entries in the lockfile and drops the
windows-sys 0.61.2 and getrandom 0.4.3 dependencies in favour of older
versions. The storage crate's dev-dependency is repinned to match.

Auto-committed-on: cuttlefish
Co-authored-by: Medulla <medulla@tinyhumans.ai>
@tinysweeper tinysweeper Bot added priority: p2 Soon. Real but survivable — a rough edge, a gap, a thing that will bite later. and removed priority: p3 Whenever. Cosmetic, a nicety, or a cleanup with no user visible effect. labels Oct 22, 2026
@senamakel
senamakel merged commit 99fd391 into main Oct 22, 2026
11 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

priority: p2 Soon. Real but survivable — a rough edge, a gap, a thing that will bite later.

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[tsd-primitive] tinyflows on tsd types+api; own models; tinyflows-import out

1 participant