From 4666055a809fa72d007daee5a76a86c111825a3e Mon Sep 17 00:00:00 2001 From: salamonpavel Date: Thu, 12 Oct 2023 16:34:54 +0200 Subject: [PATCH] Update agent/src/main/scala/za/co/absa/atum/agent/dispatcher/Dispatcher.scala Co-authored-by: Adam Cervenka --- .../scala/za/co/absa/atum/agent/dispatcher/Dispatcher.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/agent/src/main/scala/za/co/absa/atum/agent/dispatcher/Dispatcher.scala b/agent/src/main/scala/za/co/absa/atum/agent/dispatcher/Dispatcher.scala index 365e805ab..42a402226 100644 --- a/agent/src/main/scala/za/co/absa/atum/agent/dispatcher/Dispatcher.scala +++ b/agent/src/main/scala/za/co/absa/atum/agent/dispatcher/Dispatcher.scala @@ -20,7 +20,7 @@ import za.co.absa.atum.model.Partitioning import za.co.absa.atum.model.dto.{AtumContextDTO, CheckpointDTO} trait Dispatcher { - def fetchAtumContext(partitioning: Partitioning, parentPartitioning: Option[Partitioning]): Option[AtumContextDTO] + def getOrCreateAtumContext(partitioning: Partitioning, parentPartitioning: Option[Partitioning]): AtumContextDTO def saveCheckpoint(checkpoint: CheckpointDTO): Unit }