@@ -41,8 +41,8 @@ public class OpenAPIExecutor implements CallableTask<CallOpenAPI> {
41
41
private WorkflowDefinition definition ;
42
42
private WorkflowApplication application ;
43
43
private TargetSupplier targetSupplier ;
44
-
45
44
private ResourceLoader resourceLoader ;
45
+ private OperationDefinitionSupplier operationDefinitionSupplier ;
46
46
47
47
@ Override
48
48
public boolean accept (Class <? extends TaskBase > clazz ) {
@@ -53,9 +53,6 @@ public boolean accept(Class<? extends TaskBase> clazz) {
53
53
public CompletableFuture <WorkflowModel > apply (
54
54
WorkflowContext workflowContext , TaskContext taskContext , WorkflowModel input ) {
55
55
56
- OperationDefinitionSupplier operationDefinitionSupplier =
57
- new OperationDefinitionSupplier (application , task );
58
-
59
56
OperationDefinition operation =
60
57
operationDefinitionSupplier .get (workflowContext , taskContext , input );
61
58
@@ -91,7 +88,7 @@ public void init(CallOpenAPI task, WorkflowDefinition definition) {
91
88
this .workflow = definition .workflow ();
92
89
this .application = definition .application ();
93
90
this .resourceLoader = definition .resourceLoader ();
94
-
91
+ this . operationDefinitionSupplier = new OperationDefinitionSupplier ( application , task );
95
92
this .targetSupplier =
96
93
getTargetSupplier (
97
94
task .getWith ().getDocument ().getEndpoint (), application .expressionFactory ());
0 commit comments