Skip to content

Commit 5587edf

Browse files
authored
Merge pull request #480 from fjtirado/enable_callable_task
Enable callable task in TaskExecutorFactory
2 parents d6b21b8 + 4db3a21 commit 5587edf

File tree

1 file changed

+16
-0
lines changed

1 file changed

+16
-0
lines changed

impl/core/src/main/java/io/serverlessworkflow/impl/executors/DefaultTaskExecutorFactory.java

+16
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,11 @@
1515
*/
1616
package io.serverlessworkflow.impl.executors;
1717

18+
import io.serverlessworkflow.api.types.CallAsyncAPI;
19+
import io.serverlessworkflow.api.types.CallFunction;
20+
import io.serverlessworkflow.api.types.CallGRPC;
1821
import io.serverlessworkflow.api.types.CallHTTP;
22+
import io.serverlessworkflow.api.types.CallOpenAPI;
1923
import io.serverlessworkflow.api.types.CallTask;
2024
import io.serverlessworkflow.api.types.Task;
2125
import io.serverlessworkflow.api.types.TaskBase;
@@ -42,6 +46,18 @@ public TaskExecutor<? extends TaskBase> getTaskExecutor(
4246
if (callTask.getCallHTTP() != null) {
4347
return new CallTaskExecutor<>(
4448
callTask.getCallHTTP(), definition, findCallTask(CallHTTP.class));
49+
} else if (callTask.getCallAsyncAPI() != null) {
50+
return new CallTaskExecutor<>(
51+
callTask.getCallAsyncAPI(), definition, findCallTask(CallAsyncAPI.class));
52+
} else if (callTask.getCallGRPC() != null) {
53+
return new CallTaskExecutor<>(
54+
callTask.getCallGRPC(), definition, findCallTask(CallGRPC.class));
55+
} else if (callTask.getCallOpenAPI() != null) {
56+
return new CallTaskExecutor<>(
57+
callTask.getCallOpenAPI(), definition, findCallTask(CallOpenAPI.class));
58+
} else if (callTask.getCallFunction() != null) {
59+
return new CallTaskExecutor<>(
60+
callTask.getCallFunction(), definition, findCallTask(CallFunction.class));
4561
}
4662
} else if (task.getSwitchTask() != null) {
4763
return new SwitchExecutor(task.getSwitchTask(), definition);

0 commit comments

Comments
 (0)