diff --git a/repository/statistics/click_statistics.go b/repository/statistics/click_statistics.go
index 3622e56..19265ad 100644
--- a/repository/statistics/click_statistics.go
+++ b/repository/statistics/click_statistics.go
@@ -53,14 +53,14 @@ type PipeLineStatsResp [][]struct {
 	QuestionID int64
 }
 
-func (s *StatisticClick) GetPipelinesStatistics(ctx context.Context, from uint64, to uint64) ([]PipeLineStatsResp, error) {
+func (s *StatisticClick) GetPipelinesStatistics(ctx context.Context, quizID int64, from uint64, to uint64) ([]PipeLineStatsResp, error) {
 	query := `
 SELECT
     ctxsession,ctxquestionid,count(*) as session_count
-FROM mv_last_answers_events WHERE event_time BETWEEN ? AND ?
+FROM mv_last_answers_events WHERE ctxquizid = ? AND event_time BETWEEN ? AND ?
 GROUP BY ctxsession, ctxquestionid ORDER BY ctxsession, ctxquestionid
 `
-	rows, err := s.conn.QueryContext(ctx, query, from, to)
+	rows, err := s.conn.QueryContext(ctx, query, quizID, from, to)
 	if err != nil {
 		return nil, err
 	}