Permalink
Browse files

Closes GH-9

  • Loading branch information...
1 parent 38c355b commit df771e5cda153b505921ef0a9db6f170cf9dbc5a @klbostee committed Jul 23, 2010
Showing with 4 additions and 0 deletions.
  1. +4 −0 dumbo/core.py
View
@@ -380,6 +380,7 @@ def run(self):
'nummaptasks',
'numreducetasks',
'priority',
+ 'queue',
'cachefile',
'cachearchive',
'file',
@@ -435,6 +436,9 @@ def run(self):
if addedopts['priority']:
self.opts.append(('jobconf', 'mapred.job.priority=%s'
% addedopts['priority'][0]))
+ if addedopts['queue']:
+ self.opts.append(('jobconf', 'mapred.job.queue.name=%s'
+ % addedopts['queue'][0]))
if addedopts['cachefile']:
for cachefile in addedopts['cachefile']:
self.opts.append(('cacheFile', cachefile))

0 comments on commit df771e5

Please sign in to comment.