summaryrefslogtreecommitdiffstats
path: root/idrop-web/grails-app/services
diff options
context:
space:
mode:
authormconway <michael_conway@unc.edu>2013-10-31 20:32:30 (GMT)
committer mconway <michael_conway@unc.edu>2013-10-31 20:32:30 (GMT)
commitaea45b0d3747163e5466630a6a5d8e989b85dfdc (patch)
treecfc52ad18f90bba948bb9c7d7467b59e84a93c1d /idrop-web/grails-app/services
parentc7ee3e425ae7b77524265d57e1e49db044724ae4 (diff)
downloadQCG-Data-aea45b0d3747163e5466630a6a5d8e989b85dfdc.zip
QCG-Data-aea45b0d3747163e5466630a6a5d8e989b85dfdc.tar.gz
QCG-Data-aea45b0d3747163e5466630a6a5d8e989b85dfdc.tar.bz2
[#1776] add rule queue processing views
Diffstat (limited to 'idrop-web/grails-app/services')
-rw-r--r--idrop-web/grails-app/services/org/irods/mydrop/service/RuleProcessingService.groovy9
1 files changed, 7 insertions, 2 deletions
diff --git a/idrop-web/grails-app/services/org/irods/mydrop/service/RuleProcessingService.groovy b/idrop-web/grails-app/services/org/irods/mydrop/service/RuleProcessingService.groovy
index 7a1ea35..44d74a4 100644
--- a/idrop-web/grails-app/services/org/irods/mydrop/service/RuleProcessingService.groovy
+++ b/idrop-web/grails-app/services/org/irods/mydrop/service/RuleProcessingService.groovy
@@ -2,6 +2,7 @@ package org.irods.mydrop.service
import org.irods.jargon.core.connection.IRODSAccount
import org.irods.jargon.core.pub.IRODSAccessObjectFactory
+import org.irods.jargon.core.pub.RuleProcessingAO
import org.irods.jargon.core.utils.LocalFileUtils
import org.irods.jargon.core.utils.MiscIRODSUtils
import org.irods.jargon.ruleservice.composition.RuleCompositionService
@@ -35,7 +36,6 @@ class RuleProcessingService {
return ruleService.executeRuleFromParts(ruleBody, inputParameters, outputParameters)
}
-
def isRule(String rulePath) {
if (!rulePath) {
return false
@@ -52,7 +52,6 @@ class RuleProcessingService {
}
}
-
def deleteOutputParam(IRODSAccount irodsAccount, String absPath, String parameter) {
log.info("deleteOutputParam")
RuleCompositionService ruleService = new RuleCompositionServiceImpl(irodsAccessObjectFactory, irodsAccount)
@@ -77,4 +76,10 @@ class RuleProcessingService {
RuleCompositionService ruleService = new RuleCompositionServiceImpl(irodsAccessObjectFactory, irodsAccount)
return ruleService.addOutputParameterToRule(absPath, parameterName)
}
+
+ def listDelayedRuleExecutions(IRODSAccount irodsAccount, int offset) {
+ log.info("listDelayedRuleExecutions()")
+ RuleProcessingAO ruleProcessingAO = irodsAccessObjectFactory.getRuleProcessingAO(irodsAccount)
+ return ruleProcessingAO.listAllDelayedRuleExecutions(offset)
+ }
}