Skip to content

Commit

Permalink
Fix node filter parameters for some api endpoints
Browse files Browse the repository at this point in the history
  • Loading branch information
gschueler committed Jun 3, 2011
1 parent 7b0217d commit a03873f
Showing 1 changed file with 13 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -2713,9 +2713,14 @@ class ScheduledExecutionController {
//convert api parameters to node filter parameters
def filters = FrameworkController.extractApiNodeFilterParams(params)
if (filters) {
inparams.extra['_replaceNodeFilters']='true'
inparams.extra['doNodedispatch']=true
filters.each {k, v ->
inparams.extra[k] = v
}
if(null==inparams.extra['nodeExcludePrecedence']){
inparams.extra['nodeExcludePrecedence'] = true
}
}

def result = executeScheduledExecution(scheduledExecution, framework, rolelist, inparams)
Expand Down Expand Up @@ -2795,9 +2800,13 @@ class ScheduledExecutionController {
//convert api parameters to node filter parameters
def filters=FrameworkController.extractApiNodeFilterParams(params)
if(filters){
filters['doNodedispatch']=true
filters.each{k,v->
params[k]=v
}
if (null == params['nodeExcludePrecedence']) {
params['nodeExcludePrecedence'] = true
}
}

def results=runAdhoc()
Expand Down Expand Up @@ -2863,9 +2872,13 @@ class ScheduledExecutionController {
//convert api parameters to node filter parameters
def filters=FrameworkController.extractApiNodeFilterParams(params)
if(filters){
filters['doNodedispatch'] = true
filters.each{k,v->
params[k]=v
}
if (null == params['nodeExcludePrecedence']) {
params['nodeExcludePrecedence'] = true
}
}

def results=runAdhoc()
Expand Down

0 comments on commit a03873f

Please sign in to comment.