aboutsummaryrefslogtreecommitdiffstats
path: root/packages
diff options
context:
space:
mode:
Diffstat (limited to 'packages')
-rw-r--r--packages/plugins-queue-restate/src/idProvider.ts3
-rw-r--r--packages/plugins-queue-restate/src/semaphore.ts3
2 files changed, 6 insertions, 0 deletions
diff --git a/packages/plugins-queue-restate/src/idProvider.ts b/packages/plugins-queue-restate/src/idProvider.ts
index 72ebc860..ee85f46f 100644
--- a/packages/plugins-queue-restate/src/idProvider.ts
+++ b/packages/plugins-queue-restate/src/idProvider.ts
@@ -9,6 +9,9 @@ export const idProvider = object({
return state;
},
},
+ options: {
+ ingressPrivate: true,
+ },
});
export async function genId(ctx: Context) {
diff --git a/packages/plugins-queue-restate/src/semaphore.ts b/packages/plugins-queue-restate/src/semaphore.ts
index 253dbe33..eb78f6b6 100644
--- a/packages/plugins-queue-restate/src/semaphore.ts
+++ b/packages/plugins-queue-restate/src/semaphore.ts
@@ -41,6 +41,9 @@ export const semaphore = object({
setState(ctx, state);
},
},
+ options: {
+ ingressPrivate: true,
+ },
});
function selectAndPopItem(items: QueueItem[]): QueueItem {