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 2ec51f5 commit 1586d3c
Showing 1 changed file with 13 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -2850,9 +2850,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 @@ -2932,9 +2937,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 @@ -3000,9 +3009,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 1586d3c

Please sign in to comment.