Package dev.dokimos.server.service

Class RunService

java.lang.Object

dev.dokimos.server.service.RunService

@Service
public class RunService
extends Object

Constructor Summary

Constructors

Constructor	Description
RunService(ExperimentRunRepository runRepository, ItemResultRepository itemResultRepository, IngestedBatchRepository ingestedBatchRepository, DatasetService datasetService, DatasetItemRepository datasetItemRepository, AnnotationRepository annotationRepository, RegressionAlertService regressionAlertService)

Method Summary

Modifier and Type	Method	Description
void	addItems(UUID runId, AddItemsRequest request, String idempotencyKey, TenantScope scope)	Adds item results to a run; only allowed while the run is RUNNING.
ExperimentRun	createRun(Experiment experiment, CreateRunRequest request, TenantScope scope)	Creates a run and persists its provenance fields (name, git SHA, branch, triggered_by) plus an optional link to the dataset version it executed against.
ExperimentRun	createRun(Experiment experiment, Map<String,Object> config)
void	deleteRun(UUID runId, TenantScope scope)	Deletes a run visible under the scope; FKs cascade to its item and eval results.
void	failEvaluatedRun(UUID runId)	Moves an evaluating run to FAILED when its judge job has terminally failed, so the run does not stay stuck in EVALUATING.
void	finalizeEvaluatedRun(UUID runId)	Finalizes a run whose judge job has finished scoring: re-computes the materialized pass-rate fields and moves the run to SUCCESS.
RunDetails	getRunDetails(UUID runId, org.springframework.data.domain.Pageable pageable, TenantScope scope)
List<RunSummary>	listRuns(Experiment experiment, TenantScope scope)
void	updateRun(UUID runId, UpdateRunRequest request, TenantScope scope)	Updates a run's status.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RunService

public RunService(ExperimentRunRepository runRepository,
 ItemResultRepository itemResultRepository,
 IngestedBatchRepository ingestedBatchRepository,
 DatasetService datasetService,
 DatasetItemRepository datasetItemRepository,
 AnnotationRepository annotationRepository,
 RegressionAlertService regressionAlertService)

Method Details

createRun

@Transactional
public ExperimentRun createRun(Experiment experiment,
 Map<String,Object> config)

createRun

@Transactional
public ExperimentRun createRun(Experiment experiment,
 CreateRunRequest request,
 TenantScope scope)

Creates a run and persists its provenance fields (name, git SHA, branch, triggered_by) plus an optional link to the dataset version it executed against. The dataset linkage is the foundation for the per-case diff and CI gate: runs paired by (datasetVersionId, ordinal) share stable item identities across executions.

Throws:

IllegalArgumentException - if only one of datasetName / datasetVersion is supplied, or if the referenced dataset version does not exist

addItems

@Transactional
public void addItems(UUID runId,
 AddItemsRequest request,
 String idempotencyKey,
 TenantScope scope)

Adds item results to a run; only allowed while the run is RUNNING. A pessimistic lock on the run row serializes ingestion against updateRun(java.util.UUID, dev.dokimos.server.dto.v1.UpdateRunRequest, dev.dokimos.server.tenant.TenantScope) so materialized counts stay consistent. When idempotencyKey is non-null, a previously committed batch with the same (runId, idempotencyKey) returns a no-op; the composite PK on ingested_batches is the backstop.

Throws:

IllegalStateException - if the run is not RUNNING

deleteRun

@Transactional
public void deleteRun(UUID runId,
 TenantScope scope)

Deletes a run visible under the scope; FKs cascade to its item and eval results.

updateRun

@Transactional
public void updateRun(UUID runId,
 UpdateRunRequest request,
 TenantScope scope)

Updates a run's status. On a terminal status this method is the sole writer of the materialized pass-rate fields; the pessimistic lock on the run row blocks until any in-flight addItems(java.util.UUID, dev.dokimos.server.dto.v1.AddItemsRequest, java.lang.String, dev.dokimos.server.tenant.TenantScope) batch commits.

finalizeEvaluatedRun

@Transactional
public void finalizeEvaluatedRun(UUID runId)

Finalizes a run whose judge job has finished scoring: re-computes the materialized pass-rate fields and moves the run to SUCCESS. The run row is locked so the finalization serializes against any concurrent ingestion or status update.

Parameters:

runId - the run to finalize

Throws:

IllegalArgumentException - if the run does not exist

failEvaluatedRun

@Transactional
public void failEvaluatedRun(UUID runId)

Moves an evaluating run to FAILED when its judge job has terminally failed, so the run does not stay stuck in EVALUATING. No-op if the run is no longer EVALUATING.

Parameters:

runId - the run to fail

Throws:

IllegalArgumentException - if the run does not exist

listRuns

@Transactional(readOnly=true)
public List<RunSummary> listRuns(Experiment experiment,
 TenantScope scope)

getRunDetails

@Transactional(readOnly=true)
public RunDetails getRunDetails(UUID runId,
 org.springframework.data.domain.Pageable pageable,
 TenantScope scope)