From 60ffac4646249d1ad3d140bec522eb7a53ec8ade Mon Sep 17 00:00:00 2001 From: Darin Kelkhoff Date: Thu, 14 Mar 2024 11:15:54 -0500 Subject: [PATCH] CE-936 - add reviewStepRecordFields to these processes --- .../quartz/processes/PauseQuartzJobsProcess.java | 9 ++++++++- .../quartz/processes/ResumeQuartzJobsProcess.java | 9 ++++++++- 2 files changed, 16 insertions(+), 2 deletions(-) diff --git a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/scheduler/quartz/processes/PauseQuartzJobsProcess.java b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/scheduler/quartz/processes/PauseQuartzJobsProcess.java index 96f033cd..f74791cc 100644 --- a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/scheduler/quartz/processes/PauseQuartzJobsProcess.java +++ b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/scheduler/quartz/processes/PauseQuartzJobsProcess.java @@ -22,12 +22,15 @@ package com.kingsrook.qqq.backend.core.scheduler.quartz.processes; +import java.util.List; import com.kingsrook.qqq.backend.core.exceptions.QException; import com.kingsrook.qqq.backend.core.model.MetaDataProducerInterface; 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.data.QRecord; import com.kingsrook.qqq.backend.core.model.metadata.QInstance; +import com.kingsrook.qqq.backend.core.model.metadata.fields.QFieldMetaData; +import com.kingsrook.qqq.backend.core.model.metadata.fields.QFieldType; import com.kingsrook.qqq.backend.core.model.metadata.layout.QIcon; import com.kingsrook.qqq.backend.core.model.metadata.processes.QProcessMetaData; import com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.AbstractLoadStep; @@ -61,6 +64,10 @@ public class PauseQuartzJobsProcess extends AbstractLoadStep implements MetaData .withTransformStepClass(NoopTransformStep.class) .withLoadStepClass(getClass()) .withIcon(new QIcon("pause_circle_outline")) + .withReviewStepRecordFields(List.of( + new QFieldMetaData("id", QFieldType.LONG), + new QFieldMetaData("jobName", QFieldType.STRING), + new QFieldMetaData("jobGroup", QFieldType.STRING))) .getProcessMetaData(); } @@ -77,7 +84,7 @@ public class PauseQuartzJobsProcess extends AbstractLoadStep implements MetaData QuartzScheduler instance = QuartzScheduler.getInstance(); for(QRecord record : runBackendStepInput.getRecords()) { - instance.pauseJob(record.getValueString("jobName"), record.getValueString("groupName")); + instance.pauseJob(record.getValueString("jobName"), record.getValueString("jobGroup")); } } catch(Exception e) diff --git a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/scheduler/quartz/processes/ResumeQuartzJobsProcess.java b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/scheduler/quartz/processes/ResumeQuartzJobsProcess.java index e7215452..687f29b3 100644 --- a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/scheduler/quartz/processes/ResumeQuartzJobsProcess.java +++ b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/scheduler/quartz/processes/ResumeQuartzJobsProcess.java @@ -22,12 +22,15 @@ package com.kingsrook.qqq.backend.core.scheduler.quartz.processes; +import java.util.List; import com.kingsrook.qqq.backend.core.exceptions.QException; import com.kingsrook.qqq.backend.core.model.MetaDataProducerInterface; 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.data.QRecord; import com.kingsrook.qqq.backend.core.model.metadata.QInstance; +import com.kingsrook.qqq.backend.core.model.metadata.fields.QFieldMetaData; +import com.kingsrook.qqq.backend.core.model.metadata.fields.QFieldType; import com.kingsrook.qqq.backend.core.model.metadata.layout.QIcon; import com.kingsrook.qqq.backend.core.model.metadata.processes.QProcessMetaData; import com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.AbstractLoadStep; @@ -61,6 +64,10 @@ public class ResumeQuartzJobsProcess extends AbstractLoadStep implements MetaDat .withTransformStepClass(NoopTransformStep.class) .withLoadStepClass(getClass()) .withIcon(new QIcon("play_circle_outline")) + .withReviewStepRecordFields(List.of( + new QFieldMetaData("id", QFieldType.LONG), + new QFieldMetaData("jobName", QFieldType.STRING), + new QFieldMetaData("jobGroup", QFieldType.STRING))) .getProcessMetaData(); } @@ -77,7 +84,7 @@ public class ResumeQuartzJobsProcess extends AbstractLoadStep implements MetaDat QuartzScheduler instance = QuartzScheduler.getInstance(); for(QRecord record : runBackendStepInput.getRecords()) { - instance.resumeJob(record.getValueString("jobName"), record.getValueString("groupName")); + instance.resumeJob(record.getValueString("jobName"), record.getValueString("jobGroup")); } } catch(Exception e)