From 4db3a21aef2ce98b3e5d2deba819f7591b2b5172 Mon Sep 17 00:00:00 2001 From: Francisco Javier Tirado Sarti Date: Mon, 25 Nov 2024 19:50:15 +0100 Subject: [PATCH] Enable callable task in TaskExecutorFactory Signed-off-by: Francisco Javier Tirado Sarti --- .../executors/DefaultTaskExecutorFactory.java | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/impl/core/src/main/java/io/serverlessworkflow/impl/executors/DefaultTaskExecutorFactory.java b/impl/core/src/main/java/io/serverlessworkflow/impl/executors/DefaultTaskExecutorFactory.java index 8ca2feb4..b5ac0119 100644 --- a/impl/core/src/main/java/io/serverlessworkflow/impl/executors/DefaultTaskExecutorFactory.java +++ b/impl/core/src/main/java/io/serverlessworkflow/impl/executors/DefaultTaskExecutorFactory.java @@ -15,7 +15,11 @@ */ package io.serverlessworkflow.impl.executors; +import io.serverlessworkflow.api.types.CallAsyncAPI; +import io.serverlessworkflow.api.types.CallFunction; +import io.serverlessworkflow.api.types.CallGRPC; import io.serverlessworkflow.api.types.CallHTTP; +import io.serverlessworkflow.api.types.CallOpenAPI; import io.serverlessworkflow.api.types.CallTask; import io.serverlessworkflow.api.types.Task; import io.serverlessworkflow.api.types.TaskBase; @@ -42,6 +46,18 @@ public TaskExecutor getTaskExecutor( if (callTask.getCallHTTP() != null) { return new CallTaskExecutor<>( callTask.getCallHTTP(), definition, findCallTask(CallHTTP.class)); + } else if (callTask.getCallAsyncAPI() != null) { + return new CallTaskExecutor<>( + callTask.getCallAsyncAPI(), definition, findCallTask(CallAsyncAPI.class)); + } else if (callTask.getCallGRPC() != null) { + return new CallTaskExecutor<>( + callTask.getCallGRPC(), definition, findCallTask(CallGRPC.class)); + } else if (callTask.getCallOpenAPI() != null) { + return new CallTaskExecutor<>( + callTask.getCallOpenAPI(), definition, findCallTask(CallOpenAPI.class)); + } else if (callTask.getCallFunction() != null) { + return new CallTaskExecutor<>( + callTask.getCallFunction(), definition, findCallTask(CallFunction.class)); } } else if (task.getSwitchTask() != null) { return new SwitchExecutor(task.getSwitchTask(), definition);