mirror of
https://github.com/openobserve/openobserve.git
synced 2026-11-04 16:09:05 +00:00
Shrinath RaoandClaude Opus 4.7
61aa772d57
## Summary
Comprehensive rework of the `tests/api-testing/` suite. 30+ commits
implementing all 6 phases of the [revamp
plan](../../tests/ui-testing/MD_Files/api%20tests%20revamp/API_TESTS_REVAMP.md).
**Before → After:**
| | Baseline | Final | Δ |
|---|---|---|---|
| passed | 421 | **443** | **+22 ✓** |
| failed | 3 | **2** | -1 (only same pre-existing) |
| skipped | 53 | 39 | -14 (unskipped dead tests now run) |
| xfailed | 1 | 2 | +1 (new visible backend-bug signal) |
| runtime | 588s | **387s** | **-201s (34% faster)** |
**Zero tests that passed in baseline are now failing.** The 2 remaining
failures are the exact pre-existing ones
(`test_enrichment_table_join.py` backend panic + `test_workflow.py` SMTP
env-miss).
## What's in the diff
- **New `support/` framework** — `OpenObserveClient`, endpoint wrappers
(`alerts`, `dashboards`, `streams`, `search`, etc.), `wait_until()`,
payload factories, pytest fixtures, SSE parser. 14 framework selfcheck
tests.
- **16 of 16 OLD-tier test files rewritten** — using the new framework,
unique-suffix names, body validation, `wait_until` instead of
`time.sleep`, parametrize where appropriate.
- **29 files moved into 12 feature folders** mirroring the UI suite
layout
(`tests/{alerts,dashboards,ingest,orgs,pipelines,regression,rum,search,streams,users,workflow}/`).
- **−6,500 LOC net** (copy-paste + dead code removal; new framework adds
back ~1,500).
- **Ruff config** in pyproject.toml: T201 ban on `print()`, PT pytest
rules, B bugbear, UP pyupgrade.
## CI workflow changes
- New job `api_regression_tests`: `strategy.matrix` over the 4 env-flag
combinations (UTF8_VIEW × JOIN_MATCH_ONE) — now runs in parallel instead
of as 4 sequential server reboots in the main job.
- New job `api_fuzz_tests`: schemathesis OpenAPI-driven fuzz against
`/api-doc/openapi.json` (214 endpoints tested). Informational
(`continue-on-error: true`). Each run surfaces **7–10 distinct 5xx
panics** (e.g., empty `sql` body returning 500 instead of 400, traces
endpoints crashing on unescaped path params that get interpolated into
SQL). Filed to backend team for separate triage.
- Server `o2_*.log` files uploaded as artifacts on failure (was:
silently lost).
- `api_tests_summary` now requires BOTH integration + regression to
pass.
### CI infrastructure fixes
A short hardening pass landed after the initial CI run surfaced several
issues:
- **pytest-sugar count inflation** — dropped `--force-sugar` from both
pytest invocations. The flag double-registered sugar on top of the
auto-loaded entry point, inflating the CI test counter ~3x (display
showed 1364 when collection was 486). Counter is now honest.
- **schemathesis 4.x flag migration** — `--base-url` → `-u`,
`--hypothesis-max-examples` → `-n`, `--hypothesis-deadline` →
`--request-timeout`, `--data-generation-method` → `-m`, dropped
`--auth-type basic`. The fuzz job was failing immediately on flag-parse
before this.
- **Regression matrix binary path** — used `${{ github.workspace
}}/target/debug/openobserve` so the absolute path resolves correctly
under `working-directory: tests/api-testing/` (was: every matrix job
failed with "No such file or directory").
- **`permissions: contents: read`** added to all 4 workflow jobs —
closes CodeQL alert #369.
- **Removed redundant server boot** in `api_integration_tests` (leftover
from main's structure after the regression matrix split; was silently
failing to bind to :5080 and getting masked by the first server).
## Backend bugs surfaced (for backend team to track)
The rework uncovered and visibly flagged these as `xfail`/documented
test comments:
1. `DELETE /api/organizations/{id}` returns 404 unconditionally even for
just-created orgs — endpoint appears unimplemented.
2. `test_dashboard_missing_required_fields` triggers backend panic
(returns 500 instead of 400/422).
3. JS `getEnrichmentTableData()` restricted to `_meta` org AND not
exposed in the `/functions/test` endpoint runtime — `ReferenceError`
even with explicit `enrichment_tables: [...]`.
4. Bulk API silently sanitizes invalid `_index` values (`****` → `_`)
without flagging — user data lands in unexpected index.
5. `AVG` of a single value drifts by ~1e-14 (likely float reduction
order; documented tolerance in `test_advanced_sql.py`).
6. Org name validation rejects hyphens (only
`A-Z/a-z/0-9/spaces/underscores`) — not in spec.
Plus 7–10 additional 5xx panics surfaced per fuzz run (input validation
gaps — separate triage list in fuzz job logs).
## Test bugs uncovered + fixed
- `test_pipeline.py`: had two function definitions named
`test_pipeline_creation_and_action_with_schedule` — Python's last-wins
meant the first test's body never executed for years.
- `test_alertsV2.py`: `assert alert_disabled == "False"` was indented
inside an `else:` branch that never executed because the response is
always a dict; AND `enabled` is a bool, not the string `"False"`. Two
layers of broken.
- `test_bulk.py`: variable typo (`valid_bulk_payload` reused on the POST
call) made the invalid-index test silently duplicate the valid case.
- `test_organisations.py`: `test_create_organization` used pre-pytest-4
`yield`-style fixtures — silently ignored by pytest 8.
- `test_js_result_array.py`: 8 tests skipped with `"Temporarily disabled
- failing test"` — the actual cause was that JS functions are restricted
to `_meta` org. One-line fix unskipped all 8.
- `test_fuzzy.py`: 4 tests `@pytest.mark.skip`-ed because they used a
1-minute time window against older static test data → 0 hits → flake →
skip. Wider window unskips them.
- 547 LOC of zombie commented-out test blocks deleted (15 commented `#
def test_` definitions, including one orphan case where the `def` was
commented but the indented body wasn't).
## Folder layout
```
tests/api-testing/
├── support/ # NEW framework
│ ├── client.py # OpenObserveClient
│ ├── endpoints/ # 7 per-resource wrappers
│ ├── factories.py # unique_name, time_window, *_payload
│ ├── wait.py # wait_until + WaitTimeout
│ ├── sse.py # read_sse_response
│ └── fixtures.py # client, temp_user_email, temp_stream_name, ...
├── helpers/ # Non-test shared code (was scattered in tests/)
│ ├── sourcemap_helpers.py
│ └── workflow/ # workflow chain + pages/ live here now
├── fixtures/
│ └── rum/ # Standalone RUM ingest scripts (was in tests/)
└── tests/
├── alerts/ # 3 files
├── dashboards/ # 4 files
├── ingest/ # 4 files
├── orgs/ # 2 files
├── pipelines/ # 10 files
├── regression/ # 2 files (env-flag matrix targets)
├── rum/ # 3 files
├── search/ # 8 files
├── streams/ # 1 file
├── users/ # 1 file
├── workflow/ # 3 files
├── conftest.py
└── test_framework_selfcheck.py
```
## Test plan
- [x] `rye run pytest --collect-only` — 486 tests discovered
- [x] Full default-set run (`--ignore=tests/regression`) — 443 pass / 2
fail / 39 skip / 2 xfail in 387s
- [x] `rye run pytest -m framework` — 14/14 selfcheck tests pass
- [x] `rye run ruff check support/ tests/test_framework_selfcheck.py` —
clean
- [x] CI run on this PR — `api_integration_tests` + all 4
`api_regression_tests` matrix jobs green
- [x] CI run — `api_fuzz_tests` runs cleanly (informational; surfaces
7–10 unique 5xx panics per run)
## Note on test count
The `test_streaming.py` rewrite folded 7 "tests" (`test_ingest_data`,
`test_ingest_join`, `test_disable_streaming`,
`test_update_max_query_range`, `test_enable_streaming`,
`test_delete_stream`, `test_delete_stream_join`) into pytest fixtures.
Each only checked `status_code == 200` of a setup/teardown operation —
they were imperative steps masquerading as tests. The fixtures still
perform the same operations and assert their success; they're just no
longer counted as discrete pytest items. **Functional coverage is
identical.**
🤖 Generated with [Claude Code](https://claude.com/claude-code)
---------
Co-authored-by: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
229 lines
16 KiB
Python
229 lines
16 KiB
Python
import sys
|
|
from pathlib import Path
|
|
|
|
# Add the current directory to sys.path
|
|
current_dir = Path(__file__).parent
|
|
sys.path.append(str(current_dir))
|
|
|
|
from pages.template_page import TemplatePage
|
|
from pages.folder_page import FolderPage
|
|
from pages.dashboard_page import DashboardPage
|
|
from pages.destination_page import DestinationPage
|
|
from pages.alert_page import AlertPage
|
|
from pages.user_page import UserPage
|
|
from pages.enrichment_page import EnrichmentPage
|
|
from pages.function_page import FunctionPage
|
|
from pages.pipeline_page import PipelinePage
|
|
from pages.report_page import ReportPage
|
|
from pages.savedview_page import SavedViewPage
|
|
from pages.serviceaccount_page import ServiceAccountPage
|
|
from pages.search_page import SearchPage
|
|
from pages.alertV2_page import AlertV2Page
|
|
|
|
|
|
# Use environment variable
|
|
def create_objects(session, base_url, user_email, user_password, org_id, stream_name, num_objects):
|
|
"""Create objects in the OpenObserve running instance."""
|
|
|
|
|
|
template_page = TemplatePage(session, base_url, org_id)
|
|
destination_page = DestinationPage(session, base_url, org_id)
|
|
alert_page = AlertPage(session, base_url, org_id)
|
|
folder_page = FolderPage(session, base_url, org_id)
|
|
dashboard_page = DashboardPage(session, base_url, org_id)
|
|
user_page = UserPage(session, base_url, org_id)
|
|
enrichment_page = EnrichmentPage(session, base_url, org_id)
|
|
function_page = FunctionPage(session, base_url, org_id)
|
|
pipeline_page = PipelinePage(session, base_url, org_id)
|
|
report_page = ReportPage(session, base_url, org_id)
|
|
savedview_page = SavedViewPage(session, base_url, org_id)
|
|
serviceaccount_page = ServiceAccountPage(session, base_url, org_id)
|
|
search_page = SearchPage(session, base_url, org_id)
|
|
alertV2_page = AlertV2Page(session, base_url, org_id)
|
|
|
|
for i in range(num_objects):
|
|
|
|
# Create templates
|
|
template_name_webhook = f"template_webhook_{template_page.Unique_value_temp}_{i}"
|
|
template_page.create_template_webhook(session, base_url, user_email, user_password, org_id, template_name_webhook)
|
|
|
|
template_name_email = f"template_email_{template_page.Unique_value_temp}_{i}"
|
|
template_page.create_template_email(session, base_url, user_email, user_password, org_id, template_name_email)
|
|
|
|
# Create destinations
|
|
|
|
destination_name_webhook = f"destination_webhook_{destination_page.Unique_value_destination}_{i}"
|
|
destination_page.create_destination_webhook(session, base_url, org_id, user_email, user_password, template_name_webhook, destination_name_webhook)
|
|
|
|
email_address_admin = f"admin{user_page.Unique_value_user}{i}@gmail.com"
|
|
user_page.create_user_admin(session, base_url, user_email, user_password, org_id, email_address_admin)
|
|
|
|
destination_name_email = f"destination_email_{destination_page.Unique_value_destination}_{i}"
|
|
destination_page.create_destination_email(session, base_url, org_id, user_email, user_password, email_address_admin, template_name_email, destination_name_email)
|
|
|
|
destination_name_pipeline = f"destination_pipeline_{destination_page.Unique_value_destination}_{i}"
|
|
destination_page.create_destination_pipeline(session, base_url, org_id, user_email, user_password, destination_name_pipeline)
|
|
folder_name = f"folder_{folder_page.Unique_value_folder}_{i}"
|
|
folder_id = folder_page.create_folder_dashboard_v2(session, base_url, user_email, user_password, org_id, folder_name)
|
|
|
|
dashboard_name = f"dashboard_{dashboard_page.Unique_value_dashboard}_{i}"
|
|
dashboard_id = dashboard_page.create_dashboard(session, base_url, user_email, user_password, org_id, stream_name, folder_id, dashboard_name)
|
|
|
|
enrichment_name = f"enrichment_{enrichment_page.Unique_value_enrichment}_{i}"
|
|
enrichment_page.create_enrichment(session, base_url, user_email, user_password, org_id, enrichment_name)
|
|
|
|
function_name = f"function_{function_page.Unique_value_function}_{i}"
|
|
function_page.create_function(session, base_url, user_email, user_password, org_id, function_name)
|
|
|
|
realTime_pipeline_name = f"realTime_pipeline_{pipeline_page.Unique_value_pipeline}_{i}"
|
|
pipeline_page.create_realTime_pipeline(session, base_url, user_email, user_password, org_id, stream_name, realTime_pipeline_name)
|
|
|
|
scheduled_pipeline_name = f"scheduled_pipeline_{pipeline_page.Unique_value_pipeline}_{i}"
|
|
pipeline_page.create_scheduled_pipeline(session, base_url, user_email, user_password, org_id, stream_name, scheduled_pipeline_name)
|
|
|
|
scheduled_report_name = f"scheduled_report_{report_page.Unique_value_report}_{i}"
|
|
report_page.create_scheduled_report(session, base_url, user_email, user_password, org_id, dashboard_id, folder_id, scheduled_report_name)
|
|
|
|
cached_report_name = f"cached_report_{report_page.Unique_value_report}_{i}"
|
|
report_page.create_cached_report(session, base_url, user_email, user_password, org_id, dashboard_id, folder_id, cached_report_name)
|
|
|
|
savedview_name = f"savedview_{savedview_page.Unique_value_savedview}_{i}"
|
|
savedview_page.create_savedView(session, base_url, user_email, user_password, org_id, stream_name, savedview_name)
|
|
|
|
email_address_serviceaccount = f"serviceaccount{user_page.Unique_value_user}{i}@gmail.com"
|
|
serviceaccount_page.create_service_account(session, base_url, user_email, user_password, org_id, email_address_serviceaccount)
|
|
|
|
# Create alerts
|
|
alert_webhook = f"standard_{alert_page.Unique_value_alert}_{i}"
|
|
alert_page.create_standard_alert(session, base_url, user_email, user_password, org_id, stream_name, template_name_webhook, destination_name_webhook, alert_webhook)
|
|
|
|
alert_email = f"alert_email_{alert_page.Unique_value_alert}_{i}"
|
|
alert_page.create_standard_alert(session, base_url, user_email, user_password, org_id, stream_name, template_name_email, destination_name_email, alert_email)
|
|
|
|
alert_cron = f"alert_cron_{alert_page.Unique_value_alert}_{i}"
|
|
alert_page.create_standard_alert_cron(session, base_url, user_email, user_password, org_id, stream_name, template_name_email, destination_name_email, alert_cron)
|
|
|
|
alert_real_time = f"alert_real_time_{alert_page.Unique_value_alert}_{i}"
|
|
alert_page.create_real_time_alert(session, base_url, user_email, user_password, org_id, stream_name, template_name_webhook, destination_name_webhook, alert_real_time)
|
|
|
|
alert_sql = f"alert_sql_{alert_page.Unique_value_alert}_{i}"
|
|
alert_page.create_standard_alert_sql(session, base_url, user_email, user_password, org_id, stream_name, template_name_webhook, destination_name_webhook, alert_sql)
|
|
|
|
# Create search
|
|
search_page.search_partition_logs_query_2_hours_stream(session, base_url, user_email, user_password, org_id, stream_name)
|
|
search_page.search_cache_logs_query_2_hours_stream(session, base_url, user_email, user_password, org_id, stream_name)
|
|
search_page.search_histogram_logs_query_2_hours_stream(session, base_url, user_email, user_password, org_id, stream_name)
|
|
|
|
# Test cases for Version 2 API
|
|
# Create templates
|
|
template_v2_webhook = f"template_webhook_{template_page.Unique_value_temp}_{i}v2"
|
|
template_page.create_template_webhook(session, base_url, user_email, user_password, org_id, template_v2_webhook)
|
|
# Create destinations
|
|
destination_v2_webhook = f"destination_webhook_{destination_page.Unique_value_destination}_{i}v2"
|
|
destination_page.create_destination_webhook(session, base_url, org_id, user_email, user_password, template_v2_webhook, destination_v2_webhook)
|
|
# Create folder
|
|
folder_v2_name = f"folder_{folder_page.Unique_value_folder}_{i}v2"
|
|
folder_id = folder_page.create_folder_alert_v2(session, base_url, user_email, user_password, org_id, folder_v2_name)
|
|
# Create alert
|
|
alert_v2_name = f"alert_{alertV2_page.Unique_value_alert}_{i}v2"
|
|
alertV2_page.create_scheduled_sql_alert(session, base_url, user_email, user_password, org_id, stream_name, destination_v2_webhook, folder_id, alert_v2_name)
|
|
alert_v2_name_no_trigger = f"alert_{alertV2_page.Unique_value_alert}_{i}v2_no_trigger"
|
|
alertV2_page.create_scheduled_sql_alert_vrl_no_trigger(session, base_url, user_email, user_password, org_id, stream_name, destination_v2_webhook, folder_id, alert_v2_name_no_trigger)
|
|
alert_v2_name_trigger = f"alert_{alertV2_page.Unique_value_alert}_{i}v2_trigger"
|
|
alertV2_page.create_scheduled_sql_alert_vrl_trigger(session, base_url, user_email, user_password, org_id, stream_name, destination_v2_webhook, folder_id, alert_v2_name_trigger)
|
|
|
|
|
|
# Created all objects successfully by admin user
|
|
|
|
# Create templates
|
|
|
|
template_admin_webhook = f"template_webhook_{template_page.Unique_value_temp}_{i}admin"
|
|
template_page.create_template_webhook(session, base_url, email_address_admin, "Complexpass#123", org_id, template_admin_webhook)
|
|
|
|
template_admin_email = f"template_email_{template_page.Unique_value_temp}_{i}admin"
|
|
template_page.create_template_email(session, base_url, email_address_admin, "Complexpass#123", org_id, template_admin_email)
|
|
|
|
# Create destinations
|
|
|
|
destination_admin_webhook = f"destination_webhook_{destination_page.Unique_value_destination}_{i}admin"
|
|
destination_page.create_destination_webhook(session, base_url, org_id, email_address_admin, "Complexpass#123", template_admin_webhook, destination_admin_webhook)
|
|
|
|
email_admin = f"aduser{user_page.Unique_value_user}{i}@gmail.com"
|
|
user_page.create_user_admin(session, base_url, email_address_admin, "Complexpass#123", org_id, email_admin)
|
|
|
|
destination_admin_email = f"destination_email_{destination_page.Unique_value_destination}_{i}admin"
|
|
destination_page.create_destination_email(session, base_url, org_id, email_address_admin, "Complexpass#123", email_admin, template_admin_email, destination_admin_email)
|
|
|
|
destination_admin_pipeline = f"destination_pipeline_{destination_page.Unique_value_destination}_{i}admin"
|
|
destination_page.create_destination_pipeline(session, base_url, org_id, email_address_admin, "Complexpass#123", destination_admin_pipeline)
|
|
|
|
folder_admin = f"folder_{folder_page.Unique_value_folder}_{i}admin"
|
|
folder_id = folder_page.create_folder_dashboard_v2(session, base_url, email_address_admin, "Complexpass#123", org_id, folder_admin)
|
|
|
|
dashboard_admin = f"dashboard_{dashboard_page.Unique_value_dashboard}_{i}admin"
|
|
dashboard_id = dashboard_page.create_dashboard(session, base_url, email_address_admin, "Complexpass#123", org_id, stream_name, folder_id, dashboard_admin)
|
|
|
|
enrichment_admin = f"enrichment_{enrichment_page.Unique_value_enrichment}_{i}admin"
|
|
enrichment_page.create_enrichment(session, base_url, email_address_admin, "Complexpass#123", org_id, enrichment_admin)
|
|
|
|
function_admin = f"function_{function_page.Unique_value_function}_{i}admin"
|
|
function_page.create_function(session, base_url, email_address_admin, "Complexpass#123", org_id, function_admin)
|
|
|
|
realTime_pipeline_admin = f"realTime_pipeline_{pipeline_page.Unique_value_pipeline}_{i}admin"
|
|
pipeline_page.create_realTime_pipeline(session, base_url, email_address_admin, "Complexpass#123", org_id, stream_name, realTime_pipeline_admin)
|
|
|
|
scheduled_pipeline_admin = f"scheduled_pipeline_{pipeline_page.Unique_value_pipeline}_{i}admin"
|
|
pipeline_page.create_scheduled_pipeline(session, base_url, email_address_admin, "Complexpass#123", org_id, stream_name, scheduled_pipeline_admin)
|
|
|
|
scheduled_report_admin = f"scheduled_report_{report_page.Unique_value_report}_{i}admin"
|
|
report_page.create_scheduled_report(session, base_url, email_address_admin, "Complexpass#123", org_id, dashboard_id, folder_id, scheduled_report_admin)
|
|
|
|
cached_report_admin = f"cached_report_{report_page.Unique_value_report}_{i}admin"
|
|
report_page.create_cached_report(session, base_url, email_address_admin, "Complexpass#123", org_id, dashboard_id, folder_id, cached_report_admin)
|
|
|
|
savedview_admin = f"savedview_{savedview_page.Unique_value_savedview}_{i}admin"
|
|
savedview_page.create_savedView(session, base_url, email_address_admin, "Complexpass#123", org_id, stream_name, savedview_admin)
|
|
|
|
email_address_serviceaccount_admin = f"serviceaccount_admin{user_page.Unique_value_user}{i}@gmail.com"
|
|
serviceaccount_page.create_service_account(session, base_url, email_address_admin, "Complexpass#123", org_id, email_address_serviceaccount_admin)
|
|
|
|
# Create alerts
|
|
alert_webhook_admin = f"alert_webhook_{alert_page.Unique_value_alert}_{i}admin"
|
|
alert_page.create_standard_alert(session, base_url, email_address_admin, "Complexpass#123", org_id, stream_name, template_name_webhook, destination_name_webhook, alert_webhook_admin)
|
|
|
|
alert_email_admin = f"alert_email_{alert_page.Unique_value_alert}_{i}admin"
|
|
alert_page.create_standard_alert(session, base_url, email_address_admin, "Complexpass#123", org_id, stream_name, template_name_email, destination_name_email, alert_email_admin)
|
|
|
|
alert_cron_admin = f"alert_cron_{alert_page.Unique_value_alert}_{i}admin"
|
|
alert_page.create_standard_alert_cron(session, base_url, email_address_admin, "Complexpass#123", org_id, stream_name, template_name_email, destination_name_email, alert_cron_admin)
|
|
|
|
alert_real_time_admin = f"alert_real_time_{alert_page.Unique_value_alert}_{i}admin"
|
|
alert_page.create_real_time_alert(session, base_url, email_address_admin, "Complexpass#123", org_id, stream_name, template_name_webhook, destination_name_webhook, alert_real_time_admin)
|
|
|
|
alert_sql_admin = f"alert_sql_{alert_page.Unique_value_alert}_{i}admin"
|
|
alert_page.create_standard_alert_sql(session, base_url, email_address_admin, "Complexpass#123", org_id, stream_name, template_name_webhook, destination_name_webhook, alert_sql_admin)
|
|
|
|
# Create search
|
|
search_page.search_partition_logs_query_2_hours_stream(session, base_url, email_address_admin, "Complexpass#123", org_id, stream_name)
|
|
search_page.search_cache_logs_query_2_hours_stream(session, base_url, email_address_admin, "Complexpass#123", org_id, stream_name)
|
|
search_page.search_histogram_logs_query_2_hours_stream(session, base_url, email_address_admin, "Complexpass#123", org_id, stream_name)
|
|
|
|
|
|
# Test cases for Version 2 API
|
|
# Create templates
|
|
template_v2_webhook = f"template_webhook_{template_page.Unique_value_temp}_{i}adminv2"
|
|
template_page.create_template_webhook(session, base_url, email_address_admin, "Complexpass#123", org_id, template_v2_webhook)
|
|
# Create destinations
|
|
destination_v2_webhook = f"destination_webhook_{destination_page.Unique_value_destination}_{i}adminv2"
|
|
destination_page.create_destination_webhook(session, base_url, org_id, email_address_admin, "Complexpass#123", template_v2_webhook, destination_v2_webhook)
|
|
# Create folder
|
|
folder_v2_name = f"folder_{folder_page.Unique_value_folder}_{i}adminv2"
|
|
folder_id = folder_page.create_folder_alert_v2(session, base_url, email_address_admin, "Complexpass#123", org_id, folder_v2_name)
|
|
# Create alert
|
|
alert_v2_name = f"alert_{alertV2_page.Unique_value_alert}_{i}adminv2"
|
|
alertV2_page.create_scheduled_sql_alert(session, base_url, email_address_admin, "Complexpass#123", org_id, stream_name, destination_v2_webhook, folder_id, alert_v2_name)
|
|
alert_v2_name_no_trigger = f"alert_{alertV2_page.Unique_value_alert}_{i}adminv2_no_trigger"
|
|
alertV2_page.create_scheduled_sql_alert_vrl_no_trigger(session, base_url, email_address_admin, "Complexpass#123", org_id, stream_name, destination_v2_webhook, folder_id, alert_v2_name_no_trigger)
|
|
alert_v2_name_trigger = f"alert_{alertV2_page.Unique_value_alert}_{i}adminv2_trigger"
|
|
alertV2_page.create_scheduled_sql_alert_vrl_trigger(session, base_url, email_address_admin, "Complexpass#123", org_id, stream_name, destination_v2_webhook, folder_id, alert_v2_name_trigger)
|
|
|