Treating unfinished jobs + start_chart
This commit is contained in:
parent
b34716210e
commit
8320cec425
8 changed files with 87 additions and 12 deletions
|
@ -2,7 +2,7 @@
|
|||
SCRIPT_DIR=$( cd -- "$( dirname -- "${BASH_SOURCE[0]}" )" &> /dev/null && pwd )
|
||||
USER_HOME=$HOME
|
||||
[[ -n "${SUDO_USER}" ]] && USER_HOME="$(eval "echo ~${SUDO_USER}")"
|
||||
. ${SHRC_D:-$USER_HOME/.pqb.shrc.d}/01_util.functions
|
||||
. ${SHRC_D:-$USER_HOME/.sz.shrc.d}/01_util.functions
|
||||
|
||||
set -e
|
||||
|
||||
|
@ -11,12 +11,29 @@ count_unfinished_jobs() {
|
|||
}
|
||||
|
||||
wait_for_idle_queue() {
|
||||
local TIMEOUT="${1:-${TIMEOUT:-120}}" START="$(date +%s)"
|
||||
while [[ "$( count_unfinished_jobs )" -gt 0 ]]; do
|
||||
printf '.'
|
||||
|
||||
if (( TIMEOUT > 0 && ($(date +%s) - START) > TIMEOUT )); then
|
||||
printf 'TIMEOUT %s reached.\n' "$TIMEOUT" >&2
|
||||
printf '\n'
|
||||
return 1
|
||||
break;
|
||||
fi
|
||||
|
||||
sleep 2
|
||||
done
|
||||
printf '\n'
|
||||
}
|
||||
|
||||
wait_for_idle_queue
|
||||
|
||||
abort_unfinished_jobs() {
|
||||
midclt call core.get_jobs \
|
||||
| jq -r '.[] | select( .time_finished == null ) | .id ' \
|
||||
| xargs -rn1 midclt call core.job_abort
|
||||
}
|
||||
|
||||
wait_for_idle_queue || if [[ -z "$NO_AUTO_ABORT" ]]; then
|
||||
abort_unfinished_jobs
|
||||
fi
|
||||
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue