Permalink
Browse files

made log_uri parameter optional in run_jobflow()

  • Loading branch information...
1 parent 5e3976b commit 1949a39af73cec575595e44696d97ed2c8b685d6 @mulka mulka committed Mar 28, 2012
Showing with 3 additions and 2 deletions.
  1. +3 −2 boto/emr/connection.py
View
@@ -197,7 +197,7 @@ def modify_instance_groups(self, instance_group_ids, new_sizes):
return self.get_object('ModifyInstanceGroups', params,
ModifyInstanceGroupsResponse, verb='POST')
- def run_jobflow(self, name, log_uri, ec2_keyname=None,
+ def run_jobflow(self, name, log_uri=None, ec2_keyname=None,
availability_zone=None,
master_instance_type='m1.small',
slave_instance_type='m1.small', num_instances=1,
@@ -282,8 +282,9 @@ def run_jobflow(self, name, log_uri, ec2_keyname=None,
params = {}
if action_on_failure:
params['ActionOnFailure'] = action_on_failure
+ if log_uri:
+ params['LogUri'] = log_uri
params['Name'] = name
- params['LogUri'] = log_uri
# Common instance args
common_params = self._build_instance_common_args(ec2_keyname,

0 comments on commit 1949a39

Please sign in to comment.