diff --git a/pkg/exchange/batch/margin_interest.go b/pkg/exchange/batch/margin_interest.go
index 4332db1b3..5ffe823b5 100644
--- a/pkg/exchange/batch/margin_interest.go
+++ b/pkg/exchange/batch/margin_interest.go
@@ -17,6 +17,7 @@ func (e *MarginInterestBatchQuery) Query(ctx context.Context, asset string, star
 	query := &AsyncTimeRangedBatchQuery{
 		Type:    types.MarginInterest{},
 		Limiter: rate.NewLimiter(rate.Every(5*time.Second), 2),
+		JumpIfEmpty: time.Hour * 24 * 30,
 		Q: func(startTime, endTime time.Time) (interface{}, error) {
 			return e.QueryInterestHistory(ctx, asset, &startTime, &endTime)
 		},
diff --git a/pkg/exchange/batch/margin_liquidation.go b/pkg/exchange/batch/margin_liquidation.go
index babd98b82..1f4425382 100644
--- a/pkg/exchange/batch/margin_liquidation.go
+++ b/pkg/exchange/batch/margin_liquidation.go
@@ -18,6 +18,7 @@ func (e *MarginLiquidationBatchQuery) Query(ctx context.Context, startTime, endT
 	query := &AsyncTimeRangedBatchQuery{
 		Type:    types.MarginLiquidation{},
 		Limiter: rate.NewLimiter(rate.Every(5*time.Second), 2),
+		JumpIfEmpty: time.Hour * 24 * 30,
 		Q: func(startTime, endTime time.Time) (interface{}, error) {
 			return e.QueryLiquidationHistory(ctx, &startTime, &endTime)
 		},
diff --git a/pkg/exchange/batch/margin_repay.go b/pkg/exchange/batch/margin_repay.go
index 60e2bdc69..0d5c29e25 100644
--- a/pkg/exchange/batch/margin_repay.go
+++ b/pkg/exchange/batch/margin_repay.go
@@ -18,6 +18,7 @@ func (e *MarginRepayBatchQuery) Query(ctx context.Context, asset string, startTi
 	query := &AsyncTimeRangedBatchQuery{
 		Type:    types.MarginRepay{},
 		Limiter: rate.NewLimiter(rate.Every(5*time.Second), 2),
+		JumpIfEmpty: time.Hour * 24 * 30,
 		Q: func(startTime, endTime time.Time) (interface{}, error) {
 			return e.QueryRepayHistory(ctx, asset, &startTime, &endTime)
 		},