Skip to content

Commit db83e67

Browse files
committed
chore(schedule-engine): demote per-tick log lines to debug
Audit the schedule engine's logger.info calls and demote anything that fires per-tick or per-instance to logger.debug. The previous mix would emit ~3 info lines per fire ("Calculated next schedule timestamp", "Triggering scheduled task", "Successfully triggered scheduled task") which scales linearly with schedule volume. Demoted to debug: - "Calculated next schedule timestamp" — every tick (re-register after every fire) - "Triggering scheduled task" — every fire - "Successfully triggered scheduled task" — every fire - "Recovering schedule" — per-instance in the recovery loop, fan-out potential during recovery storms - "Job already exists for instance" — per-instance recovery - "No job found for instance, registering next run" — per-instance recovery Kept at info (lifecycle / per-event, fires once): - Worker startup / disabled / shutdown - "Recovering schedules in environment" (per recovery call, not per instance) - "No instances found for environment" (empty recovery summary)
1 parent 6765f63 commit db83e67

1 file changed

Lines changed: 6 additions & 6 deletions

File tree

  • internal-packages/schedule-engine/src/engine

internal-packages/schedule-engine/src/engine/index.ts

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -189,7 +189,7 @@ export class ScheduleEngine {
189189
const schedulingDelayMs = nextScheduledTimestamp.getTime() - Date.now();
190190
span.setAttribute("scheduling_delay_ms", schedulingDelayMs);
191191

192-
this.logger.info("Calculated next schedule timestamp", {
192+
this.logger.debug("Calculated next schedule timestamp", {
193193
instanceId: params.instanceId,
194194
taskIdentifier: instance.taskSchedule.taskIdentifier,
195195
nextScheduledTimestamp: nextScheduledTimestamp.toISOString(),
@@ -430,7 +430,7 @@ export class ScheduleEngine {
430430
span.setAttribute("scheduling_accuracy_ms", schedulingAccuracyMs);
431431
span.setAttribute("actual_execution_time", actualExecutionTime.toISOString());
432432

433-
this.logger.info("Triggering scheduled task", {
433+
this.logger.debug("Triggering scheduled task", {
434434
instanceId: params.instanceId,
435435
taskIdentifier: instance.taskSchedule.taskIdentifier,
436436
scheduleTimestamp: scheduleTimestamp.toISOString(),
@@ -481,7 +481,7 @@ export class ScheduleEngine {
481481
);
482482
} else if (result) {
483483
if (result.success) {
484-
this.logger.info("Successfully triggered scheduled task", {
484+
this.logger.debug("Successfully triggered scheduled task", {
485485
instanceId: params.instanceId,
486486
taskIdentifier: instance.taskSchedule.taskIdentifier,
487487
durationMs: triggerDuration,
@@ -742,7 +742,7 @@ export class ScheduleEngine {
742742
} as { recovered: string[]; skipped: string[] };
743743

744744
for (const { instance, schedule } of instancesWithSchedule) {
745-
this.logger.info("Recovering schedule", {
745+
this.logger.debug("Recovering schedule", {
746746
schedule,
747747
instance,
748748
});
@@ -791,7 +791,7 @@ export class ScheduleEngine {
791791
const job = await this.worker.getJob(`scheduled-task-instance:${instance.id}`);
792792

793793
if (job) {
794-
this.logger.info("Job already exists for instance", {
794+
this.logger.debug("Job already exists for instance", {
795795
instanceId: instance.id,
796796
job,
797797
schedule,
@@ -823,7 +823,7 @@ export class ScheduleEngine {
823823
lastScheduleTime = undefined;
824824
}
825825

826-
this.logger.info("No job found for instance, registering next run", {
826+
this.logger.debug("No job found for instance, registering next run", {
827827
instanceId: instance.id,
828828
schedule,
829829
lastScheduleTime: lastScheduleTime?.toISOString(),

0 commit comments

Comments
 (0)