-
Query the
JobStatusTracker(JST) table via.tables().jobStatusTrackers(). -
Filter on
trackerType()/status()using theTrackerType/TrackerStatusenums (net.pricefx.domain.JobStatusTracker). -
in()isn't supported for enum columns, for multiple values, combine several.equal()checks withexprs.or()(PFUN-35753).
Code
Groovy
def qapi = api.queryApi()
def exprs = qapi.exprs()
def jst = qapi.tables().jobStatusTrackers()
return qapi.source(jst, [jst.id(), jst.jobName(), jst.trackerType(), jst.status(), jst.processingStart(), jst.processingEnd()],
exprs.and(
jst.trackerType().equal(net.pricefx.domain.JobStatusTracker.TrackerType.CALCULATIONFLOW),
jst.status().equal(net.pricefx.domain.JobStatusTracker.TrackerStatus.FAILED)
))
.stream { it.toList() }