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

CE-936 - Make test pass (by starting simple scheduler via QScheduleManager)

Browse Source
This commit is contained in:
darin.kelkhoff
2024-03-12 13:39:12 -05:00
parent 3684101259
commit 11d33c6d06
1 changed files with 15 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
qqq-backend-core/src/test/java/com/kingsrook/qqq/backend/core/scheduler/simple/SimpleSchedulerTest.java
View File

@ -28,7 +28,6 @@ import com.kingsrook.qqq.backend.core.BaseTest;
import com.kingsrook.qqq.backend.core.actions.processes.BackendStep; import com.kingsrook.qqq.backend.core.actions.processes.BackendStep;
import com.kingsrook.qqq.backend.core.context.QContext; import com.kingsrook.qqq.backend.core.context.QContext;
import com.kingsrook.qqq.backend.core.exceptions.QException; import com.kingsrook.qqq.backend.core.exceptions.QException;
import com.kingsrook.qqq.backend.core.exceptions.QInstanceValidationException;
import com.kingsrook.qqq.backend.core.instances.QInstanceValidator; import com.kingsrook.qqq.backend.core.instances.QInstanceValidator;
import com.kingsrook.qqq.backend.core.model.actions.processes.RunBackendStepInput; import com.kingsrook.qqq.backend.core.model.actions.processes.RunBackendStepInput;
import com.kingsrook.qqq.backend.core.model.actions.processes.RunBackendStepOutput; import com.kingsrook.qqq.backend.core.model.actions.processes.RunBackendStepOutput;
@ -38,6 +37,7 @@ import com.kingsrook.qqq.backend.core.model.metadata.processes.QBackendStepMetaD
import com.kingsrook.qqq.backend.core.model.metadata.processes.QProcessMetaData; import com.kingsrook.qqq.backend.core.model.metadata.processes.QProcessMetaData;
import com.kingsrook.qqq.backend.core.model.metadata.scheduleing.QScheduleMetaData; import com.kingsrook.qqq.backend.core.model.metadata.scheduleing.QScheduleMetaData;
import com.kingsrook.qqq.backend.core.model.session.QSession; import com.kingsrook.qqq.backend.core.model.session.QSession;
import com.kingsrook.qqq.backend.core.scheduler.QScheduleManager;
import com.kingsrook.qqq.backend.core.utils.SleepUtils; import com.kingsrook.qqq.backend.core.utils.SleepUtils;
import com.kingsrook.qqq.backend.core.utils.TestUtils; import com.kingsrook.qqq.backend.core.utils.TestUtils;
import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.AfterEach;
@ -67,9 +67,13 @@ class SimpleSchedulerTest extends BaseTest
** **
*******************************************************************************/ *******************************************************************************/
@Test @Test
void testStartAndStop() void testStartAndStop() throws QException
{ {
QInstance qInstance = QContext.getQInstance(); QInstance qInstance = QContext.getQInstance();
QScheduleManager qScheduleManager = QScheduleManager.initInstance(qInstance, () -> QContext.getQSession());
qScheduleManager.start();
SimpleScheduler simpleScheduler = SimpleScheduler.getInstance(qInstance); SimpleScheduler simpleScheduler = SimpleScheduler.getInstance(qInstance);
simpleScheduler.setSchedulerName(TestUtils.SIMPLE_SCHEDULER_NAME); simpleScheduler.setSchedulerName(TestUtils.SIMPLE_SCHEDULER_NAME);
simpleScheduler.start(); simpleScheduler.start();
@ -85,7 +89,7 @@ class SimpleSchedulerTest extends BaseTest
** **
*******************************************************************************/ *******************************************************************************/
@Test @Test
void testScheduledProcess() throws QInstanceValidationException void testScheduledProcess() throws QException
{ {
QInstance qInstance = QContext.getQInstance(); QInstance qInstance = QContext.getQInstance();
new QInstanceValidator().validate(qInstance); new QInstanceValidator().validate(qInstance);
@ -95,7 +99,10 @@ class SimpleSchedulerTest extends BaseTest
qInstance.addProcess( qInstance.addProcess(
new QProcessMetaData() new QProcessMetaData()
.withName("testScheduledProcess") .withName("testScheduledProcess")
.withSchedule(new QScheduleMetaData().withRepeatMillis(2).withInitialDelaySeconds(0)) .withSchedule(new QScheduleMetaData()
.withSchedulerName(TestUtils.SIMPLE_SCHEDULER_NAME)
.withRepeatMillis(2)
.withInitialDelaySeconds(0))
.withStepList(List.of(new QBackendStepMetaData() .withStepList(List.of(new QBackendStepMetaData()
.withName("step") .withName("step")
.withCode(new QCodeReference(BasicStep.class)))) .withCode(new QCodeReference(BasicStep.class))))
@ -103,6 +110,9 @@ class SimpleSchedulerTest extends BaseTest
BasicStep.counter = 0; BasicStep.counter = 0;
QScheduleManager qScheduleManager = QScheduleManager.initInstance(qInstance, () -> QContext.getQSession());
qScheduleManager.start();
SimpleScheduler simpleScheduler = SimpleScheduler.getInstance(qInstance); SimpleScheduler simpleScheduler = SimpleScheduler.getInstance(qInstance);
simpleScheduler.setSchedulerName(TestUtils.SIMPLE_SCHEDULER_NAME); simpleScheduler.setSchedulerName(TestUtils.SIMPLE_SCHEDULER_NAME);
simpleScheduler.setSessionSupplier(QSession::new); simpleScheduler.setSessionSupplier(QSession::new);