diff --git a/src/Managing.Infrastructure.Database/InfluxDb/AgentBalanceRepository.cs b/src/Managing.Infrastructure.Database/InfluxDb/AgentBalanceRepository.cs
index ae74ca2f..e329ae8d 100644
--- a/src/Managing.Infrastructure.Database/InfluxDb/AgentBalanceRepository.cs
+++ b/src/Managing.Infrastructure.Database/InfluxDb/AgentBalanceRepository.cs
@@ -88,6 +88,7 @@ public class AgentBalanceRepository : IAgentBalanceRepository
                        $") " +
                        $"|> filter(fn: (r) => r[\"user_id\"] == \"{userId}\") " +
                        $"|> aggregateWindow(every: {samplingInterval}, fn: last, createEmpty: false) " +
+                       $"|> drop(columns: [\"_start\", \"_stop\"])" +
                        $"|> pivot(rowKey: [\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")";
 
             var result = await query.QueryAsync<AgentBalanceDto>(flux, _influxDbRepository.Organization);
diff --git a/src/Managing.Infrastructure.Database/InfluxDb/CandleRepository.cs b/src/Managing.Infrastructure.Database/InfluxDb/CandleRepository.cs
index 4baea514..ed95ec12 100644
--- a/src/Managing.Infrastructure.Database/InfluxDb/CandleRepository.cs
+++ b/src/Managing.Infrastructure.Database/InfluxDb/CandleRepository.cs
@@ -37,6 +37,7 @@ public class CandleRepository : ICandleRepository
                        $"|> filter(fn: (r) => r[\"exchange\"] == \"{exchange}\")" +
                        $"|> filter(fn: (r) => r[\"ticker\"] == \"{ticker}\")" +
                        $"|> filter(fn: (r) => r[\"timeframe\"] == \"{timeframe}\")" +
+                       $"|> drop(columns: [\"_start\", \"_stop\"])" +
                        $"|> pivot(rowKey:[\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")";
             if (limit != null)
             {
@@ -65,6 +66,7 @@ public class CandleRepository : ICandleRepository
                        $"|> filter(fn: (r) => r[\"exchange\"] == \"{exchange}\")" +
                        $"|> filter(fn: (r) => r[\"ticker\"] == \"{ticker}\")" +
                        $"|> filter(fn: (r) => r[\"timeframe\"] == \"{timeframe}\")" +
+                       $"|> drop(columns: [\"_start\", \"_stop\"])" +
                        $"|> pivot(rowKey:[\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")";
             if (limit != null)
             {