Run Every Two Hours on Weekdays | CronBase

#!/bin/bash
# Lock file to prevent overlapping executions
LOCKFILE="/var/run/weekday_sync.lock"
exec 200>"$LOCKFILE"
if ! flock -n 200; then
  echo "Error: Another instance of the job is already running." >&2
  exit 1
fi
echo "Starting weekday sync task..."
# Real-world task execution
curl -f -s https://api.example.com/sync || { echo "Sync failed" >&2; exit 1; }
echo "Task completed successfully."

const cron = require('node-cron');
const axios = require('axios');

// Schedule task for every 2 hours on weekdays
cron.schedule('0 */2 * * 1-5', async () => {
  console.log('Starting scheduled weekday data synchronization...');
  try {
    const response = await axios.post('https://api.example.com/v1/sync');
    console.log(`Sync completed with status: ${response.status}`);
  } catch (error) {
    console.error('Execution failed during weekday sync:', error.message);
  }
}, {
  scheduled: true,
  timezone: "UTC"
});

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

logging.basicConfig(level=logging.INFO)
logger = logging.getLogger('weekday_cron')

def execute_sync_job():
    logger.info("Executing scheduled weekday synchronization job...")
    try:
        response = requests.post("https://api.example.com/jobs/sync", timeout=30)
        response.raise_for_status()
        logger.info(f"Job completed successfully: {response.status_code}")
    except Exception as err:
        logger.error(f"Job failed during execution: {err}")

if __name__ == '__main__':
    scheduler = BlockingScheduler()
    # 0 */2 * * 1-5 maps to day_of_week='mon-fri', hour='*/2', minute=0
    scheduler.add_job(execute_sync_job, 'cron', day_of_week='mon-fri', hour='*/2', minute=0, timezone='UTC')
    try:
        scheduler.start()
    except (KeyboardInterrupt, SystemExit):
        pass

package main

import (
	"log"
	"net/http"
	"time"

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

func main() {
	// Use UTC timezone to avoid DST transition complications
	c := cron.New(cron.WithLocation(time.UTC))
	_, err := c.AddFunc("0 */2 * * 1-5", func() {
		log.Println("Starting weekday pipeline execution...")
		client := &http.Client{Timeout: 10 * time.Second}
		resp, err := client.Post("https://api.example.com/pipeline", "application/json", nil)
		if err != nil {
			log.Printf("Pipeline execution failed: %v", err)
			return
		}
		defer resp.Body.Close()
		log.Printf("Pipeline execution completed with status: %s", resp.Status)
	})
	if err != nil {
		log.Fatalf("Failed to schedule cron job: %v", err)
	}
	c.Start()
	select {} // Block forever
}

package com.example.cron;

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

@Component
public class WeekdaySyncScheduler {
    private static final Logger logger = LoggerFactory.getLogger(WeekdaySyncScheduler.class);
    private final RestTemplate restTemplate = new RestTemplate();

    // Standard Spring cron format: second, minute, hour, day of month, month, day(s) of week
    @Scheduled(cron = "0 0 */2 * * MON-FRI", zone = "UTC")
    public void runWeekdayTask() {
        logger.info("Starting weekday task execution...");
        try {
            String url = "https://api.example.com/tasks/trigger";
            String response = restTemplate.postForObject(url, null, String.class);
            logger.info("Task completed successfully: {}", response);
        } catch (Exception e) {
            logger.error("Error occurred while running weekday task", e);
        }
    }
}

apiVersion: batch/v1
kind: CronJob
metadata:
  name: weekday-sync-job
  namespace: default
spec:
  schedule: "0 */2 * * 1-5"
  concurrencyPolicy: Forbid
  startingDeadlineSeconds: 600
  successfulJobsHistoryLimit: 3
  failedJobsHistoryLimit: 1
  jobTemplate:
    spec:
      template:
        spec:
          containers:
          - name: sync-worker
            image: curlimages/curl:latest
            command: 
            - /bin/sh
            - -c
            - "curl -f -s https://api.example.com/sync || exit 1"
          restartPolicy: OnFailure