diff --git a/planetstack/ec2_observer/steps/sync_nodes.py b/planetstack/ec2_observer/steps/sync_nodes.py
index 9dc00f2..9f032ed 100644
--- a/planetstack/ec2_observer/steps/sync_nodes.py
+++ b/planetstack/ec2_observer/steps/sync_nodes.py
@@ -12,40 +12,40 @@
 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()
+