mirror/hatchet
1
0
Fork 0
mirror of https://github.com/hatchet-dev/hatchet.git synced 2026-01-07 09:19:41 -06:00
Code Issues Packages Projects Releases Wiki Activity

fix: serial-registration (#1574)

Browse Source 
* fix: serial-registration

* fix case

* release ver
This commit is contained in:
Gabe Ruttner
2025-04-18 10:54:22 -04:00
committed by GitHub
parent 0ec8f830b9
commit 4e42beecc6
2 changed files with 16 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
sdks/typescript/package.json
View File

@@ -1,6 +1,6 @@
{
"name": "@hatchet-dev/typescript-sdk",
"version": "1.3.1",
"version": "1.3.2",
"description": "Background task orchestration & visibility for developers",
"types": "dist/index.d.ts",
"files": [

34
sdks/typescript/src/v1/client/worker.ts
View File

@@ -87,29 +87,25 @@ export class Worker {
* @returns Array of registered workflow promises
*/
async registerWorkflows(workflows?: Array<BaseWorkflowDeclaration<any, any> | V0Workflow>) {
return Promise.all(
workflows?.map(async (wf) => {
if (wf instanceof BaseWorkflowDeclaration) {
// TODO check if tenant is V1
const register = this.nonDurable.registerWorkflowV1(wf);
for (const wf of workflows || []) {
if (wf instanceof BaseWorkflowDeclaration) {
// TODO check if tenant is V1
await this.nonDurable.registerWorkflowV1(wf);
if (wf.definition._durableTasks.length > 0) {
if (!this.durable) {
this.durable = await this._v0.worker(`${this.name}-durable`, {
...this.config,
maxRuns: this.config.durableSlots || DEFAULT_DURABLE_SLOTS,
});
}
this.durable.registerDurableActionsV1(wf.definition);
if (wf.definition._durableTasks.length > 0) {
if (!this.durable) {
this.durable = await this._v0.worker(`${this.name}-durable`, {
...this.config,
maxRuns: this.config.durableSlots || DEFAULT_DURABLE_SLOTS,
});
}
return register;
this.durable.registerDurableActionsV1(wf.definition);
}
} else {
// fallback to v0 client for backwards compatibility
return this.nonDurable.registerWorkflow(wf);
}) || []
);
await this.nonDurable.registerWorkflow(wf);
}
}
}
/**