From e2a8279244f3ee6c7edbaa4dcd7616cb80ce0b1d Mon Sep 17 00:00:00 2001 From: Piotr Rudnicki Date: Mon, 9 Dec 2024 17:08:54 +0100 Subject: [PATCH] add debug log for schedule deployments for batches (#7302) Co-authored-by: Piotr Rudnicki --- .../engine/management/periodic/PeriodicProcessService.scala | 3 +++ 1 file changed, 3 insertions(+) diff --git a/engine/flink/management/periodic/src/main/scala/pl/touk/nussknacker/engine/management/periodic/PeriodicProcessService.scala b/engine/flink/management/periodic/src/main/scala/pl/touk/nussknacker/engine/management/periodic/PeriodicProcessService.scala index 2b5968270f7..38949a6123d 100644 --- a/engine/flink/management/periodic/src/main/scala/pl/touk/nussknacker/engine/management/periodic/PeriodicProcessService.scala +++ b/engine/flink/management/periodic/src/main/scala/pl/touk/nussknacker/engine/management/periodic/PeriodicProcessService.scala @@ -248,6 +248,9 @@ class PeriodicProcessService( scheduleDeploymentsWithStatus = schedules.schedules.values.toList.flatMap(_.latestDeployments.map { deployment => (deployment, runtimeStatuses.getStatus(deployment.id)) }) + _ = logger.debug( + s"Process '$processName' schedule deployments with status: ${scheduleDeploymentsWithStatus.map(_.toString)}" + ) needRescheduleDeployments <- Future .sequence(scheduleDeploymentsWithStatus.map { case (deploymentData, statusOpt) => synchronizeDeploymentState(deploymentData, statusOpt).run.map { needReschedule =>