From f4a595478b4e62ebf92116ed31c6fc2c12bd2f8a Mon Sep 17 00:00:00 2001 From: bsimpson63 Date: Sun, 21 Apr 2013 18:59:43 -0400 Subject: [PATCH] Make jobflows visible to all users. --- r2/r2/lib/emr_helpers.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/r2/r2/lib/emr_helpers.py b/r2/r2/lib/emr_helpers.py index c53ace378..342755d5f 100644 --- a/r2/r2/lib/emr_helpers.py +++ b/r2/r2/lib/emr_helpers.py @@ -220,7 +220,8 @@ class EmrJob(object): bootstrap_actions=[], log_uri=None, keep_alive=True, ec2_keyname=None, hadoop_version='0.20.205', ami_version='latest', master_instance_type='m1.small', - slave_instance_type='m1.small', num_slaves=1): + slave_instance_type='m1.small', num_slaves=1, + visible_to_all_users=True): self.jobflowid = None self.conn = emr_connection @@ -237,6 +238,7 @@ class EmrJob(object): self.master_instance_type = master_instance_type self.slave_instance_type = slave_instance_type self.num_instances = num_slaves + 1 + self.visible_to_all_users = visible_to_all_users def run(self): steps = copy(self.setup_steps) @@ -250,7 +252,8 @@ class EmrJob(object): slave_instance_type=self.slave_instance_type, num_instances=self.num_instances, enable_debugging=self.enable_debugging, - log_uri=self.log_uri) + log_uri=self.log_uri, + visible_to_all_users=self.visible_to_all_users) self.jobflowid = self.conn.run_jobflow(**job_flow_args) return