redis-daemon/dev.ust.zinc.grader.daemon.jobs/GradingTask

GradingTask

object GradingTask : Job<Payload.GradingTask>

Properties

coroutineContext

open override val coroutineContext: CoroutineContext

val jobName: String

name of the job, that is the IPC topic name

private val logger: Logger

Functions

private suspend fun gradeOrSkip(errorsOrLazyPipeline: Either<List<ErrorUnit.ConfigErrorUnit>, Pair<List<ErrorUnit.ContextErrorUnit>, LazyPipeline>>, payload: Payload.GradingTask, partialContext: PartialContext, startTime: Instant, isReportFinal: Boolean): Payload.DoneGrading

Grades the assignment if the Config is valid using the pipeline and returns the DoneGrading payload.

open suspend override fun handlePayload(payload: Payload.GradingTask)

There are three cases of immediate/scheduled & Partial/Full grading:

fun packagePayload(payload: Payload): JobMessage