Commit d0ce4e2
committed
fix(flows): fix OpenAPI spec generation for FlowController endpoints
The Micronaut OpenAPI annotation processor was silently skipping all
FlowController endpoints mapped to `{namespace}/{id}` (GET, PUT, DELETE)
because processing `FlowWithSource` → `Flow`/`Task` → `AbstractRetry`
triggered a `PostponeToNextRoundException` on the concrete retry subtypes
(Constant, Exponential, Random). This exception occurs because the Micronaut
constraint validators on those subtypes are processed in the same annotation
processing round, making their metadata unavailable when the OpenAPI processor
tries to introspect them.
Fix: annotate the `retry` field in both `Flow` and `Task` with
`@Schema(implementation = Object.class)` to prevent the processor from
following the `@JsonSubTypes` chain on `AbstractRetry`. Also add class-level
`@Schema` documentation to the concrete retry subtypes.1 parent e601372 commit d0ce4e2
6 files changed
Lines changed: 1531 additions & 59 deletions
File tree
- core/src/main/java/io/kestra/core/models
- flows
- tasks
- retrys
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
103 | 103 | | |
104 | 104 | | |
105 | 105 | | |
| 106 | + | |
| 107 | + | |
| 108 | + | |
| 109 | + | |
| 110 | + | |
| 111 | + | |
| 112 | + | |
| 113 | + | |
106 | 114 | | |
107 | 115 | | |
108 | 116 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
18 | 18 | | |
19 | 19 | | |
20 | 20 | | |
| 21 | + | |
21 | 22 | | |
22 | 23 | | |
23 | 24 | | |
| |||
45 | 46 | | |
46 | 47 | | |
47 | 48 | | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
48 | 53 | | |
49 | 54 | | |
50 | 55 | | |
| |||
Lines changed: 2 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
8 | 8 | | |
9 | 9 | | |
10 | 10 | | |
| 11 | + | |
11 | 12 | | |
12 | 13 | | |
13 | 14 | | |
| |||
18 | 19 | | |
19 | 20 | | |
20 | 21 | | |
| 22 | + | |
21 | 23 | | |
22 | 24 | | |
23 | 25 | | |
| |||
Lines changed: 2 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
9 | 9 | | |
10 | 10 | | |
11 | 11 | | |
| 12 | + | |
12 | 13 | | |
13 | 14 | | |
14 | 15 | | |
| |||
19 | 20 | | |
20 | 21 | | |
21 | 22 | | |
| 23 | + | |
22 | 24 | | |
23 | 25 | | |
24 | 26 | | |
| |||
Lines changed: 2 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
9 | 9 | | |
10 | 10 | | |
11 | 11 | | |
| 12 | + | |
12 | 13 | | |
13 | 14 | | |
14 | 15 | | |
| |||
19 | 20 | | |
20 | 21 | | |
21 | 22 | | |
| 23 | + | |
22 | 24 | | |
23 | 25 | | |
24 | 26 | | |
| |||
0 commit comments