diff --git a/tests/bats/99_lapi-stream-mode.bats b/tests/bats/99_lapi-stream-mode.bats
index f1190d52a..1fa93fade 100644
--- a/tests/bats/99_lapi-stream-mode.bats
+++ b/tests/bats/99_lapi-stream-mode.bats
@@ -37,24 +37,24 @@ api() {
 
 @test "$FILE stream start" {
     run -0 api "/v1/decisions/stream?startup=true"
+    [[ "$DB_BACKEND" == "mysql" ]] && sleep 3
     run -0 jq -r '.new' <(output)
     assert_output --partial '1111:2222:3333:4444:5555:6666:7777:8888'
     assert_output --partial '1.2.3.4'
     assert_output --partial '1.2.4.0/24'
-
 }
 
 @test "$FILE stream cont (add)" {
-    sleep 1
     run -0 cscli decisions add -i '1.2.3.5'
+    [[ "$DB_BACKEND" == "mysql" ]] && sleep 3
     run -0 api "/v1/decisions/stream"
     run -0 jq -r '.new' <(output)
     assert_output --partial '1.2.3.5'
 }
 
 @test "$FILE stream cont (del)" {
-    sleep 1
     run -0 cscli decisions delete -i '1.2.3.4'
+    [[ "$DB_BACKEND" == "mysql" ]] && sleep 3
     run -0 api "/v1/decisions/stream"
     run -0 jq -r '.deleted' <(output)
     assert_output --partial '1.2.3.4'
diff --git a/tests/lib/db/instance-mysql b/tests/lib/db/instance-mysql
index 6e03e32c7..036c00a29 100755
--- a/tests/lib/db/instance-mysql
+++ b/tests/lib/db/instance-mysql
@@ -78,7 +78,8 @@ restore() {
         "--port=${MYSQL_PORT}" \
         "--password=${MYSQL_PASSWORD}" < "$backup_file"
 
-    exec_sql "CREATE USER IF NOT EXISTS 'crowdsec_test' IDENTIFIED BY 'crowdsec_test';"
+    exec_sql "DROP USER IF EXISTS 'crowdsec_test';"
+    exec_sql "CREATE USER 'crowdsec_test' IDENTIFIED BY 'crowdsec_test';"
     exec_sql "GRANT ALL PRIVILEGES ON crowdsec_test.* TO 'crowdsec_test';"
 }