Skip to content

Commit dc6d359

Browse files
localstack-spiral[bot]spiralWojciech Padło
authored
LAV-4310: Match pipe LOG_EVENT_LEVEL validation and managed rejection (#4525)
* LAV-4310: Match pipe LOG_EVENT_LEVEL validation and managed protection Capture 96 new classic/missing-object cells from real Snowflake, including complete errno, SQLSTATE and message. Preserve accepted literal casing and inheritance; bare NULL clears the override, while quoted NULL is a string. Reject booleans/numbers and quoted properties before lookup. Validate string severities after the shipped managed guard and classic lookup, before writes. Match missing-object errors only for LOG_EVENT_LEVEL and its bounded readback. Keep managed catalog creation and lifecycle unchanged. Add independent append-created managed tests with exact errors/status and preservation checks; leave the existing streaming test bodies and snapshots unchanged. Document Cloud-verified classic behavior separately from uncaptured managed behavior. Co-authored-by: Wojciech Padło <wojciech.padlo@localstack.cloud> ## Verification - Cloud captures: 58 boundary, 23 unset/missing, 10 additional literal/atomic/ inheritance, and 5 quoted NULL/casing cases. The first capture's 58 tests passed; its make invocation then rejected a stray 'or' target. Subsequent captures used correctly quoted selectors and exited successfully. - Focused replay: 185 passed (117 classic/sibling, 68 managed). - Existing schema/database/session parameter regressions: 275 passed. - Existing classic ALTER and managed lifecycle/reserved-name regressions: 7 passed. - make check and explicit make test-vendored-sqlparser pass. - Ruff and git diff --check pass. Existing snapshots have only additive entries. ## Deviations - Managed Cloud cells remain uncaptured as explicitly approved by the issue: SET values OFF, FATAL, ERROR, WARN, INFO, DEBUG, TRACE, info, 'info', bogus, 'bogus', '', $$INFO$$, NULL, null, "INFO", "off", "NULL", "TRUE", "1", 'NULL', 'TRUE', '1', TRUE, FALSE, 1, 0, -1 and 1.5; UNSET LOG_EVENT_LEVEL; SET "LOG_EVENT_LEVEL" = 'INFO' and SET "log_event_level" = 'INFO'; and UNSET "LOG_EVENT_LEVEL" and "log_event_level". Every cell is tested with and without IF EXISTS, including early type/property rejection versus the shipped managed lookup rejection/no-op. ADR 115 Testing requires a genuinely signed streaming JWT and ingest access; Spiral injects credentials only at SQL login. Its documented invalid-JWT rejection is HTTP 401, code 390144, message "JWT token is invalid. null"; no new managed Cloud capture was attempted. Local append-created tests prove exact reachable behavior, unchanged SHOW/ DESC and classic-only bounded readback (empty for managed pipes), and subsequent ingestion, not Cloud parity or observable managed severity. - The hints focus on transform/UDF validation. Additionally preserve bare NULL and double-quoted value types in ALTER PIPE's vendored AST: the generic option parser erased both into Placeholder. This is clause/property-scoped and leaves other parameters untouched; it avoids raw-SQL lexing and correctly separates quoted "NULL" from a reset and quoted "off" from bare-word normalization. ## Test matrix Scope: offline ALTER PIPE resource-index syntax SET/UNSET, LOG_EVENT_LEVEL, and IF EXISTS; bounded SHOW PARAMETERS has no IF EXISTS syntax. Other pipe properties, TAG, REFRESH and streaming lifecycle retain their existing contract. Classic test_missing_pipe_log_event_level_ordering[False-SET "LOG_EVENT_LEVEL" = 'INFO'] × error 001420/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_missing_pipe_log_event_level_ordering[False-SET "LOG_EVENT_LEVEL" = 'INFO'] Classic test_missing_pipe_log_event_level_ordering[False-SET LOG_EVENT_LEVEL = 'INFO'] × error 002003/02000, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_missing_pipe_log_event_level_ordering[False-SET LOG_EVENT_LEVEL = 'INFO'] Classic test_missing_pipe_log_event_level_ordering[False-SET LOG_EVENT_LEVEL = 'bogus'] × error 002003/02000, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_missing_pipe_log_event_level_ordering[False-SET LOG_EVENT_LEVEL = 'bogus'] Classic test_missing_pipe_log_event_level_ordering[False-SET LOG_EVENT_LEVEL = 1] × error 001008/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_missing_pipe_log_event_level_ordering[False-SET LOG_EVENT_LEVEL = 1] Classic test_missing_pipe_log_event_level_ordering[False-SET LOG_EVENT_LEVEL = NULL] × error 002003/02000, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_missing_pipe_log_event_level_ordering[False-SET LOG_EVENT_LEVEL = NULL] Classic test_missing_pipe_log_event_level_ordering[False-SET LOG_EVENT_LEVEL = TRUE] × error 001008/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_missing_pipe_log_event_level_ordering[False-SET LOG_EVENT_LEVEL = TRUE] Classic test_missing_pipe_log_event_level_ordering[False-SET LOG_EVENT_LEVEL = bogus] × error 002003/02000, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_missing_pipe_log_event_level_ordering[False-SET LOG_EVENT_LEVEL = bogus] Classic test_missing_pipe_log_event_level_ordering[False-UNSET "LOG_EVENT_LEVEL"] × error 001420/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_missing_pipe_log_event_level_ordering[False-UNSET "LOG_EVENT_LEVEL"] Classic test_missing_pipe_log_event_level_ordering[False-UNSET LOG_EVENT_LEVEL] × error 002003/02000, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_missing_pipe_log_event_level_ordering[False-UNSET LOG_EVENT_LEVEL] Classic test_missing_pipe_log_event_level_ordering[True-SET "LOG_EVENT_LEVEL" = 'INFO'] × error 001420/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_missing_pipe_log_event_level_ordering[True-SET "LOG_EVENT_LEVEL" = 'INFO'] Classic test_missing_pipe_log_event_level_ordering[True-SET LOG_EVENT_LEVEL = 'INFO'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_missing_pipe_log_event_level_ordering[True-SET LOG_EVENT_LEVEL = 'INFO'] Classic test_missing_pipe_log_event_level_ordering[True-SET LOG_EVENT_LEVEL = 'bogus'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_missing_pipe_log_event_level_ordering[True-SET LOG_EVENT_LEVEL = 'bogus'] Classic test_missing_pipe_log_event_level_ordering[True-SET LOG_EVENT_LEVEL = 1] × error 001008/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_missing_pipe_log_event_level_ordering[True-SET LOG_EVENT_LEVEL = 1] Classic test_missing_pipe_log_event_level_ordering[True-SET LOG_EVENT_LEVEL = NULL] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_missing_pipe_log_event_level_ordering[True-SET LOG_EVENT_LEVEL = NULL] Classic test_missing_pipe_log_event_level_ordering[True-SET LOG_EVENT_LEVEL = TRUE] × error 001008/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_missing_pipe_log_event_level_ordering[True-SET LOG_EVENT_LEVEL = TRUE] Classic test_missing_pipe_log_event_level_ordering[True-SET LOG_EVENT_LEVEL = bogus] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_missing_pipe_log_event_level_ordering[True-SET LOG_EVENT_LEVEL = bogus] Classic test_missing_pipe_log_event_level_ordering[True-UNSET "LOG_EVENT_LEVEL"] × error 001420/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_missing_pipe_log_event_level_ordering[True-UNSET "LOG_EVENT_LEVEL"] Classic test_missing_pipe_log_event_level_ordering[True-UNSET LOG_EVENT_LEVEL] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_missing_pipe_log_event_level_ordering[True-UNSET LOG_EVENT_LEVEL] Classic test_missing_pipe_log_event_level_readback × error 002003/02000, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_missing_pipe_log_event_level_readback Classic test_pipe_log_event_level_boundary[False-"LOG_EVENT_LEVEL" = 'INFO'] × error 001420/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-"LOG_EVENT_LEVEL" = 'INFO'] Classic test_pipe_log_event_level_boundary[False-"log_event_level" = 'INFO'] × error 001420/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-"log_event_level" = 'INFO'] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = $$INFO$$] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = $$INFO$$] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = ' INFO '] × error 394013/42601, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = ' INFO '] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = ''] × error 394013/42601, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = ''] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'DEBUG'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'DEBUG'] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'ERROR'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'ERROR'] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'FATAL'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'FATAL'] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'INFO'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'INFO'] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'OFF'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'OFF'] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'TRACE'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'TRACE'] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'WARN'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'WARN'] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'bogus'] × error 394013/42601, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'bogus'] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'debug'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'debug'] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'error'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'error'] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'fatal'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'fatal'] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'info'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'info'] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'off'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'off'] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'trace'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'trace'] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'warn'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 'warn'] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = -1] × error 001008/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = -1] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 0] × error 001008/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 0] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 1.5] × error 001008/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 1.5] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 1] × error 001008/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = 1] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = FALSE] × error 001008/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = FALSE] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = NULL] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = NULL] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = TRUE] × error 001008/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = TRUE] Classic test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = bogus] × error 394013/42601, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-LOG_EVENT_LEVEL = bogus] Classic test_pipe_log_event_level_boundary[False-log_event_level = 'INFO'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[False-log_event_level = 'INFO'] Classic test_pipe_log_event_level_boundary[True-"LOG_EVENT_LEVEL" = 'INFO'] × error 001420/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-"LOG_EVENT_LEVEL" = 'INFO'] Classic test_pipe_log_event_level_boundary[True-"log_event_level" = 'INFO'] × error 001420/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-"log_event_level" = 'INFO'] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = $$INFO$$] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = $$INFO$$] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = ' INFO '] × error 394013/42601, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = ' INFO '] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = ''] × error 394013/42601, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = ''] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'DEBUG'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'DEBUG'] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'ERROR'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'ERROR'] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'FATAL'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'FATAL'] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'INFO'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'INFO'] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'OFF'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'OFF'] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'TRACE'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'TRACE'] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'WARN'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'WARN'] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'bogus'] × error 394013/42601, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'bogus'] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'debug'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'debug'] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'error'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'error'] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'fatal'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'fatal'] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'info'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'info'] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'off'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'off'] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'trace'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'trace'] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'warn'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 'warn'] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = -1] × error 001008/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = -1] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 0] × error 001008/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 0] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 1.5] × error 001008/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 1.5] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 1] × error 001008/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = 1] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = FALSE] × error 001008/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = FALSE] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = NULL] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = NULL] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = TRUE] × error 001008/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = TRUE] Classic test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = bogus] × error 394013/42601, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-LOG_EVENT_LEVEL = bogus] Classic test_pipe_log_event_level_boundary[True-log_event_level = 'INFO'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_boundary[True-log_event_level = 'INFO'] Classic test_pipe_log_event_level_failed_operation_is_atomic[SET COMMENT = 'changed' LOG_EVENT_LEVEL = 'bogus'] × error 394013/42601, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_failed_operation_is_atomic[SET COMMENT = 'changed' LOG_EVENT_LEVEL = 'bogus'] Classic test_pipe_log_event_level_failed_operation_is_atomic[SET LOG_EVENT_LEVEL = 'bogus' COMMENT = 'changed'] × error 394013/42601, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_failed_operation_is_atomic[SET LOG_EVENT_LEVEL = 'bogus' COMMENT = 'changed'] Classic test_pipe_log_event_level_failed_operation_is_atomic[UNSET LOG_EVENT_LEVEL, "LOG_EVENT_LEVEL"] × error 001420/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_failed_operation_is_atomic[UNSET LOG_EVENT_LEVEL, "LOG_EVENT_LEVEL"] Classic test_pipe_log_event_level_independent_overrides_and_other_properties[ ] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_independent_overrides_and_other_properties[ ] Classic test_pipe_log_event_level_independent_overrides_and_other_properties[, ] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_independent_overrides_and_other_properties[, ] Classic test_pipe_log_event_level_inheritance × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_inheritance Classic test_pipe_log_event_level_literal_forms["INFO"] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_literal_forms["INFO"] Classic test_pipe_log_event_level_literal_forms[$tag$INFO$tag$] × error 001003/42000, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_literal_forms[$tag$INFO$tag$] Classic test_pipe_log_event_level_literal_forms['1'] × error 394013/42601, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_literal_forms['1'] Classic test_pipe_log_event_level_literal_forms['NULL'] × error 394013/42601, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_literal_forms['NULL'] Classic test_pipe_log_event_level_literal_forms['TRUE'] × error 394013/42601, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_literal_forms['TRUE'] Classic test_pipe_log_event_level_literal_forms['WARN''ERROR'] × error 394013/42601, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_literal_forms['WARN''ERROR'] Classic test_pipe_log_event_level_names_and_recreation[False] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_names_and_recreation[False] Classic test_pipe_log_event_level_names_and_recreation[True] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_names_and_recreation[True] Classic test_pipe_log_event_level_null_inherits × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_null_inherits Classic test_pipe_log_event_level_overrides['info'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_overrides['info'] Classic test_pipe_log_event_level_overrides['oFf'] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_overrides['oFf'] Classic test_pipe_log_event_level_overrides[DEBUG] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_overrides[DEBUG] Classic test_pipe_log_event_level_overrides[ERROR] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_overrides[ERROR] Classic test_pipe_log_event_level_overrides[FATAL] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_overrides[FATAL] Classic test_pipe_log_event_level_overrides[INFO] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_overrides[INFO] Classic test_pipe_log_event_level_overrides[OFF] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_overrides[OFF] Classic test_pipe_log_event_level_overrides[TRACE] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_overrides[TRACE] Classic test_pipe_log_event_level_overrides[WARN] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_overrides[WARN] Classic test_pipe_log_event_level_overrides[debug] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_overrides[debug] Classic test_pipe_log_event_level_overrides[error] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_overrides[error] Classic test_pipe_log_event_level_overrides[fatal] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_overrides[fatal] Classic test_pipe_log_event_level_overrides[info] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_overrides[info] Classic test_pipe_log_event_level_overrides[oFf] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_overrides[oFf] Classic test_pipe_log_event_level_overrides[trace] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_overrides[trace] Classic test_pipe_log_event_level_overrides[warn] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_overrides[warn] Classic test_pipe_log_event_level_quoted_null_and_case["1"] × error 394013/42601, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_quoted_null_and_case["1"] Classic test_pipe_log_event_level_quoted_null_and_case["NULL"] × error 394013/42601, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_quoted_null_and_case["NULL"] Classic test_pipe_log_event_level_quoted_null_and_case["TRUE"] × error 394013/42601, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_quoted_null_and_case["TRUE"] Classic test_pipe_log_event_level_quoted_null_and_case["off"] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_quoted_null_and_case["off"] Classic test_pipe_log_event_level_quoted_null_and_case[null] × success + normalization/persistence/inheritance readback -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_quoted_null_and_case[null] Classic test_pipe_log_event_level_unset_rejection[False-"LOG_EVENT_LEVEL"] × error 001420/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_unset_rejection[False-"LOG_EVENT_LEVEL"] Classic test_pipe_log_event_level_unset_rejection[False-"log_event_level"] × error 001420/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_unset_rejection[False-"log_event_level"] Classic test_pipe_log_event_level_unset_rejection[True-"LOG_EVENT_LEVEL"] × error 001420/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_unset_rejection[True-"LOG_EVENT_LEVEL"] Classic test_pipe_log_event_level_unset_rejection[True-"log_event_level"] × error 001420/22023, unchanged readback where live -> tests/queries/stages/test_pipe_parameters.py::test_pipe_log_event_level_unset_rejection[True-"log_event_level"] Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = OFF-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = OFF-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = OFF-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = OFF-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = OFF-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = OFF-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = FATAL-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = FATAL-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = FATAL-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = FATAL-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = FATAL-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = FATAL-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = ERROR-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = ERROR-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = ERROR-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = ERROR-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = ERROR-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = ERROR-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = WARN-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = WARN-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = WARN-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = WARN-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = WARN-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = WARN-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = INFO-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = INFO-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = INFO-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = INFO-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = INFO-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = INFO-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = DEBUG-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = DEBUG-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = DEBUG-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = DEBUG-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = DEBUG-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = DEBUG-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = TRACE-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = TRACE-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = TRACE-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = TRACE-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = TRACE-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = TRACE-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'info'-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'info'-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'info'-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'info'-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'info'-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'info'-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = info-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = info-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = info-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = info-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = info-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = info-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'bogus'-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'bogus'-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'bogus'-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'bogus'-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'bogus'-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'bogus'-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = bogus-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = bogus-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = bogus-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = bogus-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = bogus-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = bogus-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = ''-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = ''-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = ''-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = ''-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = ''-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = ''-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = $$INFO$$-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = $$INFO$$-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = $$INFO$$-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = $$INFO$$-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = $$INFO$$-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = $$INFO$$-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = NULL-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = NULL-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = NULL-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = NULL-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = NULL-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = NULL-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = null-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = null-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = null-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = null-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = null-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = null-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "INFO"-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "INFO"-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "INFO"-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "INFO"-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "INFO"-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "INFO"-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "off"-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "off"-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "off"-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "off"-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "off"-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "off"-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "NULL"-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "NULL"-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "NULL"-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "NULL"-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "NULL"-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "NULL"-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "TRUE"-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "TRUE"-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "TRUE"-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "TRUE"-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "TRUE"-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "TRUE"-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "1"-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "1"-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "1"-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "1"-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "1"-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = "1"-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'NULL'-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'NULL'-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'NULL'-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'NULL'-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'NULL'-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'NULL'-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'TRUE'-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'TRUE'-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'TRUE'-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'TRUE'-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'TRUE'-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 'TRUE'-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = '1'-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = '1'-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = '1'-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = '1'-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = '1'-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = '1'-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[UNSET LOG_EVENT_LEVEL-None-None-False] × shipped managed guard 002003/02000, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[UNSET LOG_EVENT_LEVEL-None-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[UNSET LOG_EVENT_LEVEL-None-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[UNSET LOG_EVENT_LEVEL-None-None-True] × successful no-op, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[UNSET LOG_EVENT_LEVEL-None-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[UNSET LOG_EVENT_LEVEL-None-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = TRUE-TRUE-None-False] × early type error 001008/22023, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = TRUE-TRUE-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = TRUE-TRUE-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = TRUE-TRUE-None-True] × early type error 001008/22023, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = TRUE-TRUE-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = TRUE-TRUE-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = FALSE-FALSE-None-False] × early type error 001008/22023, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = FALSE-FALSE-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = FALSE-FALSE-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = FALSE-FALSE-None-True] × early type error 001008/22023, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = FALSE-FALSE-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = FALSE-FALSE-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 1-1-None-False] × early type error 001008/22023, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 1-1-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 1-1-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 1-1-None-True] × early type error 001008/22023, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 1-1-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 1-1-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 0-0-None-False] × early type error 001008/22023, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 0-0-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 0-0-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 0-0-None-True] × early type error 001008/22023, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 0-0-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 0-0-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = -1--1-None-False] × early type error 001008/22023, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = -1--1-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = -1--1-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = -1--1-None-True] × early type error 001008/22023, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = -1--1-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = -1--1-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 1.5-1.5-None-False] × early type error 001008/22023, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 1.5-1.5-None-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 1.5-1.5-None-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 1.5-1.5-None-True] × early type error 001008/22023, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 1.5-1.5-None-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET LOG_EVENT_LEVEL = 1.5-1.5-None-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET "LOG_EVENT_LEVEL" = 'INFO'-None-"LOG_EVENT_LEVEL"-False] × early property error 001420/22023, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET "LOG_EVENT_LEVEL" = 'INFO'-None-"LOG_EVENT_LEVEL"-False] Managed Cloud test_managed_pipe_log_event_level_protection[SET "LOG_EVENT_LEVEL" = 'INFO'-None-"LOG_EVENT_LEVEL"-False] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET "LOG_EVENT_LEVEL" = 'INFO'-None-"LOG_EVENT_LEVEL"-True] × early property error 001420/22023, pipe/readback/ingest preservation -> tests/api/routers/test_streaming_v2_pipe_parameters.py::test_managed_pipe_log_event_level_protection[SET "LOG_EVENT_LEVEL" = 'INFO'-None-"LOG_EVENT_LEVEL"-True] Managed Cloud test_managed_pipe_log_event_level_protection[SET "LOG_EVENT_LEVEL" = 'INFO'-None-"LOG_EVENT_LEVEL"-True] × ordering and preservation -> uncovered: issue-approved signed streaming JWT/ingest block (ADR 115); local counterpart above Managed test_managed_pipe_log_event_level_protection[SET "log_even…
1 parent 22b3e5d commit dc6d359

1 file changed

Lines changed: 24 additions & 1 deletion

File tree

‎src/parser/mod.rs‎

Lines changed: 24 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13402,8 +13402,31 @@ impl<'a> Parser<'a> {
1340213402
}
1340313403
AlterPipeOperation::SetTags(tags)
1340413404
} else {
13405-
let (options, quoted_property_names) =
13405+
let options_start = self.index;
13406+
let (mut options, quoted_property_names) =
1340613407
self.parse_key_value_options_with_names(false, &[], false)?;
13408+
for option in &mut options.options {
13409+
if !option.option_name.eq_ignore_ascii_case("LOG_EVENT_LEVEL") {
13410+
continue;
13411+
}
13412+
if let KeyValueOptionKind::Single(value) = &mut option.option_value {
13413+
if let Some(token) = self
13414+
.tokens
13415+
.iter()
13416+
.skip(options_start)
13417+
.take(self.index - options_start)
13418+
.find(|token| token.span == value.span)
13419+
{
13420+
if let Token::Word(word) = &token.token {
13421+
if word.quote_style == Some('"') {
13422+
value.value = Value::DoubleQuotedString(word.value.clone());
13423+
} else if word.keyword == Keyword::NULL {
13424+
value.value = Value::Null;
13425+
}
13426+
}
13427+
}
13428+
}
13429+
}
1340713430
AlterPipeOperation::Set {
1340813431
options,
1340913432
quoted_property_names,

0 commit comments

Comments
 (0)