diff --git a/internal/answerwc/to_client.go b/internal/answerwc/to_client.go
index 47a1fe6..b3e3073 100644
--- a/internal/answerwc/to_client.go
+++ b/internal/answerwc/to_client.go
@@ -140,7 +140,7 @@ func (w *SendToClient) processPendingAnswer(ctx context.Context) {
 				return
 			}
 
-			allAnswersDirty, err := w.dal.AnswerRepo.GetAllAnswersByQuizID(ctx, answer.Session)
+			allAnswersDirty, err := w.dal.WorkerAnsRepo.GetAllAnswersByQuizID(ctx, answer.Session)
 			fmt.Println("ANS4", err)
 			if err != nil {
 				w.reportError(err, "Error getting all answers by quizID")