diff --git a/package.json b/package.json
index f6a997a0..81ab81c7 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@reflex-platform/npm-core-sdk",
-  "version": "1.11.0-SNAPSHOT-250422150922",
+  "version": "1.11.0-SNAPSHOT-250423124303",
   "description": "npm libs from core model proto files",
   "homepage": "",
   "main": "index.ts",
diff --git a/shared.ts b/shared.ts
index 70935a0e..b912e2b6 100644
--- a/shared.ts
+++ b/shared.ts
@@ -1986,7 +1986,11 @@ export enum WorkflowTypeEnum {
     /**
      * @generated from protobuf enum value: UPGRADE_MODEL = 27;
      */
-    UPGRADE_MODEL = 27
+    UPGRADE_MODEL = 27,
+    /**
+     * @generated from protobuf enum value: SWEEP = 28;
+     */
+    SWEEP = 28
 }
 /**
  * @generated from protobuf enum api.ModuleWorkflowTypeEnum
diff --git a/workflow.client.ts b/workflow.client.ts
index 95527c0c..85f73328 100644
--- a/workflow.client.ts
+++ b/workflow.client.ts
@@ -4,6 +4,8 @@
 import type { RpcTransport } from "@protobuf-ts/runtime-rpc";
 import type { ServiceInfo } from "@protobuf-ts/runtime-rpc";
 import { WorkflowService } from "./workflow";
+import type { StartWorkflowSweepResult } from "./workflow";
+import type { StartWorkflowSweepRequest } from "./workflow";
 import type { StartWorkflowUpgradeModelResult } from "./workflow";
 import type { StartWorkflowUpgradeModelRequest } from "./workflow";
 import type { StartWorkflowAnonymizeDataResult } from "./workflow";
@@ -179,6 +181,10 @@ export interface IWorkflowServiceClient {
      * @generated from protobuf rpc: StartWorkflowUpgradeModel(api.StartWorkflowUpgradeModelRequest) returns (api.StartWorkflowUpgradeModelResult);
      */
     startWorkflowUpgradeModel(input: StartWorkflowUpgradeModelRequest, options?: RpcOptions): UnaryCall<StartWorkflowUpgradeModelRequest, StartWorkflowUpgradeModelResult>;
+    /**
+     * @generated from protobuf rpc: StartWorkflowSweep(api.StartWorkflowSweepRequest) returns (api.StartWorkflowSweepResult);
+     */
+    startWorkflowSweep(input: StartWorkflowSweepRequest, options?: RpcOptions): UnaryCall<StartWorkflowSweepRequest, StartWorkflowSweepResult>;
 }
 /**
  * @generated from protobuf service api.WorkflowService
@@ -385,4 +391,11 @@ export class WorkflowServiceClient implements IWorkflowServiceClient, ServiceInf
         const method = this.methods[27], opt = this._transport.mergeOptions(options);
         return stackIntercept<StartWorkflowUpgradeModelRequest, StartWorkflowUpgradeModelResult>("unary", this._transport, method, opt, input);
     }
+    /**
+     * @generated from protobuf rpc: StartWorkflowSweep(api.StartWorkflowSweepRequest) returns (api.StartWorkflowSweepResult);
+     */
+    startWorkflowSweep(input: StartWorkflowSweepRequest, options?: RpcOptions): UnaryCall<StartWorkflowSweepRequest, StartWorkflowSweepResult> {
+        const method = this.methods[28], opt = this._transport.mergeOptions(options);
+        return stackIntercept<StartWorkflowSweepRequest, StartWorkflowSweepResult>("unary", this._transport, method, opt, input);
+    }
 }
diff --git a/workflow.ts b/workflow.ts
index dc955348..ef209f13 100644
--- a/workflow.ts
+++ b/workflow.ts
@@ -806,6 +806,20 @@ export interface StartWorkflowUpgradeModelResult {
      */
     workflowExecution?: WorkflowExecutionResult;
 }
+/**
+ * @generated from protobuf message api.StartWorkflowSweepRequest
+ */
+export interface StartWorkflowSweepRequest {
+}
+/**
+ * @generated from protobuf message api.StartWorkflowSweepResult
+ */
+export interface StartWorkflowSweepResult {
+    /**
+     * @generated from protobuf field: api.WorkflowExecutionResult WorkflowExecution = 1 [json_name = "WorkflowExecution"];
+     */
+    workflowExecution?: WorkflowExecutionResult;
+}
 /**
  * @generated from protobuf enum api.WorkflowStatusEnum
  */
@@ -4071,6 +4085,90 @@ class StartWorkflowUpgradeModelResult$Type extends MessageType<StartWorkflowUpgr
  * @generated MessageType for protobuf message api.StartWorkflowUpgradeModelResult
  */
 export const StartWorkflowUpgradeModelResult = new StartWorkflowUpgradeModelResult$Type();
