Skip to content

Commit a573d9f

Browse files
committed
Change check for SequencerStartUpModule
1 parent dd79529 commit a573d9f

File tree

2 files changed

+5
-15
lines changed

2 files changed

+5
-15
lines changed

packages/sequencer/src/sequencer/executor/Sequencer.ts

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -86,6 +86,9 @@ export class Sequencer<Modules extends SequencerModulesRecord>
8686
// eslint-disable-next-line no-await-in-loop
8787
await sequencerModule.start();
8888
}
89+
if (!moduleClassNames.includes("SequencerStartupModule")) {
90+
log.warn("SequencerStartupModule is not defined.");
91+
}
8992
}
9093

9194
public async close() {

packages/sequencer/src/worker/worker/WorkerReadyModule.ts

Lines changed: 2 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,6 @@
11
import { injectable } from "tsyringe";
22
import { injectOptional } from "@proto-kit/common";
33

4-
import { SequencerStartupModule } from "../../sequencer/SequencerStartupModule";
5-
64
import { LocalTaskWorkerModule } from "./LocalTaskWorkerModule";
75

86
/**
@@ -15,19 +13,8 @@ export class WorkerReadyModule {
1513
@injectOptional("LocalTaskWorkerModule")
1614
private readonly localTaskWorkerModule:
1715
| LocalTaskWorkerModule<any>
18-
| undefined,
19-
@injectOptional("SequencerStartupModule")
20-
private readonly sequencerStartupModule: SequencerStartupModule | undefined
21-
) {
22-
if (
23-
localTaskWorkerModule !== undefined &&
24-
sequencerStartupModule === undefined
25-
) {
26-
throw new Error(
27-
"The LocalTaskWorkerModule requires the SequencerStartupModule to be defined as well."
28-
);
29-
}
30-
}
16+
| undefined
17+
) {}
3118

3219
// eslint-disable-next-line consistent-return
3320
public async waitForReady() {

0 commit comments

Comments
 (0)