diff --git a/warden_server/test_warden_server.py b/warden_server/test_warden_server.py
index e76e35645e926c7536c472f87bcd7ea1948dccbe..4d1a84c4ecbb1bb16b5233009a04c6cdacc5a01d 100755
--- a/warden_server/test_warden_server.py
+++ b/warden_server/test_warden_server.py
@@ -413,7 +413,8 @@ def init_user():
     try:
         conn = my.connect(user='root', passwd=getpass.getpass('Enter MySQL Root password:'))
         with conn.cursor() as cur:
-            cur.execute("GRANT SELECT, INSERT, UPDATE, CREATE, DELETE, DROP ON *.* TO %s@'localhost' IDENTIFIED BY %s", (USER, PASSWORD))
+            cur.execute("CREATE USER IF NOT EXISTS %s@'localhost' IDENTIFIED BY %s", (USER, PASSWORD))
+            cur.execute("GRANT SELECT, INSERT, UPDATE, CREATE, DELETE, DROP ON *.* TO %s@'localhost'", (USER,))
         conn.commit()
         print("DB User set up successfuly")
     except my.OperationalError as ex: