diff options
| author | Kyle Mulka <repalviglator@yahoo.com> | 2012-03-28 16:39:33 -0400 |
|---|---|---|
| committer | Kyle Mulka <repalviglator@yahoo.com> | 2012-03-28 16:39:33 -0400 |
| commit | 1949a39af73cec575595e44696d97ed2c8b685d6 (patch) | |
| tree | 73a7cf8ebe123c3d10e48080cca3c8e816a6bf7c | |
| parent | 5e3976b6615c131d8567caa433f90c5aada8536b (diff) | |
| download | boto-1949a39af73cec575595e44696d97ed2c8b685d6.tar.gz | |
made log_uri parameter optional in run_jobflow()
| -rw-r--r-- | boto/emr/connection.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/boto/emr/connection.py b/boto/emr/connection.py index bd264d20..7e39af9c 100644 --- a/boto/emr/connection.py +++ b/boto/emr/connection.py @@ -197,7 +197,7 @@ class EmrConnection(AWSQueryConnection): 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 @@ class EmrConnection(AWSQueryConnection): 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, |