test: Avoid dumping raw snabbkaffe traces to the console
This commit is contained in:
parent
180130d684
commit
d12966db5b
|
@ -252,7 +252,6 @@ t_session_subscription_idempotency(Config) ->
|
||||||
ok
|
ok
|
||||||
end,
|
end,
|
||||||
fun(Trace) ->
|
fun(Trace) ->
|
||||||
ct:pal("trace:\n ~p", [Trace]),
|
|
||||||
Session = session_open(Node1, ClientId),
|
Session = session_open(Node1, ClientId),
|
||||||
?assertMatch(
|
?assertMatch(
|
||||||
#{SubTopicFilter := #{}},
|
#{SubTopicFilter := #{}},
|
||||||
|
@ -326,7 +325,6 @@ t_session_unsubscription_idempotency(Config) ->
|
||||||
ok
|
ok
|
||||||
end,
|
end,
|
||||||
fun(Trace) ->
|
fun(Trace) ->
|
||||||
ct:pal("trace:\n ~p", [Trace]),
|
|
||||||
Session = session_open(Node1, ClientId),
|
Session = session_open(Node1, ClientId),
|
||||||
?assertEqual(
|
?assertEqual(
|
||||||
#{},
|
#{},
|
||||||
|
@ -415,10 +413,7 @@ do_t_session_discard(Params) ->
|
||||||
|
|
||||||
ok
|
ok
|
||||||
end,
|
end,
|
||||||
fun(Trace) ->
|
[]
|
||||||
ct:pal("trace:\n ~p", [Trace]),
|
|
||||||
ok
|
|
||||||
end
|
|
||||||
),
|
),
|
||||||
ok.
|
ok.
|
||||||
|
|
||||||
|
|
|
@ -581,7 +581,6 @@ t_write_failure(Config) ->
|
||||||
)
|
)
|
||||||
end),
|
end),
|
||||||
fun(Trace0) ->
|
fun(Trace0) ->
|
||||||
ct:pal("trace: ~p", [Trace0]),
|
|
||||||
Trace = ?of_kind(
|
Trace = ?of_kind(
|
||||||
[buffer_worker_flush_nack, buffer_worker_retry_inflight_failed], Trace0
|
[buffer_worker_flush_nack, buffer_worker_retry_inflight_failed], Trace0
|
||||||
),
|
),
|
||||||
|
|
|
@ -1929,7 +1929,6 @@ t_bad_attributes(Config) ->
|
||||||
ok
|
ok
|
||||||
end,
|
end,
|
||||||
fun(Trace) ->
|
fun(Trace) ->
|
||||||
ct:pal("trace:\n ~p", [Trace]),
|
|
||||||
?assertMatch(
|
?assertMatch(
|
||||||
[
|
[
|
||||||
#{placeholder := [<<"payload">>, <<"ok">>], value := #{}},
|
#{placeholder := [<<"payload">>, <<"ok">>], value := #{}},
|
||||||
|
|
|
@ -517,7 +517,6 @@ t_write_failure(Config) ->
|
||||||
ok
|
ok
|
||||||
end,
|
end,
|
||||||
fun(Trace0) ->
|
fun(Trace0) ->
|
||||||
ct:pal("trace: ~p", [Trace0]),
|
|
||||||
Trace = ?of_kind(buffer_worker_flush_nack, Trace0),
|
Trace = ?of_kind(buffer_worker_flush_nack, Trace0),
|
||||||
?assertMatch([#{result := {error, _}} | _], Trace),
|
?assertMatch([#{result := {error, _}} | _], Trace),
|
||||||
[#{result := {error, Error}} | _] = Trace,
|
[#{result := {error, Error}} | _] = Trace,
|
||||||
|
|
|
@ -520,7 +520,6 @@ t_write_failure(Config) ->
|
||||||
)
|
)
|
||||||
end),
|
end),
|
||||||
fun(Trace0) ->
|
fun(Trace0) ->
|
||||||
ct:pal("trace: ~p", [Trace0]),
|
|
||||||
Trace = ?of_kind(buffer_worker_flush_nack, Trace0),
|
Trace = ?of_kind(buffer_worker_flush_nack, Trace0),
|
||||||
?assertMatch([#{result := {error, _}} | _], Trace),
|
?assertMatch([#{result := {error, _}} | _], Trace),
|
||||||
[#{result := {error, Error}} | _] = Trace,
|
[#{result := {error, Error}} | _] = Trace,
|
||||||
|
|
|
@ -3346,7 +3346,6 @@ wait_n_events(NEvents, Timeout, EventName) ->
|
||||||
end.
|
end.
|
||||||
|
|
||||||
assert_sync_retry_fail_then_succeed_inflight(Trace) ->
|
assert_sync_retry_fail_then_succeed_inflight(Trace) ->
|
||||||
ct:pal(" ~p", [Trace]),
|
|
||||||
?assert(
|
?assert(
|
||||||
?strict_causality(
|
?strict_causality(
|
||||||
#{?snk_kind := buffer_worker_flush_nack, ref := _Ref},
|
#{?snk_kind := buffer_worker_flush_nack, ref := _Ref},
|
||||||
|
@ -3366,7 +3365,6 @@ assert_sync_retry_fail_then_succeed_inflight(Trace) ->
|
||||||
ok.
|
ok.
|
||||||
|
|
||||||
assert_async_retry_fail_then_succeed_inflight(Trace) ->
|
assert_async_retry_fail_then_succeed_inflight(Trace) ->
|
||||||
ct:pal(" ~p", [Trace]),
|
|
||||||
?assert(
|
?assert(
|
||||||
?strict_causality(
|
?strict_causality(
|
||||||
#{?snk_kind := handle_async_reply, action := nack},
|
#{?snk_kind := handle_async_reply, action := nack},
|
||||||
|
|
Loading…
Reference in New Issue