plausible/analytics
1
1
Fork 0
mirror of https://github.com/plausible/analytics.git synced 2025-01-05 17:16:44 +03:00
Code Issues Packages Projects Releases Wiki Activity

Flaky test: wait till lock is acquired (#4903)

Browse Source
This commit is contained in:
hq1 2024-12-16 12:39:36 +01:00 committed by GitHub
parent 729a32e610
commit fb2e7cda36
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
test/plausible/ingestion/event_test.exs
View File

@ -280,7 +280,10 @@ defmodule Plausible.Ingestion.EventTest do
test "drops events on session lock timeout" do test "drops events on session lock timeout" do
site = new_site() site = new_site()
test = self()
very_slow_buffer = fn sessions -> very_slow_buffer = fn sessions ->
send(test, :slow_buffer_insert_started)
Process.sleep(1000) Process.sleep(1000)
Plausible.Session.WriteBuffer.insert(sessions) Plausible.Session.WriteBuffer.insert(sessions)
end end
@ -310,11 +313,12 @@ defmodule Plausible.Ingestion.EventTest do
) )
end) end)
Process.sleep(200) receive do
:slow_buffer_insert_started ->
assert {:ok, %{buffered: [], dropped: [dropped]}} = Event.build_and_buffer(second_request) assert {:ok, %{buffered: [], dropped: [dropped]}} = Event.build_and_buffer(second_request)
assert dropped.drop_reason == :lock_timeout assert dropped.drop_reason == :lock_timeout
end end
end
test "drops pageleave event when no session found from cache" do test "drops pageleave event when no session found from cache" do
site = new_site() site = new_site()