1515 */
1616package 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 ;
1821import io .serverlessworkflow .api .types .CallHTTP ;
22+ import io .serverlessworkflow .api .types .CallOpenAPI ;
1923import io .serverlessworkflow .api .types .CallTask ;
2024import io .serverlessworkflow .api .types .Task ;
2125import 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