servers-executor/karya.servers.executor.usecase.internal/ProcessTask

ProcessTask

class ProcessTask @Inject constructor(tasksRepo: TasksRepo, errorLogsRepo: ErrorLogsRepo, queueClient: ProducerQueueClient)

Use case class responsible for processing tasks based on the executor result.

Constructors

Link copied to clipboard
@Inject
constructor(tasksRepo: TasksRepo, errorLogsRepo: ErrorLogsRepo, queueClient: ProducerQueueClient)

Creates an instance of ProcessTask with the specified repositories and queue client.

Types

Link copied to clipboard
object Companion : Logging

Functions

Link copied to clipboard
suspend fun invoke(result: ExecutorResult, message: QueueMessage.ExecutorMessage, start: Instant)

Processes the task based on the executor result.