+// @generated message type with reflection information, may provide speed optimized methods
+class StartWorkflowSweepRequest$Type extends MessageType<StartWorkflowSweepRequest> {
+    constructor() {
+        super("api.StartWorkflowSweepRequest", [], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: {} } });
+    }
+    create(value?: PartialMessage<StartWorkflowSweepRequest>): StartWorkflowSweepRequest {
+        const message = globalThis.Object.create((this.messagePrototype!));
+        if (value !== undefined)
+            reflectionMergePartial<StartWorkflowSweepRequest>(this, message, value);
+        return message;
+    }
+    internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowSweepRequest): StartWorkflowSweepRequest {
+        let message = target ?? this.create(), end = reader.pos + length;
+        while (reader.pos < end) {
+            let [fieldNo, wireType] = reader.tag();
+            switch (fieldNo) {
+                default:
+                    let u = options.readUnknownField;
+                    if (u === "throw")
+                        throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
+                    let d = reader.skip(wireType);
+                    if (u !== false)
+                        (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
+            }
+        }
+        return message;
+    }
+    internalBinaryWrite(message: StartWorkflowSweepRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
+        let u = options.writeUnknownFields;
+        if (u !== false)
+            (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
+        return writer;
+    }
+}
+/**
+ * @generated MessageType for protobuf message api.StartWorkflowSweepRequest
+ */
+export const StartWorkflowSweepRequest = new StartWorkflowSweepRequest$Type();
+// @generated message type with reflection information, may provide speed optimized methods
+class StartWorkflowSweepResult$Type extends MessageType<StartWorkflowSweepResult> {
+    constructor() {
+        super("api.StartWorkflowSweepResult", [
+            { no: 1, name: "WorkflowExecution", kind: "message", jsonName: "WorkflowExecution", T: () => WorkflowExecutionResult }
+        ]);
+    }
+    create(value?: PartialMessage<StartWorkflowSweepResult>): StartWorkflowSweepResult {
+        const message = globalThis.Object.create((this.messagePrototype!));
+        if (value !== undefined)
+            reflectionMergePartial<StartWorkflowSweepResult>(this, message, value);
+        return message;
+    }
+    internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowSweepResult): StartWorkflowSweepResult {
+        let message = target ?? this.create(), end = reader.pos + length;
+        while (reader.pos < end) {
+            let [fieldNo, wireType] = reader.tag();
+            switch (fieldNo) {
+                case /* api.WorkflowExecutionResult WorkflowExecution = 1 [json_name = "WorkflowExecution"];*/ 1:
+                    message.workflowExecution = WorkflowExecutionResult.internalBinaryRead(reader, reader.uint32(), options, message.workflowExecution);
+                    break;
+                default:
+                    let u = options.readUnknownField;
+                    if (u === "throw")
+                        throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
+                    let d = reader.skip(wireType);
+                    if (u !== false)
+                        (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
+            }
+        }
+        return message;
+    }
+    internalBinaryWrite(message: StartWorkflowSweepResult, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
+        /* api.WorkflowExecutionResult WorkflowExecution = 1 [json_name = "WorkflowExecution"]; */
+        if (message.workflowExecution)
+            WorkflowExecutionResult.internalBinaryWrite(message.workflowExecution, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
+        let u = options.writeUnknownFields;
+        if (u !== false)
+            (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
+        return writer;
+    }
+}
+/**
+ * @generated MessageType for protobuf message api.StartWorkflowSweepResult
+ */
+export const StartWorkflowSweepResult = new StartWorkflowSweepResult$Type();
 /**
  * @generated ServiceType for protobuf service api.WorkflowService
  */
@@ -4102,5 +4200,6 @@ export const WorkflowService = new ServiceType("api.WorkflowService", [
     { name: "StartWorkflowPruneData", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow to prune project entity data." }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowPruneDataRequest, O: StartWorkflowPruneDataResult },
     { name: "StartWorkflowSynchronizeRulesOnGit", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow to synchronize rules on git" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowSynchronizeRulesOnGitRequest, O: StartWorkflowSynchronizeRulesOnGitResult },
     { name: "StartWorkflowAnonymizeData", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow to anonymize project entity data." }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowAnonymizeDataRequest, O: StartWorkflowAnonymizeDataResult },
-    { name: "StartWorkflowUpgradeModel", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow to run upgrade script according to the model version." }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowUpgradeModelRequest, O: StartWorkflowUpgradeModelResult }
+    { name: "StartWorkflowUpgradeModel", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow to run upgrade script according to the model version." }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowUpgradeModelRequest, O: StartWorkflowUpgradeModelResult },
+    { name: "StartWorkflowSweep", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow to sweep the platform." }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowSweepRequest, O: StartWorkflowSweepResult }
 ], { "api.k8sService": "organisation-server", "api.roleManager": true, "api.resourceManager": true });