diff --git a/.scripts/copy-shared-files.mjs b/.scripts/copy-shared-files.mjs index 42c2a749..b559df11 100644 --- a/.scripts/copy-shared-files.mjs +++ b/.scripts/copy-shared-files.mjs @@ -49,7 +49,6 @@ const ESLINTRC_EXCLUDE = [ 'protobufs', 'food-delivery', 'nestjs-exchange-rates', - 'workflow-streams', ]; const ESLINTIGNORE_EXCLUDE = [ 'production', diff --git a/workflow-streams/.eslintrc.js b/workflow-streams/.eslintrc.js index b35cad39..b8251a06 100644 --- a/workflow-streams/.eslintrc.js +++ b/workflow-streams/.eslintrc.js @@ -36,7 +36,7 @@ module.exports = { }, overrides: [ { - files: ['src/workflows.ts', 'src/workflows-*.ts', 'src/workflows/*.ts', 'src/llm-workflows.ts'], + files: ['src/workflows.ts', 'src/workflows-*.ts', 'src/workflows/*.ts'], rules: { 'no-restricted-imports': [ 'error', diff --git a/workflow-streams/src/llm-worker.ts b/workflow-streams/src/llm-worker.ts index d9f34cb0..77148dbe 100644 --- a/workflow-streams/src/llm-worker.ts +++ b/workflow-streams/src/llm-worker.ts @@ -23,7 +23,7 @@ async function run() { connection, namespace: 'default', taskQueue: LLM_TASK_QUEUE, - workflowsPath: require.resolve('./llm-workflows'), + workflowsPath: require.resolve('./workflows-llm'), activities, }); await worker.run(); diff --git a/workflow-streams/src/run-llm.ts b/workflow-streams/src/run-llm.ts index 485f5ebf..93e2943e 100644 --- a/workflow-streams/src/run-llm.ts +++ b/workflow-streams/src/run-llm.ts @@ -31,7 +31,7 @@ import { type TextComplete, type TextDelta, } from './llm-shared'; -import { llmStreaming } from './llm-workflows'; +import { llmStreaming } from './workflows-llm'; // Long enough that you can comfortably kill the worker mid-stream and watch // the retry render. Adjust to taste. diff --git a/workflow-streams/src/test/workflows.test.ts b/workflow-streams/src/test/workflows.test.ts index e81cfac4..a2d5fdd6 100644 --- a/workflow-streams/src/test/workflows.test.ts +++ b/workflow-streams/src/test/workflows.test.ts @@ -10,7 +10,7 @@ import type * as activities from '../activities'; import type * as llmActivities from '../llm-activities'; import { TOPIC_PROGRESS, TOPIC_STATUS, type StatusEvent } from '../shared'; import { closeSignal, hub, order, pipeline, ticker } from '../workflows'; -import { llmStreaming } from '../llm-workflows'; +import { llmStreaming } from '../workflows-llm'; // The unit tests below cover the workflow side only. The client subscribe path // needs a real server, so it is exercised by the integration test at the end. @@ -116,7 +116,7 @@ describe('workflow-streams workflows', function () { const worker = await Worker.create({ connection: env.nativeConnection, taskQueue, - workflowsPath: require.resolve('../llm-workflows'), + workflowsPath: require.resolve('../workflows-llm'), activities: mockActivities, }); const result = await worker.runUntil( diff --git a/workflow-streams/src/llm-workflows.ts b/workflow-streams/src/workflows-llm.ts similarity index 100% rename from workflow-streams/src/llm-workflows.ts rename to workflow-streams/src/workflows-llm.ts