QRunIO/qqq
2
0
Fork 0
mirror of https://github.com/Kingsrook/qqq.git synced 2025-07-18 13:10:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

make scheduler look at env var in addition to system property for deciding whether to start or not.

Browse Source
This commit is contained in:
darin.kelkhoff
2023-01-24 14:13:02 -06:00
parent 9889320fa6
commit 6b12390f6c
2 changed files with 35 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/scheduler/ScheduleManager.java
View File

@ -31,6 +31,7 @@ import com.kingsrook.qqq.backend.core.actions.processes.RunProcessAction;
import com.kingsrook.qqq.backend.core.actions.queues.SQSQueuePoller; import com.kingsrook.qqq.backend.core.actions.queues.SQSQueuePoller;
import com.kingsrook.qqq.backend.core.context.CapturedContext; import com.kingsrook.qqq.backend.core.context.CapturedContext;
import com.kingsrook.qqq.backend.core.context.QContext; import com.kingsrook.qqq.backend.core.context.QContext;
import com.kingsrook.qqq.backend.core.instances.QMetaDataVariableInterpreter;
import com.kingsrook.qqq.backend.core.logging.QLogger; import com.kingsrook.qqq.backend.core.logging.QLogger;
import com.kingsrook.qqq.backend.core.model.actions.processes.RunProcessInput; import com.kingsrook.qqq.backend.core.model.actions.processes.RunProcessInput;
import com.kingsrook.qqq.backend.core.model.metadata.QInstance; import com.kingsrook.qqq.backend.core.model.metadata.QInstance;
@ -101,10 +102,19 @@ public class ScheduleManager
public void start() public void start()
{ {
String propertyName = "qqq.scheduleManager.enabled"; String propertyName = "qqq.scheduleManager.enabled";
String propertyValue = System.getProperty(propertyName, ""); String propertyValue = System.getProperty(propertyName);
if(propertyValue.equals("false")) if("false".equals(propertyValue))
{ {
LOG.warn("Not starting ScheduleManager (per system property [" + propertyName + "=" + propertyValue + "])."); LOG.warn("Not starting ScheduleManager (per system property] [" + propertyName + "=" + propertyValue + "]).");
return;
}
QMetaDataVariableInterpreter qMetaDataVariableInterpreter = new QMetaDataVariableInterpreter();
String envName = "QQQ_SCHEDULE_MANAGER_ENABLED";
String envValue = qMetaDataVariableInterpreter.interpret("${env." + envName + "}");
if("false".equals(envValue))
{
LOG.warn("Not starting ScheduleManager (per environment variable] [" + envName + "=" + envValue + "]).");
return; return;
} }
@ -150,7 +160,10 @@ public class ScheduleManager
executor.setName(runner.getName()); executor.setName(runner.getName());
setScheduleInExecutor(schedule, executor); setScheduleInExecutor(schedule, executor);
executor.start(); if(!executor.start())
{
LOG.warn("executor.start return false for: " + executor.getName());
}
executors.add(executor); executors.add(executor);
} }
@ -222,7 +235,10 @@ public class ScheduleManager
executor.setName(queue.getName()); executor.setName(queue.getName());
setScheduleInExecutor(schedule, executor); setScheduleInExecutor(schedule, executor);
executor.start(); if(!executor.start())
{
LOG.warn("executor.start return false for: " + executor.getName());
}
executors.add(executor); executors.add(executor);
} }
@ -268,7 +284,10 @@ public class ScheduleManager
StandardScheduledExecutor executor = new StandardScheduledExecutor(runProcess); StandardScheduledExecutor executor = new StandardScheduledExecutor(runProcess);
executor.setName("process:" + process.getName()); executor.setName("process:" + process.getName());
setScheduleInExecutor(process.getSchedule(), executor); setScheduleInExecutor(process.getSchedule(), executor);
executor.start(); if(!executor.start())
{
LOG.warn("executor.start return false for: " + executor.getName());
}
executors.add(executor); executors.add(executor);
} }

10
qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/scheduler/StandardScheduledExecutor.java
View File

@ -260,4 +260,14 @@ public class StandardScheduledExecutor
STOPPING, STOPPING,
} }
/*******************************************************************************
** Getter for name
**
*******************************************************************************/
public String getName()
{
return name;
}
} }