Fixed tabulations

[plstackapi.git] / planetstack / ec2_observer / steps / sync_nodes.py

diff --git a/planetstack/ec2_observer/steps/sync_nodes.py b/planetstack/ec2_observer/steps/sync_nodes.py
index 9dc00f2..9f032ed 100644 (file)
--- a/planetstack/ec2_observer/steps/sync_nodes.py
+++ b/planetstack/ec2_observer/steps/sync_nodes.py
@@ -12,40 +12,40 @@ from ec2_observer.awslib import *
 import pdb
 
 class SyncNodes(SyncStep):
-       provides=[Node]
-       requested_interval=0
+    provides=[Node]
+    requested_interval=0
 
-       def fetch_pending(self, deletion):
+    def fetch_pending(self, deletion):
         if (deletion):
             return []
 
-               deployment = Deployment.objects.filter(Q(name="Amazon EC2"))[0]
-               current_site_deployments = SiteDeployments.objects.filter(Q(deployment=deployment))
+        deployment = Deployment.objects.filter(Q(name="Amazon EC2"))[0]
+        current_site_deployments = SiteDeployments.objects.filter(Q(deployment=deployment))
 
-               zone_ret = aws_run('ec2 describe-availability-zones')
-               zones = zone_ret['AvailabilityZones']
+        zone_ret = aws_run('ec2 describe-availability-zones')
+        zones = zone_ret['AvailabilityZones']
 
-               # collect local nodes
-               instance_types = 'm1.small | m1.medium | m1.large | m1.xlarge | m3.medium | m3.large | m3.xlarge | m3.2xlarge'.split(' | ')
+        # collect local nodes
+        instance_types = 'm1.small | m1.medium | m1.large | m1.xlarge | m3.medium | m3.large | m3.xlarge | m3.2xlarge'.split(' | ')
 
-               all_new_nodes = []
-               for sd in current_site_deployments:
-                       s = sd.site
-                       current_fqns = [n.name for n in s.nodes.all()]
-                       all_fqns = ['.'.join([n,s.name]) for n in instance_types]
-                       new_node_names = list(set(all_fqns) - set(current_fqns))
+        all_new_nodes = []
+        for sd in current_site_deployments:
+            s = sd.site
+            current_fqns = [n.name for n in s.nodes.all()]
+            all_fqns = ['.'.join([n,s.name]) for n in instance_types]
+            new_node_names = list(set(all_fqns) - set(current_fqns))
 
-                       new_nodes = []
-                       for node_name in new_node_names:
-                               node = Node(name=node_name,
-                                                       site=s,deployment=deployment)
-                               new_nodes.append(node)
+            new_nodes = []
+            for node_name in new_node_names:
+                node = Node(name=node_name,
+                            site=s,deployment=deployment)
+                new_nodes.append(node)
 
-                       all_new_nodes.extend(new_nodes)
+            all_new_nodes.extend(new_nodes)
 
-               return all_new_nodes
-                                
+        return all_new_nodes
+                 
 
-       def sync_record(self, node):
-               node.save()
-                 
+    def sync_record(self, node):
+        node.save()
+