safebox/framework-scheduler
7
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 16 Wiki Activity

commented scheduler process

Browse Source
This commit is contained in:
Gyorgy Berenyi
2024-08-02 17:36:02 +02:00
parent e984dc7d20
commit 8d1821f102
2 changed files with 32 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
scripts/scheduler/entrypoint.sh
View File

@@ -336,7 +336,7 @@ check_redis_availability $REDIS_SERVER $REDIS_PORT $CURL_RETRIES $CURL_SLEEP_SHO
echo `date`" Scheduler initialized, starting listening for events" echo `date`" Scheduler initialized, starting listening for events"
# STARTING SCHEDULER PROCESSES # STARTING SCHEDULER PROCESSES
/scripts/scheduler.sh & #/scripts/scheduler.sh &
while true; do while true; do

56
scripts/scheduler/scheduler.sh
View File

@@ -76,32 +76,35 @@ $DOCKER_REGISTRY_URL$SETUP:$SETUP_VERSION"
check_status() { check_status() {
# checking sytem status # checking sytem status
RET=0; if [ "$STATUS" != "1" ]; then
DATE=$( date +"%Y%m%d%H%M")
TASK="system-status:$DATE"
SYSTEM_STATUS=$(ls /etc/user/config/services/*.json |grep -v service-framework.json)
INSTALLED_SERVICES=$(ls /etc/user/config/services/*.json );
SERVICES="";
for SERVICE in $(echo $INSTALLED_SERVICES); do
CONTENT=$(cat $SERVICE | base64 -w0);
if [ "$SERVICES" != "" ]; then
SERVICES=","$SERVICES;
fi;
SERVICES=$SERVICES'"'$(cat $SERVICE | jq -r .main.SERVICE_NAME)'": "'$CONTENT'"';
done
if [ "$SYSTEM_STATUS" != "" ]; then
STATUS="1";
else
STATUS="2";
fi
echo '{ "STATUS": "'$STATUS'", "INSTALLED_SERVICES": {'$SERVICES'} }';
JSON_TARGET=$(echo '{ "STATUS": "'$STATUS'", "INSTALLED_SERVICES": {'$SERVICES'} }' | jq -r . | base64 -w0); RET=0;
DATE=$( date +"%Y%m%d%H%M")
TASK="system-status"
SYSTEM_STATUS=$(ls /etc/user/config/services/*.json |grep -v service-framework.json)
redis-cli -h $REDIS_SERVER -p $REDIS_PORT SET $TASK "$JSON_TARGET"; INSTALLED_SERVICES=$(ls /etc/user/config/services/*.json );
redis-cli -h $REDIS_SERVER -p $REDIS_PORT sadd shceduler_in "$TASK"; SERVICES="";
for SERVICE in $(echo $INSTALLED_SERVICES); do
CONTENT=$(cat $SERVICE | base64 -w0);
if [ "$SERVICES" != "" ]; then
SERVICES=","$SERVICES;
fi;
SERVICES=$SERVICES'"'$(cat $SERVICE | jq -r .main.SERVICE_NAME)'": "'$CONTENT'"';
done
if [ "$SYSTEM_STATUS" != "" ]; then
STATUS="1";
else
STATUS="2";
fi
echo '{ "STATUS": "'$STATUS'", "INSTALLED_SERVICES": {'$SERVICES'} }';
JSON_TARGET=$(echo '{ "DATE": "'$DATE'", "STATUS": "'$STATUS'", "INSTALLED_SERVICES": {'$SERVICES'} }' | jq -r . | base64 -w0);
redis-cli -h $REDIS_SERVER -p $REDIS_PORT SET $TASK "$JSON_TARGET";
redis-cli -h $REDIS_SERVER -p $REDIS_PORT sadd scheduler_in "$TASK";
fi
RET=""; RET="";
} }
@@ -134,6 +137,7 @@ check_redis_availability() {
while true; do while true; do
TASKS="" TASKS=""
SLEEP=1;
# GET DEPLOYMENT IDs FROM generate key # GET DEPLOYMENT IDs FROM generate key
TASKS=$(redis-cli -h $REDIS_SERVER -p $REDIS_PORT SMEMBERS scheduler_out) TASKS=$(redis-cli -h $REDIS_SERVER -p $REDIS_PORT SMEMBERS scheduler_out)
@@ -159,6 +163,8 @@ while true; do
fi fi
if [[ "$RET" == "" ]]; then if [[ "$RET" == "" ]]; then
SLEEP=$((SLEEP+5))
sleep $SLEEP;
check_status check_status
fi fi