chore: update @WorkGlow packages to version 0.0.125

- Bumped versions for several @WorkGlow packages, including cli, ai, ai-provider, job-queue, knowledge-base, sqlite, and storage to 0.0.125.
- Updated peer dependencies and imports to ensure compatibility across the updated packages.
- Refactored code to utilize the new `workglow` package instead of individual scoped packages.

Author: sroussey

.vscode/settings.json

@@ -21,10 +21,6 @@
     "**/bun.lock": true,
     "**/*.tsbuildinfo": true
   },
-  "editor.codeActionsOnSave": {
-    "source.fixAll.eslint": "explicit"
-  },
-  "eslint.codeActionsOnSave.rules": null,
   "explorer.autoRevealExclude": {
     "data-out/**": true,
     "data-in/**": true
@@ -45,5 +41,9 @@
   "js/ts.implicitProjectConfig.target": "ESNext",
   "[xml]": {
     "editor.defaultFormatter": "DotJoshJohnson.xml"
+  },
+  "editor.codeActionsOnSave": {
+    "source.fixAll.eslint": "explicit",
+    "source.organizeImports": "explicit"
   }
 }

CLAUDE.md

@@ -33,7 +33,7 @@ The CLI entrypoint is `src/sec.ts` and uses Commander for subcommands (e.g., `./
 
 ### Dependency Injection
 
-Uses `@workglow/util`'s `globalServiceRegistry` with typed tokens. Production uses `SqliteTabularRepository`, tests use `InMemoryTabularRepository`. Call `resetDependencyInjectionsForTesting()` from `src/config/TestingDI.ts` in test setup.
+Uses the `workglow` package’s `globalServiceRegistry` with typed tokens. Production uses `SqliteTabularRepository`, tests use `InMemoryTabularRepository`. Call `resetDependencyInjectionsForTesting()` from `src/config/TestingDI.ts` in test setup.
 
 ### Schema Pattern
 

bun.lock

@@ -23,22 +23,16 @@
     "@modelcontextprotocol/sdk": "^1.27.1",
     "@sroussey/parse-address": "^2.4.2",
     "@sroussey/parse-full-name": "^2.0.0",
-    "@workglow/cli": "0.0.124",
-    "@workglow/knowledge-base": "0.0.124",
-    "@workglow/job-queue": "0.0.124",
-    "@workglow/sqlite": "0.0.124",
-    "@workglow/storage": "0.0.124",
-    "@workglow/task-graph": "0.0.124",
-    "@workglow/tasks": "0.0.124",
-    "@workglow/util": "0.0.124",
+    "workglow": "0.0.125",
+    "@workglow/cli": "0.0.125",
     "awesome-phonenumber": "^7.8.0",
     "cheerio": "^1.2.0",
     "cheerio-json-mapper": "^1.0.4",
     "commander": "^14.0.3",
     "compromise": "^14.15.0",
     "concurrently": "^9.2.1",
     "csv-parse": "^6.2.1",
-    "fast-xml-parser": "^5.5.8",
+    "fast-xml-parser": "^5.5.9",
     "html-entities": "^2.6.0",
     "pdf2json": "^3.2.2",
     "pg": "^8.20.0",

package.json

@@ -10,33 +10,29 @@ interface PackageJson {
 }
 
 /**
- * Extract all @workglow/* packages from package.json
+ * Packages to link for local Workglow development (see package.json).
  */
-function getWorkglowPackages(packageJsonPath: string): string[] {
+function getWorkglowLinkTargets(packageJsonPath: string): string[] {
   const packageJsonContent = fs.readFileSync(packageJsonPath, "utf8");
   const packageJson: PackageJson = JSON.parse(packageJsonContent);
 
   const packages: string[] = [];
 
-  // Check dependencies
-  if (packageJson.dependencies) {
-    for (const packageName of Object.keys(packageJson.dependencies)) {
-      if (packageName.startsWith("@workglow/")) {
-        packages.push(packageName);
-      }
+  const consider = (deps: Record<string, string> | undefined): void => {
+    if (!deps) {
+      return;
     }
-  }
-
-  // Check devDependencies
-  if (packageJson.devDependencies) {
-    for (const packageName of Object.keys(packageJson.devDependencies)) {
-      if (packageName.startsWith("@workglow/")) {
-        packages.push(packageName);
+    for (const name of Object.keys(deps)) {
+      if (name === "workglow" || name.startsWith("@workglow/")) {
+        packages.push(name);
       }
     }
-  }
+  };
+
+  consider(packageJson.dependencies);
+  consider(packageJson.devDependencies);
 
-  return packages.sort();
+  return [...new Set(packages)].sort();
 }
 
 async function main(): Promise<void> {
@@ -47,14 +43,14 @@ async function main(): Promise<void> {
     process.exit(1);
   }
 
-  const packages = getWorkglowPackages(packageJsonPath);
+  const packages = getWorkglowLinkTargets(packageJsonPath);
 
   if (packages.length === 0) {
-    console.log("No @workglow/* packages found in package.json");
+    console.log('No "workglow" or @workglow/* packages found in package.json');
     return;
   }
 
-  console.log(`Found ${packages.length} @workglow/* package(s) to link:`);
+  console.log(`Found ${packages.length} Workglow package(s) to link:`);
   packages.forEach((pkg) => console.log(`  - ${pkg}`));
   console.log();
 
@@ -66,7 +62,7 @@ async function main(): Promise<void> {
   }
 
   try {
-    const result = await $`bun link ${packages}`;
+    await $`bun link ${packages}`;
     console.log(`✅ Successfully linked ${packages.length} package(s)`);
   } catch (error) {
     console.error(

scripts/link-workglow-packages.ts

@@ -1,12 +1,18 @@
-import { runTasks, runWorkflow } from "@workglow/cli";
-import { pipe } from "@workglow/task-graph";
+/**
+ * @license
+ * Copyright 2026 Steven Roussey <sroussey@gmail.com>
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+import { withCli } from "@workglow/cli";
 import type { Command } from "commander";
+import { pipe, type ITask, type IWorkflow } from "workglow";
 import { BootstrapDownloadTask } from "../../task/bootstrap/BootstrapDownloadTask";
-import { BootstrapSubmissionsTask } from "../../task/submissions/BootstrapSubmissionsTask";
-import { BootstrapCompanyFactsTask } from "../../task/facts/BootstrapCompanyFactsTask";
 import { FetchAllCikNamesTask } from "../../task/ciknames/FetchAllCikNamesTask";
 import { StoreCikNamesTask } from "../../task/ciknames/StoreCikNamesTask";
+import { BootstrapCompanyFactsTask } from "../../task/facts/BootstrapCompanyFactsTask";
 import { UpdateAllFormsTask } from "../../task/forms/UpdateAllFormsTask";
+import { BootstrapSubmissionsTask } from "../../task/submissions/BootstrapSubmissionsTask";
 import { runCommand } from "../runCommand";
 
 const BULK_DOWNLOADS = {
@@ -33,22 +39,30 @@ export function addBootstrapCommands(program: Command): void {
     .action(async (options) => {
       await runCommand(
         async () => {
+          const force = options.force ?? false;
+          const tasks: ITask[] = [];
           if (!options.skipDownload) {
-            for (const config of Object.values(BULK_DOWNLOADS)) {
-              const task = new BootstrapDownloadTask(config);
-              await runTasks(task);
-            }
+            tasks.push(
+              ...Object.values(BULK_DOWNLOADS).map((config) => new BootstrapDownloadTask(config))
+            );
           }
 
           if (!options.skipIngest) {
-            const cikWf = pipe([new FetchAllCikNamesTask(), new StoreCikNamesTask()]);
-            await runWorkflow(cikWf);
-            await runTasks(new BootstrapSubmissionsTask({ force: options.force }));
-            await runTasks(new BootstrapCompanyFactsTask({ force: options.force }));
+            tasks.push(
+              new FetchAllCikNamesTask(),
+              new StoreCikNamesTask(),
+              new BootstrapSubmissionsTask({ force }),
+              new BootstrapCompanyFactsTask({ force })
+            );
           }
 
           if (!options.skipForms) {
-            await runTasks(new UpdateAllFormsTask({ form: ["D", "C"], force: options.force }));
+            tasks.push(new UpdateAllFormsTask({ form: ["D", "C"], force }));
+          }
+
+          if (tasks.length > 0) {
+            const wf = (pipe as (tasks: ITask[]) => IWorkflow)(tasks);
+            await withCli(wf).run();
           }
         },
         { force: options.force }
@@ -62,14 +76,12 @@ export function addBootstrapCommands(program: Command): void {
       await runCommand(async () => {
         if (type === "ciks") {
           const wf = pipe([new FetchAllCikNamesTask(), new StoreCikNamesTask()]);
-          await runWorkflow(wf);
+          await withCli(wf).run();
           return;
         }
 
         if (type !== "submissions" && type !== "facts" && type !== "all") {
-          throw new Error(
-            `Invalid type "${type}". Must be submissions, facts, ciks, or all.`
-          );
+          throw new Error(`Invalid type "${type}". Must be submissions, facts, ciks, or all.`);
         }
 
         const types: (keyof typeof BULK_DOWNLOADS)[] =
@@ -78,7 +90,7 @@ export function addBootstrapCommands(program: Command): void {
         for (const t of types) {
           const config = BULK_DOWNLOADS[t];
           const task = new BootstrapDownloadTask(config);
-          await runTasks(task);
+          await withCli(task).run();
         }
       });
     });
@@ -94,15 +106,15 @@ export function addBootstrapCommands(program: Command): void {
 
           if (target === "cik-names" || target === "all") {
             const wf = pipe([new FetchAllCikNamesTask(), new StoreCikNamesTask()]);
-            await runWorkflow(wf);
+            await withCli(wf).run();
           }
 
           if (target === "submissions" || target === "all") {
-            await runTasks(new BootstrapSubmissionsTask({ force: options.force }));
+            await withCli(new BootstrapSubmissionsTask({ force: options.force })).run();
           }
 
           if (target === "facts" || target === "all") {
-            await runTasks(new BootstrapCompanyFactsTask({ force: options.force }));
+            await withCli(new BootstrapCompanyFactsTask({ force: options.force })).run();
           }
 
           if (

src/cli/groups/bootstrap.ts

@@ -1,19 +1,17 @@
-import { runTasks, runWorkflow } from "@workglow/cli";
-import { Workflow } from "@workglow/task-graph";
+import { withCli } from "@workglow/cli";
 import type { Command } from "commander";
-import { FetchSubmissionsTask } from "../../task/submissions/FetchSubmissionsTask";
-import { StoreSubmissionsTask } from "../../task/submissions/StoreSubmissionsTask";
+import { Workflow } from "workglow";
 import { FetchCompanyFactsTask } from "../../task/facts/FetchCompanyFactsTask";
 import { StoreCompanyFactsTask } from "../../task/facts/StoreCompanyFactsTask";
 import { FetchAndStoreFormsTask } from "../../task/forms/FetchAndStoreFormsTask";
 import { ProcessAccessionDocFormTask } from "../../task/forms/ProcessAccessionDocFormTask";
+import { FetchSubmissionsTask } from "../../task/submissions/FetchSubmissionsTask";
+import { StoreSubmissionsTask } from "../../task/submissions/StoreSubmissionsTask";
 import { secDate } from "../../util/parseDate";
 import { runCommand } from "../runCommand";
 
 export function addFetchCommands(program: Command): void {
-  const fetch = program
-    .command("fetch")
-    .description("Fetch data for a single entity");
+  const fetch = program.command("fetch").description("Fetch data for a single entity");
 
   fetch
     .command("submissions <cik>")
@@ -29,7 +27,7 @@ export function addFetchCommands(program: Command): void {
           }),
           new StoreSubmissionsTask()
         );
-        await runWorkflow(wf);
+        await withCli(wf).run();
       });
     });
 
@@ -47,7 +45,7 @@ export function addFetchCommands(program: Command): void {
           }),
           new StoreCompanyFactsTask()
         );
-        await runWorkflow(wf);
+        await withCli(wf).run();
       });
     });
 
@@ -61,7 +59,7 @@ export function addFetchCommands(program: Command): void {
           form,
           docid: accession,
         });
-        await runTasks(task);
+        await withCli(task).run();
       });
     });
 
@@ -74,7 +72,7 @@ export function addFetchCommands(program: Command): void {
           accessionNumber: accession,
           fileName: filename,
         });
-        await runTasks(task);
+        await withCli(task).run();
       });
     });
 }

src/cli/groups/fetch.ts

@@ -1,13 +1,13 @@
 import type { Command } from "commander";
-import { createInterface } from "readline";
 import { existsSync, mkdirSync, writeFileSync } from "fs";
-import { resolve } from "path";
 import { homedir } from "os";
-import { globalServiceRegistry } from "@workglow/util";
+import { resolve } from "path";
+import { createInterface } from "readline";
+import { globalServiceRegistry } from "workglow";
 import { setupAllDatabases } from "../../config/setupAllDatabases";
+import { SEC_DRY_RUN } from "../../config/tokens";
 import { parseGlobalOptions } from "../GlobalOptions";
 import { runCommand } from "../runCommand";
-import { SEC_DRY_RUN } from "../../config/tokens";
 
 export interface InitConfig {
   readonly dbType: "sqlite" | "postgres";
@@ -49,10 +49,7 @@ export function buildEnvConfig(config: InitConfig): string {
   return lines.join("\n") + "\n";
 }
 
-function prompt(
-  rl: ReturnType<typeof createInterface>,
-  question: string
-): Promise<string> {
+function prompt(rl: ReturnType<typeof createInterface>, question: string): Promise<string> {
   return new Promise((resolve) => {
     rl.question(question, (answer) => {
       resolve(answer.trim());
@@ -81,39 +78,31 @@ export function addInitCommand(parent: Command): void {
           const defaultDbFolder = resolve(homedir(), ".sec/data");
           const defaultRawFolder = resolve(homedir(), ".sec/raw");
 
-          const dbTypeAnswer = await prompt(
-            rl,
-            "Database type (sqlite or postgres) [sqlite]: "
-          );
+          const dbTypeAnswer = await prompt(rl, "Database type (sqlite or postgres) [sqlite]: ");
           const dbType = dbTypeAnswer === "postgres" ? "postgres" : "sqlite";
 
           const dbFolder =
             (await prompt(rl, `Database folder [${defaultDbFolder}]: `)) || defaultDbFolder;
 
-          const dbName = (await prompt(rl, 'Database name [edgar]: ')) || "edgar";
+          const dbName = (await prompt(rl, "Database name [edgar]: ")) || "edgar";
 
           const rawDataFolder =
             (await prompt(rl, `Raw data folder [${defaultRawFolder}]: `)) || defaultRawFolder;
 
           let pgFields: Partial<InitConfig> = {};
 
           if (dbType === "postgres") {
-            const useUrl = await prompt(
-              rl,
-              "Use a connection string? (y/n) [n]: "
-            );
+            const useUrl = await prompt(rl, "Use a connection string? (y/n) [n]: ");
 
             if (useUrl.toLowerCase() === "y") {
               const pgUrl = await prompt(rl, "PostgreSQL connection string: ");
               pgFields = { pgUrl };
             } else {
-              const pgHost =
-                (await prompt(rl, "PostgreSQL host [localhost]: ")) || "localhost";
+              const pgHost = (await prompt(rl, "PostgreSQL host [localhost]: ")) || "localhost";
               const pgPort = (await prompt(rl, "PostgreSQL port [5432]: ")) || "5432";
               const pgUser = await prompt(rl, "PostgreSQL user: ");
               const pgPassword = await prompt(rl, "PostgreSQL password: ");
-              const pgDatabase =
-                (await prompt(rl, "PostgreSQL database [edgar]: ")) || "edgar";
+              const pgDatabase = (await prompt(rl, "PostgreSQL database [edgar]: ")) || "edgar";
 
               pgFields = { pgHost, pgPort, pgUser, pgPassword, pgDatabase };
             }