diff --git a/packages/core/types/src/http/workflow-execution/admin/responses.ts b/packages/core/types/src/http/workflow-execution/admin/responses.ts index 4db29f888a..f8959ff585 100644 --- a/packages/core/types/src/http/workflow-execution/admin/responses.ts +++ b/packages/core/types/src/http/workflow-execution/admin/responses.ts @@ -1,3 +1,4 @@ +import { Acknowledgement } from "../../../workflows-sdk" import { PaginatedResponse } from "../../common/response" import { AdminWorkflowExecution } from "./entities" @@ -8,3 +9,7 @@ export interface AdminWorkflowExecutionResponse { export type AdminWorkflowExecutionListResponse = PaginatedResponse<{ workflow_executions: AdminWorkflowExecution[] }> + +export type AdminWorkflowRunResponse = { + acknowledgement: Acknowledgement +} \ No newline at end of file diff --git a/packages/core/types/src/workflows-sdk/service.ts b/packages/core/types/src/workflows-sdk/service.ts index 419e4f760a..e7f4788997 100644 --- a/packages/core/types/src/workflows-sdk/service.ts +++ b/packages/core/types/src/workflows-sdk/service.ts @@ -15,6 +15,11 @@ type FlowRunOptions = { events?: Record } +export type Acknowledgement = { + workflowId: string + transactionId: string +} + export interface WorkflowOrchestratorRunDTO extends FlowRunOptions { transactionId?: string @@ -59,7 +64,7 @@ export interface IWorkflowEngineService extends IModuleService { errors: Error[] transaction: object result: any - acknowledgement: object + acknowledgement: Acknowledgement }> getRunningTransaction( diff --git a/packages/medusa/src/api/admin/workflows-executions/[workflow_id]/run/route.ts b/packages/medusa/src/api/admin/workflows-executions/[workflow_id]/run/route.ts index 60e6def0bb..f24f4ea84f 100644 --- a/packages/medusa/src/api/admin/workflows-executions/[workflow_id]/run/route.ts +++ b/packages/medusa/src/api/admin/workflows-executions/[workflow_id]/run/route.ts @@ -1,4 +1,5 @@ import { + HttpTypes, IWorkflowEngineService, WorkflowOrchestratorRunDTO, } from "@medusajs/types" @@ -11,7 +12,7 @@ import { AdminCreateWorkflowsRunType } from "../../validators" export const POST = async ( req: AuthenticatedMedusaRequest, - res: MedusaResponse<{ acknowledgement: object }> + res: MedusaResponse ) => { const workflowEngineService: IWorkflowEngineService = req.scope.resolve( ModuleRegistrationName.WORKFLOW_ENGINE