Run Nightly Weekday Jobs at 10 PM | CronBase

const cron = require('node-cron');
const { exec } = require('child_process');

console.log('Initializing scheduler dynamic worker...');

// Schedule the weekday task at 10:00 PM (22:00)
const scheduledTask = cron.schedule('0 22 * * 1-5', () => {
  const timestamp = new Date().toISOString();
  console.log(`[${timestamp}] Starting scheduled weekday night processing...`);
  
  exec('/usr/local/bin/process-batch.sh', (error, stdout, stderr) => {
    if (error) {
      console.error(`[${timestamp}] Execution failed:`, error.message);
      return;
    }
    if (stderr) {
      console.warn(`[${timestamp}] Standard Error Output:`, stderr);
    }
    console.log(`[${timestamp}] Execution output:`, stdout);
  });
}, {
  scheduled: true,
  timezone: "America/New_York"
});

scheduledTask.start();

#!/usr/bin/env bash
# Safe installation script for the weekday 10 PM cron job.
set -euo pipefail

# Define the cron command to execute safely
CRON_CMD="0 22 * * 1-5 /usr/local/bin/backup-job.sh >> /var/log/backup-job.log 2>&1"

# Verify script exists before registering
if [ ! -f "/usr/local/bin/backup-job.sh" ]; then
    echo "Error: Target script /usr/local/bin/backup-job.sh not found." >&2
    exit 1
fi

# Idempotently append to the crontab
(crontab -l 2>/dev/null | grep -Fv "/usr/local/bin/backup-job.sh"; echo "$CRON_CMD") | crontab -
echo "Cron job successfully scheduled for 22:00 Monday-Friday."

import logging
import sys
from apscheduler.schedulers.blocking import BlockingScheduler

logging.basicConfig(
    level=logging.INFO,
    format='%(asctime)s [%(levelname)s] %(message)s',
    handlers=[logging.StreamHandler(sys.stdout)]
)
logger = logging.getLogger(__name__)

def execute_nightly_pipeline():
    try:
        logger.info("Initiating weekday nightly data pipeline run...")
        # Insert production database synchronization or backup logic here
        logger.info("Pipeline execution completed successfully.")
    except Exception as e:
        logger.error(f"Pipeline failed with unhandled exception: {str(e)}")

scheduler = BlockingScheduler()
# Add cron trigger for Monday-Friday (1-5) at 22:00 America/New_York
scheduler.add_job(
    execute_nightly_pipeline,
    'cron',
    day_of_week='mon-fri',
    hour=22,
    minute=0,
    timezone='America/New_York'
)

try:
    logger.info("Starting APScheduler daemon...")
    scheduler.start()
except (KeyboardInterrupt, SystemExit):
    logger.info("Scheduler stopped manually.")

package main

import (
	"log"
	"os"
	"os/signal"
	"syscall"
	"time"

	"github.com/robfig/cron/v3"
)

func main() {
	// Load the target execution timezone
	loc, err := time.LoadLocation("America/New_York")
	if err != nil {
		log.Fatalf("Failed to load timezone: %v", err)
	}

	c := cron.New(cron.WithLocation(loc))
	
	_, err = c.AddFunc("0 22 * * 1-5", func() {
		log.Println("Starting weekday nightly system synchronization task...")
		// Execute business logic here safely
	})
	if err != nil {
		log.Fatalf("Failed to register cron job schedule: %v", err)
	}

	c.Start()
	log.Println("Scheduler successfully started. Waiting for execution events...")

	// Handle graceful shutdown signals
	sigChan := make(chan os.Signal, 1)
	signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM)
	<-sigChan

	log.Println("Stopping scheduler daemon gracefully...")
	c.Stop()
}

package com.cronbase.scheduler;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@Component
public class WeekdayNightlyScheduler {
    private static final Logger logger = LoggerFactory.getLogger(WeekdayNightlyScheduler.class);

    // Spring Cron format: second, minute, hour, day-of-month, month, day-of-week
    // 'MON-FRI' corresponds to standard cron's '1-5'
    @Scheduled(cron = "0 0 22 * * MON-FRI", zone = "America/New_York")
    public void runWeekdayNightlyJob() {
        logger.info("Triggering scheduled weekday nightly maintenance window tasks...");
        try {
            // Database cleanup, index optimization, or backup tasks go here
            logger.info("Maintenance tasks executed successfully.");
        } catch (Exception ex) {
            logger.error("Error occurred during maintenance window execution", ex);
        }
    }
}

apiVersion: batch/v1
kind: CronJob
metadata:
  name: weekday-nightly-backup
  namespace: production
spec:
  schedule: "0 22 * * 1-5"
  concurrencyPolicy: Forbid
  successfulJobsHistoryLimit: 3
  failedJobsHistoryLimit: 5
  jobTemplate:
    spec:
      template:
        spec:
          containers:
          - name: backup-worker
            image: postgres:15-alpine
            command:
            - /bin/sh
            - -c
            - "echo 'Starting DB Backup...'; pg_dumpall -U postgres > /mnt/backups/db_$(date +%F).sql && echo 'Backup Complete'"
            env:
            - name: PGHOST
              value: "db-service"
          restartPolicy: OnFailure