Skip to content

Commit

Permalink
fix(core): generate properly taskrunners and log exporters implementa…
Browse files Browse the repository at this point in the history
…tions in json schema after adding generic types

closes kestra-io/kestra-ee#2755
  • Loading branch information
brian-mulier-p committed Jan 28, 2025
1 parent 32da58e commit 94e42a9
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -520,14 +520,14 @@ protected List<ResolvedType> subtypeResolver(ResolvedType declaredType, TypeCont
.stream()
.flatMap(registeredPlugin -> registeredPlugin.getTaskRunners().stream())
.filter(Predicate.not(io.kestra.core.models.Plugin::isInternal))
.flatMap(clz -> safelyResolveSubtype(declaredType, clz, typeContext).stream())
.map(typeContext::resolve)
.toList();
} else if (declaredType.getErasedType() == LogExporter.class) {
return getRegisteredPlugins()
.stream()
.flatMap(registeredPlugin -> registeredPlugin.getLogExporters().stream())
.filter(Predicate.not(io.kestra.core.models.Plugin::isInternal))
.flatMap(clz -> safelyResolveSubtype(declaredType, clz, typeContext).stream())
.map(typeContext::resolve)
.toList();
} else if (declaredType.getErasedType() == Chart.class) {
return getRegisteredPlugins()
Expand Down

0 comments on commit 94e42a9

Please sign in to comment.