lib/jflow/termination_protector.rb in jflow-0.4.3 vs lib/jflow/termination_protector.rb in jflow-0.4.4

@@ -16,11 +16,11 @@
     def instance_data
       @instance_data ||= JSON.parse(Net::HTTP.get(URI.parse('http://169.254.169.254/latest/dynamic/instance-identity/document')))
     end
 
     def get_asg_name
-      ec2_client = Aws::EC2::Client.new(region: region)
+      ec2_client = Aws::EC2::Client.new(region: region, credentials: Aws::InstanceProfileCredentials.new)
       instance_tags = ec2_client.describe_tags(filters: [
         {
           name: "resource-id",
           values: [instance_id]
         }
@@ -30,12 +30,12 @@
 
       asg_name
     end
 
     def set_protection(protect_status)
-      JFlow.configuration.logger.debug "Setting termination protection status to #{protect_status} for instance #{@instance_id} in region #{@region}"
+      JFlow.configuration.logger.debug "Setting termination protection status to #{protect_status} for instance #{instance_id} in region #{region}"
       begin
-        asg_client = Aws::AutoScaling::Client.new(region: region)
+        asg_client = Aws::AutoScaling::Client.new(region: region, credentials: Aws::InstanceProfileCredentials.new)
         asg_client.set_instance_protection({
           instance_ids: [instance_id],
           auto_scaling_group_name: get_asg_name,
           protected_from_scale_in: protect_status
         })