From 7f435dfb286518695a9371d24d7a3b074dc1dc30 Mon Sep 17 00:00:00 2001 From: ci core model Date: Thu, 20 Mar 2025 10:29:28 +0000 Subject: [PATCH] Latest generation --- package.json | 2 +- workflow.client.ts | 56 +++------- workflow.ts | 247 --------------------------------------------- 3 files changed, 16 insertions(+), 289 deletions(-) diff --git a/package.json b/package.json index 29f33d9a..8ac5cbe6 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@reflex-platform/npm-core-sdk", - "version": "1.10.0-SNAPSHOT-250320100522", + "version": "1.10.0-SNAPSHOT-250320102853", "description": "npm libs from core model proto files", "homepage": "", "main": "index.ts", diff --git a/workflow.client.ts b/workflow.client.ts index da44d067..ba308b77 100644 --- a/workflow.client.ts +++ b/workflow.client.ts @@ -34,10 +34,6 @@ import type { StartWorkflowOptimizeClickhouseResult } from "./workflow"; import type { StartWorkflowOptimizeClickhouseRequest } from "./workflow"; import type { StopWorkflowResult } from "./workflow"; import type { StopWorkflowRequest } from "./workflow"; -import type { StopWorkflowStopIdleFlinkResult } from "./workflow"; -import type { StopWorkflowStopIdleFlinkRequest } from "./workflow"; -import type { StartWorkflowStopIdleFlinkResult } from "./workflow"; -import type { StartWorkflowStopIdleFlinkRequest } from "./workflow"; import type { GetModuleWorkflowsResult } from "./workflow"; import type { GetModuleWorkflowsRequest } from "./workflow"; import type { DeregisterModuleWorkflowsResult } from "./workflow"; @@ -117,14 +113,6 @@ export interface IWorkflowServiceClient { * @generated from protobuf rpc: GetModuleWorkflows(api.GetModuleWorkflowsRequest) returns (api.GetModuleWorkflowsResult); */ getModuleWorkflows(input: GetModuleWorkflowsRequest, options?: RpcOptions): UnaryCall; - /** - * @generated from protobuf rpc: StartWorkflowStopIdleFlink(api.StartWorkflowStopIdleFlinkRequest) returns (api.StartWorkflowStopIdleFlinkResult); - */ - startWorkflowStopIdleFlink(input: StartWorkflowStopIdleFlinkRequest, options?: RpcOptions): UnaryCall; - /** - * @generated from protobuf rpc: StopWorkflowStopIdleFlink(api.StopWorkflowStopIdleFlinkRequest) returns (api.StopWorkflowStopIdleFlinkResult); - */ - stopWorkflowStopIdleFlink(input: StopWorkflowStopIdleFlinkRequest, options?: RpcOptions): UnaryCall; /** * @generated from protobuf rpc: StopWorkflow(api.StopWorkflowRequest) returns (api.StopWorkflowResult); */ @@ -279,123 +267,109 @@ export class WorkflowServiceClient implements IWorkflowServiceClient, ServiceInf const method = this.methods[11], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } - /** - * @generated from protobuf rpc: StartWorkflowStopIdleFlink(api.StartWorkflowStopIdleFlinkRequest) returns (api.StartWorkflowStopIdleFlinkResult); - */ - startWorkflowStopIdleFlink(input: StartWorkflowStopIdleFlinkRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[12], opt = this._transport.mergeOptions(options); - return stackIntercept("unary", this._transport, method, opt, input); - } - /** - * @generated from protobuf rpc: StopWorkflowStopIdleFlink(api.StopWorkflowStopIdleFlinkRequest) returns (api.StopWorkflowStopIdleFlinkResult); - */ - stopWorkflowStopIdleFlink(input: StopWorkflowStopIdleFlinkRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[13], opt = this._transport.mergeOptions(options); - return stackIntercept("unary", this._transport, method, opt, input); - } /** * @generated from protobuf rpc: StopWorkflow(api.StopWorkflowRequest) returns (api.StopWorkflowResult); */ stopWorkflow(input: StopWorkflowRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[14], opt = this._transport.mergeOptions(options); + const method = this.methods[12], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } /** * @generated from protobuf rpc: StartWorkflowOptimizeClickhouse(api.StartWorkflowOptimizeClickhouseRequest) returns (api.StartWorkflowOptimizeClickhouseResult); */ startWorkflowOptimizeClickhouse(input: StartWorkflowOptimizeClickhouseRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[15], opt = this._transport.mergeOptions(options); + const method = this.methods[13], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } /** * @generated from protobuf rpc: StartWorkflowCreateOrganisation(api.StartWorkflowCreateOrganisationRequest) returns (api.StartWorkflowCreateOrganisationResult); */ startWorkflowCreateOrganisation(input: StartWorkflowCreateOrganisationRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[16], opt = this._transport.mergeOptions(options); + const method = this.methods[14], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } /** * @generated from protobuf rpc: StartWorkflowDeleteOrganisation(api.StartWorkflowDeleteOrganisationRequest) returns (api.StartWorkflowDeleteOrganisationResult); */ startWorkflowDeleteOrganisation(input: StartWorkflowDeleteOrganisationRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[17], opt = this._transport.mergeOptions(options); + const method = this.methods[15], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } /** * @generated from protobuf rpc: StartWorkflowRecoverData(api.StartWorkflowRecoverDataRequest) returns (api.StartWorkflowRecoverDataResult); */ startWorkflowRecoverData(input: StartWorkflowRecoverDataRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[18], opt = this._transport.mergeOptions(options); + const method = this.methods[16], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } /** * @generated from protobuf rpc: StartWorkflowCheckAndLaunchRecoverData(api.StartWorkflowCheckAndLaunchRecoverDataRequest) returns (api.StartWorkflowCheckAndLaunchRecoverDataResult); */ startWorkflowCheckAndLaunchRecoverData(input: StartWorkflowCheckAndLaunchRecoverDataRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[19], opt = this._transport.mergeOptions(options); + const method = this.methods[17], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } /** * @generated from protobuf rpc: StartWorkflowUpdateMaterializedView(api.StartWorkflowUpdateMaterializedViewRequest) returns (api.StartWorkflowUpdateMaterializedViewResult); */ startWorkflowUpdateMaterializedView(input: StartWorkflowUpdateMaterializedViewRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[20], opt = this._transport.mergeOptions(options); + const method = this.methods[18], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } /** * @generated from protobuf rpc: GetWorkflowState(api.GetWorkflowStateRequest) returns (api.GetWorkflowStateResult); */ getWorkflowState(input: GetWorkflowStateRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[21], opt = this._transport.mergeOptions(options); + const method = this.methods[19], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } /** * @generated from protobuf rpc: GetWorkflowExecutionInformations(api.GetWorkflowExecutionInformationsRequest) returns (api.GetWorkflowExecutionInformationsResult); */ getWorkflowExecutionInformations(input: GetWorkflowExecutionInformationsRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[22], opt = this._transport.mergeOptions(options); + const method = this.methods[20], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } /** * @generated from protobuf rpc: StartWorkflowDailyProjectsOperations(api.StartWorkflowDailyProjectsOperationsRequest) returns (api.StartWorkflowDailyProjectsOperationsResult); */ startWorkflowDailyProjectsOperations(input: StartWorkflowDailyProjectsOperationsRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[23], opt = this._transport.mergeOptions(options); + const method = this.methods[21], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } /** * @generated from protobuf rpc: StartWorkflowHealthCheckWorkflows(api.StartWorkflowHealthCheckWorkflowsRequest) returns (api.StartWorkflowHealthCheckWorkflowsResult); */ startWorkflowHealthCheckWorkflows(input: StartWorkflowHealthCheckWorkflowsRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[24], opt = this._transport.mergeOptions(options); + const method = this.methods[22], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } /** * @generated from protobuf rpc: StartWorkflowExtractKPI(api.StartWorkflowExtractKPIRequest) returns (api.StartWorkflowExtractKPIResult); */ startWorkflowExtractKPI(input: StartWorkflowExtractKPIRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[25], opt = this._transport.mergeOptions(options); + const method = this.methods[23], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } /** * @generated from protobuf rpc: StartWorkflowPruneData(api.StartWorkflowPruneDataRequest) returns (api.StartWorkflowPruneDataResult); */ startWorkflowPruneData(input: StartWorkflowPruneDataRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[26], opt = this._transport.mergeOptions(options); + const method = this.methods[24], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } /** * @generated from protobuf rpc: StartWorkflowSynchronizeRulesOnGit(api.StartWorkflowSynchronizeRulesOnGitRequest) returns (api.StartWorkflowSynchronizeRulesOnGitResult); */ startWorkflowSynchronizeRulesOnGit(input: StartWorkflowSynchronizeRulesOnGitRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[27], opt = this._transport.mergeOptions(options); + const method = this.methods[25], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } /** * @generated from protobuf rpc: StartWorkflowAnonymizeData(api.StartWorkflowAnonymizeDataRequest) returns (api.StartWorkflowAnonymizeDataResult); */ startWorkflowAnonymizeData(input: StartWorkflowAnonymizeDataRequest, options?: RpcOptions): UnaryCall { - const method = this.methods[28], opt = this._transport.mergeOptions(options); + const method = this.methods[26], opt = this._transport.mergeOptions(options); return stackIntercept("unary", this._transport, method, opt, input); } } diff --git a/workflow.ts b/workflow.ts index 774e6710..84498c4f 100644 --- a/workflow.ts +++ b/workflow.ts @@ -462,50 +462,6 @@ export interface GetModuleWorkflowsResult { */ moduleWorkflows: ModuleWorkflow[]; } -/** - * @generated from protobuf message api.StartWorkflowStopIdleFlinkRequest - */ -export interface StartWorkflowStopIdleFlinkRequest { - /** - * @generated from protobuf field: string OrganisationId = 1 [json_name = "OrganisationId"]; - */ - organisationId: string; - /** - * @generated from protobuf field: bool RunWakeUpFlink = 2 [json_name = "RunWakeUpFlink"]; - */ - runWakeUpFlink: boolean; -} -/** - * @generated from protobuf message api.StartWorkflowStopIdleFlinkResult - */ -export interface StartWorkflowStopIdleFlinkResult { - /** - * @generated from protobuf field: api.WorkflowExecutionResult WorkflowExecution = 1 [json_name = "WorkflowExecution"]; - */ - workflowExecution?: WorkflowExecutionResult; - /** - * @generated from protobuf field: api.WorkflowExecutionResult WakeUpFlinkWorkflowExecution = 2 [json_name = "WakeUpFlinkWorkflowExecution"]; - */ - wakeUpFlinkWorkflowExecution?: WorkflowExecutionResult; -} -/** - * @generated from protobuf message api.StopWorkflowStopIdleFlinkRequest - */ -export interface StopWorkflowStopIdleFlinkRequest { - /** - * @generated from protobuf field: string OrganisationId = 1 [json_name = "OrganisationId"]; - */ - organisationId: string; - /** - * @generated from protobuf field: bool RunWakeUpFlink = 2 [json_name = "RunWakeUpFlink"]; - */ - runWakeUpFlink: boolean; -} -/** - * @generated from protobuf message api.StopWorkflowStopIdleFlinkResult - */ -export interface StopWorkflowStopIdleFlinkResult { -} /** * @generated from protobuf message api.StopWorkflowRequest */ @@ -2544,207 +2500,6 @@ class GetModuleWorkflowsResult$Type extends MessageType { - constructor() { - super("api.StartWorkflowStopIdleFlinkRequest", [ - { no: 1, name: "OrganisationId", kind: "scalar", jsonName: "OrganisationId", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } }, - { no: 2, name: "RunWakeUpFlink", kind: "scalar", jsonName: "RunWakeUpFlink", T: 8 /*ScalarType.BOOL*/ } - ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["OrganisationId"] } } }); - } - create(value?: PartialMessage): StartWorkflowStopIdleFlinkRequest { - const message = globalThis.Object.create((this.messagePrototype!)); - message.organisationId = ""; - message.runWakeUpFlink = false; - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowStopIdleFlinkRequest): StartWorkflowStopIdleFlinkRequest { - let message = target ?? this.create(), end = reader.pos + length; - while (reader.pos < end) { - let [fieldNo, wireType] = reader.tag(); - switch (fieldNo) { - case /* string OrganisationId = 1 [json_name = "OrganisationId"];*/ 1: - message.organisationId = reader.string(); - break; - case /* bool RunWakeUpFlink = 2 [json_name = "RunWakeUpFlink"];*/ 2: - message.runWakeUpFlink = reader.bool(); - 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: StartWorkflowStopIdleFlinkRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { - /* string OrganisationId = 1 [json_name = "OrganisationId"]; */ - if (message.organisationId !== "") - writer.tag(1, WireType.LengthDelimited).string(message.organisationId); - /* bool RunWakeUpFlink = 2 [json_name = "RunWakeUpFlink"]; */ - if (message.runWakeUpFlink !== false) - writer.tag(2, WireType.Varint).bool(message.runWakeUpFlink); - let u = options.writeUnknownFields; - if (u !== false) - (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); - return writer; - } -} -/** - * @generated MessageType for protobuf message api.StartWorkflowStopIdleFlinkRequest - */ -export const StartWorkflowStopIdleFlinkRequest = new StartWorkflowStopIdleFlinkRequest$Type(); -// @generated message type with reflection information, may provide speed optimized methods -class StartWorkflowStopIdleFlinkResult$Type extends MessageType { - constructor() { - super("api.StartWorkflowStopIdleFlinkResult", [ - { no: 1, name: "WorkflowExecution", kind: "message", jsonName: "WorkflowExecution", T: () => WorkflowExecutionResult }, - { no: 2, name: "WakeUpFlinkWorkflowExecution", kind: "message", jsonName: "WakeUpFlinkWorkflowExecution", T: () => WorkflowExecutionResult } - ]); - } - create(value?: PartialMessage): StartWorkflowStopIdleFlinkResult { - const message = globalThis.Object.create((this.messagePrototype!)); - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowStopIdleFlinkResult): StartWorkflowStopIdleFlinkResult { - 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; - case /* api.WorkflowExecutionResult WakeUpFlinkWorkflowExecution = 2 [json_name = "WakeUpFlinkWorkflowExecution"];*/ 2: - message.wakeUpFlinkWorkflowExecution = WorkflowExecutionResult.internalBinaryRead(reader, reader.uint32(), options, message.wakeUpFlinkWorkflowExecution); - 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: StartWorkflowStopIdleFlinkResult, 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(); - /* api.WorkflowExecutionResult WakeUpFlinkWorkflowExecution = 2 [json_name = "WakeUpFlinkWorkflowExecution"]; */ - if (message.wakeUpFlinkWorkflowExecution) - WorkflowExecutionResult.internalBinaryWrite(message.wakeUpFlinkWorkflowExecution, writer.tag(2, 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.StartWorkflowStopIdleFlinkResult - */ -export const StartWorkflowStopIdleFlinkResult = new StartWorkflowStopIdleFlinkResult$Type(); -// @generated message type with reflection information, may provide speed optimized methods -class StopWorkflowStopIdleFlinkRequest$Type extends MessageType { - constructor() { - super("api.StopWorkflowStopIdleFlinkRequest", [ - { no: 1, name: "OrganisationId", kind: "scalar", jsonName: "OrganisationId", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } }, - { no: 2, name: "RunWakeUpFlink", kind: "scalar", jsonName: "RunWakeUpFlink", T: 8 /*ScalarType.BOOL*/ } - ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["OrganisationId"] } } }); - } - create(value?: PartialMessage): StopWorkflowStopIdleFlinkRequest { - const message = globalThis.Object.create((this.messagePrototype!)); - message.organisationId = ""; - message.runWakeUpFlink = false; - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StopWorkflowStopIdleFlinkRequest): StopWorkflowStopIdleFlinkRequest { - let message = target ?? this.create(), end = reader.pos + length; - while (reader.pos < end) { - let [fieldNo, wireType] = reader.tag(); - switch (fieldNo) { - case /* string OrganisationId = 1 [json_name = "OrganisationId"];*/ 1: - message.organisationId = reader.string(); - break; - case /* bool RunWakeUpFlink = 2 [json_name = "RunWakeUpFlink"];*/ 2: - message.runWakeUpFlink = reader.bool(); - 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: StopWorkflowStopIdleFlinkRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { - /* string OrganisationId = 1 [json_name = "OrganisationId"]; */ - if (message.organisationId !== "") - writer.tag(1, WireType.LengthDelimited).string(message.organisationId); - /* bool RunWakeUpFlink = 2 [json_name = "RunWakeUpFlink"]; */ - if (message.runWakeUpFlink !== false) - writer.tag(2, WireType.Varint).bool(message.runWakeUpFlink); - let u = options.writeUnknownFields; - if (u !== false) - (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); - return writer; - } -} -/** - * @generated MessageType for protobuf message api.StopWorkflowStopIdleFlinkRequest - */ -export const StopWorkflowStopIdleFlinkRequest = new StopWorkflowStopIdleFlinkRequest$Type(); -// @generated message type with reflection information, may provide speed optimized methods -class StopWorkflowStopIdleFlinkResult$Type extends MessageType { - constructor() { - super("api.StopWorkflowStopIdleFlinkResult", []); - } - create(value?: PartialMessage): StopWorkflowStopIdleFlinkResult { - const message = globalThis.Object.create((this.messagePrototype!)); - if (value !== undefined) - reflectionMergePartial(this, message, value); - return message; - } - internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StopWorkflowStopIdleFlinkResult): StopWorkflowStopIdleFlinkResult { - 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: StopWorkflowStopIdleFlinkResult, 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.StopWorkflowStopIdleFlinkResult - */ -export const StopWorkflowStopIdleFlinkResult = new StopWorkflowStopIdleFlinkResult$Type(); -// @generated message type with reflection information, may provide speed optimized methods class StopWorkflowRequest$Type extends MessageType { constructor() { super("api.StopWorkflowRequest", [ @@ -4171,8 +3926,6 @@ export const WorkflowService = new ServiceType("api.WorkflowService", [ { name: "RegisterModuleWorkflows", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Register module child workflows to be executed after or before a core workflow" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: RegisterModuleWorkflowsRequest, O: RegisterModuleWorkflowsResult }, { name: "DeregisterModuleWorkflows", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Deregister module child workflow" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: DeregisterModuleWorkflowsRequest, O: DeregisterModuleWorkflowsResult }, { name: "GetModuleWorkflows", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Get module child workflow for a workflow type" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: GetModuleWorkflowsRequest, O: GetModuleWorkflowsResult }, - { name: "StartWorkflowStopIdleFlink", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow which will periodically stop idle flink jobs for an organization" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "HIDDEN" } }, I: StartWorkflowStopIdleFlinkRequest, O: StartWorkflowStopIdleFlinkResult }, - { name: "StopWorkflowStopIdleFlink", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Stop the workflow wich will periodically stop idle flink jobs for an organization" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "HIDDEN" } }, I: StopWorkflowStopIdleFlinkRequest, O: StopWorkflowStopIdleFlinkResult }, { name: "StopWorkflow", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Terminates a workflow execution" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StopWorkflowRequest, O: StopWorkflowResult }, { name: "StartWorkflowOptimizeClickhouse", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow which will periodically launch optimize clikhouse operation for all projects in the platform" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowOptimizeClickhouseRequest, O: StartWorkflowOptimizeClickhouseResult }, { name: "StartWorkflowCreateOrganisation", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow which will create an organisation" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowCreateOrganisationRequest, O: StartWorkflowCreateOrganisationResult },