56 lines
1.7 KiB
Bash
Executable File
56 lines
1.7 KiB
Bash
Executable File
#!/bin/bash
|
|
set -e
|
|
|
|
TEST_POSTFIX="cronjob-test-run"
|
|
|
|
CRONJOBS=$(kubectl get cj --no-headers --all-namespaces | awk '{print $1":"$2}')
|
|
for i in ${CRONJOBS}; do
|
|
NS=$(echo "$i" | cut -f1 -d:)
|
|
CJ=$(echo "$i" | cut -f2 -d:)
|
|
|
|
# avoid scheduled runs to prevent case when our manual job is deleted by history limit.
|
|
kubectl patch cj/"${CJ}" -n"${NS}" -p '{"spec" : {"suspend" : true }}'
|
|
kubectl get job -n"${NS}" "${CJ}-${TEST_POSTFIX}" || \
|
|
kubectl create job -n"${NS}" --from=cj/"${CJ}" "${CJ}-${TEST_POSTFIX}"
|
|
done
|
|
|
|
echo "Waiting for all test jobs to complete."
|
|
for i in {1..30}; do
|
|
RUNNING_JOBS=$(kubectl get jobs --all-namespaces | grep "${TEST_POSTFIX}.*0/1" ||:)
|
|
[ -z "${RUNNING_JOBS}" ] && break
|
|
sleep 10
|
|
done
|
|
|
|
if [ -n "${RUNNING_JOBS}" ]; then
|
|
echo -e "Timed out waiting for cj jobs to complete:\n${RUNNING_JOBS}"
|
|
exit 1
|
|
fi
|
|
|
|
echo "All test jobs completed."
|
|
|
|
NOT_FOUND_JOBS=""
|
|
echo "Checking that every cronjob has a corresponding test job"
|
|
for i in ${CRONJOBS}; do
|
|
NS=$(echo "$i" | cut -f1 -d:)
|
|
CJ=$(echo "$i" | cut -f2 -d:)
|
|
if [ -z "$(kubectl get job -n ${NS} ${CJ}-${TEST_POSTFIX} | grep '1/1' ||:)" ]; then
|
|
NOT_FOUND_JOBS="${NOT_FOUND_JOBS}\n$i"
|
|
fi
|
|
done
|
|
|
|
if [ -n "${NOT_FOUND_JOBS}" ]; then
|
|
echo -e "Some cronjobs don't have corresponding test jobs:${NOT_FOUND_JOBS}"
|
|
kubectl get jobs --all-namespaces | grep ${TEST_POSTFIX}
|
|
exit 1
|
|
fi
|
|
|
|
echo "Cronjobs run successfully:"
|
|
kubectl get jobs --all-namespaces | grep ${TEST_POSTFIX}
|
|
|
|
# Unsuspend cj on success assuming they all were not suspended on start
|
|
for i in ${CRONJOBS}; do
|
|
NS=$(echo "$i" | cut -f1 -d:)
|
|
CJ=$(echo "$i" | cut -f2 -d:)
|
|
kubectl patch cj/"${CJ}" -n"${NS}" -p '{"spec" : {"suspend" : false }}'
|
|
done
|