diff --git a/analytics/scripts/chain_activity_emitter_1d.flux b/analytics/scripts/chain_activity_emitter_1d.flux
index 5ec356a6..630290f9 100644
--- a/analytics/scripts/chain_activity_emitter_1d.flux
+++ b/analytics/scripts/chain_activity_emitter_1d.flux
@@ -6,9 +6,9 @@ runTask = (start,stop,srcBucket,destBucket,destMeasurement) => {
     data = from(bucket: srcBucket)
                  	|> range(start: start,stop: stop)
                  	|> filter(fn: (r) => r._measurement == "vaa_volume_v2" and r.version == "v2")
-                    |> filter(fn: (r) => r._field == "volume" and r._value > 0)
+                 	|> filter(fn: (r) => r._field == "volume" and r._value > 0)
                		|> drop(columns:["destination_chain","app_id","token_chain","token_address","version","_measurement","_time"])
-    				|> rename(columns: {_start: "_time"})
+               		|> rename(columns: {_start: "_time"})
                  	|> group(columns: ["emitter_chain","_time"])
 
     vols =	data
diff --git a/analytics/scripts/chain_activity_emitter_1h.flux b/analytics/scripts/chain_activity_emitter_1h.flux
index eccc9039..b61971a7 100644
--- a/analytics/scripts/chain_activity_emitter_1h.flux
+++ b/analytics/scripts/chain_activity_emitter_1h.flux
@@ -6,9 +6,9 @@ runTask = (start,stop,srcBucket,destBucket,destMeasurement) => {
     data = from(bucket: srcBucket)
                  	|> range(start: start,stop: stop)
                  	|> filter(fn: (r) => r._measurement == "vaa_volume_v2" and r.version == "v2")
-                    |> filter(fn: (r) => r._field == "volume" and r._value > 0)
+                 	|> filter(fn: (r) => r._field == "volume" and r._value > 0)
                		|> drop(columns:["destination_chain","app_id","token_chain","token_address","version","_measurement","_time"])
-    				|> rename(columns: {_start: "_time"})
+               		|> rename(columns: {_start: "_time"})
                  	|> group(columns: ["emitter_chain","_time"])
 
     vols =	data
diff --git a/analytics/scripts/chain_activity_emitter_dest_1d.flux b/analytics/scripts/chain_activity_emitter_dest_1d.flux
index 3e21e1cd..3a153cb8 100644
--- a/analytics/scripts/chain_activity_emitter_dest_1d.flux
+++ b/analytics/scripts/chain_activity_emitter_dest_1d.flux
@@ -3,8 +3,8 @@ import "date"
 runTask = (start,stop,srcBucket,destBucket,destMeasurement) => {
         data = from(bucket: srcBucket)
       		    |> range(start: start,stop: stop)
-      			|> filter(fn: (r) => r._measurement == "vaa_volume_v2" and r._field == "volume")
-      			|> group(columns: ["emitter_chain", "destination_chain", "app_id"])
+      		    |> filter(fn: (r) => r._measurement == "vaa_volume_v2" and r._field == "volume")
+      		    |> group(columns: ["emitter_chain", "destination_chain", "app_id"])
 
         data
     		|> sum(column: "_value")
diff --git a/analytics/scripts/chain_activity_emitter_dest_1h.flux b/analytics/scripts/chain_activity_emitter_dest_1h.flux
index 744b6f35..256402b4 100644
--- a/analytics/scripts/chain_activity_emitter_dest_1h.flux
+++ b/analytics/scripts/chain_activity_emitter_dest_1h.flux
@@ -5,8 +5,8 @@ runTask = (start,stop,srcBucket,destBucket,destMeasurement) => {
 
     data = from(bucket: srcBucket)
   		    |> range(start: start,stop: stop)
-  			|> filter(fn: (r) => r._measurement == "vaa_volume_v2" and r._field == "volume")
-  			|> group(columns: ["emitter_chain", "destination_chain", "app_id"])
+  		    |> filter(fn: (r) => r._measurement == "vaa_volume_v2" and r._field == "volume")
+  		    |> group(columns: ["emitter_chain", "destination_chain", "app_id"])
 
     data
 		|> sum(column: "_value")