diff --git a/vector/replay-capture/tests.yaml b/vector/replay-capture/tests.yaml index d36ea0ea88019..01b8a082739e0 100644 --- a/vector/replay-capture/tests.yaml +++ b/vector/replay-capture/tests.yaml @@ -43,9 +43,6 @@ tests: .timestamp = now() ."_" = "123456789" %token = "limited_token" - - # we can't properly check things that we verify in the capture decoding vrl sadly :( - %quota_limited = true outputs: - conditions: - source: | diff --git a/vector/replay-capture/vector.yaml b/vector/replay-capture/vector.yaml index feb30ef7fa3cc..23f8052e29f53 100644 --- a/vector/replay-capture/vector.yaml +++ b/vector/replay-capture/vector.yaml @@ -63,15 +63,7 @@ sources: assert!(is_string(.message[0].properties."$$session_id"), "$$session_id is required") assert!(is_string(%token), "token is required") - _, err = get_enrichment_table_record("quota_limited_teams", { "token": %token }) - # get_enrichment_table_record returns an err if record is not found - # that means err == null iff we found the quota limited record - %quota_limited = err == null - %response = {"status": 1} - if %quota_limited { - %response.quota_limited = ["recordings"] - } transforms: quota_check: @@ -82,7 +74,8 @@ transforms: quota_limited: type: vrl source: | - %quota_limited == true + _, err = get_enrichment_table_record("quota_limited_teams", { "token": %token }) + err == null # err is not null if row not found, we want to drop where the row _is_ found events_parsed: type: remap