diff --git a/dal/dal.go b/dal/dal.go
index 9820a9b..6ed2fde 100644
--- a/dal/dal.go
+++ b/dal/dal.go
@@ -362,3 +362,11 @@ func NewYclientsDal(ctx context.Context, cred string) (*YclientsDal, error) {
 		AnswerRepo:   answerRepo,
 	}, nil
 }
+
+func (d *YclientsDal) Close(ctx context.Context) error {
+	err := d.conn.Close()
+	if err != nil {
+		return err
+	}
+	return nil
+}