diff --git a/pkg/exchange/batch/funding_fee.go b/pkg/exchange/batch/funding_fee.go
index 98c1453f0..3d9941894 100644
--- a/pkg/exchange/batch/funding_fee.go
+++ b/pkg/exchange/batch/funding_fee.go
@@ -18,7 +18,7 @@ type BinanceFuturesIncomeBatchQuery struct {
 	BinanceFuturesIncomeHistoryService
 }
 
-func (e *BinanceFuturesIncomeBatchQuery) Query(ctx context.Context, symbol string, incomeType binanceapi.FuturesIncomeType, startTime, endTime time.Time) (c chan types.MarginInterest, errC chan error) {
+func (e *BinanceFuturesIncomeBatchQuery) Query(ctx context.Context, symbol string, incomeType binanceapi.FuturesIncomeType, startTime, endTime time.Time) (c chan binanceapi.FuturesIncome, errC chan error) {
 	query := &AsyncTimeRangedBatchQuery{
 		Type:        types.MarginInterest{},
 		Limiter:     rate.NewLimiter(rate.Every(3*time.Second), 1),