Skip to content

Commit

Permalink
Fix a couple of typos.
Browse files Browse the repository at this point in the history
  • Loading branch information
yruslan committed Nov 24, 2023
1 parent 27216b6 commit 7d781b8
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -166,10 +166,10 @@ class OrchestratorImpl extends Orchestrator {
val outputTable = job.outputTable

if (isSucceeded) {
log.info(s"$SUCCESS Job '${job.name}' outputting to '${outputTable.name}' is SUCCEEDED.")
log.info(s"$SUCCESS Job '${job.name}' outputting to '${outputTable.name}' has SUCCEEDED.")
dependencyResolver.setAvailableTable(outputTable.name)
} else {
log.warn(s"$FAILURE Job '${job.name}' outputting to '${outputTable.name}' is FAILED.")
log.warn(s"$FAILURE Job '${job.name}' outputting to '${outputTable.name}' has FAILED.")
dependencyResolver.setFailedTable(outputTable.name)
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -144,7 +144,7 @@ abstract class TaskRunnerBase(conf: Config,
case Success(validationResult) =>
val resultToReturn = validationResult.status match {
case Ready =>
log.info(s"Validation of the task: $outputTable for date: ${task.infoDate} is SUCCEEDED.")
log.info(s"Validation of the task: $outputTable for date: ${task.infoDate} has SUCCEEDED.")
Right(validationResult)
case NeedsUpdate =>
log.info(s"The table needs update: $outputTable for date: ${task.infoDate}.")
Expand Down

0 comments on commit 7d781b8

Please sign in to comment.