mirror of
https://github.com/openobserve/openobserve.git
synced 2026-11-05 08:09:22 +00:00
test: fixed schema and schema load tests on env (#9553)
This commit is contained in:
@@ -211,41 +211,34 @@ class SchemaLoadPage {
|
||||
// Step 1: Navigate to streams page first to verify stream exists
|
||||
await this.navigateToStreams();
|
||||
await this.searchStreamInStreamsPage(streamName);
|
||||
|
||||
// Wait for stream to be visible in streams page
|
||||
const streamExists = await this.page.locator(`text="${streamName}"`).isVisible();
|
||||
if (!streamExists) {
|
||||
testLogger.error('Stream not found in streams page', { streamName });
|
||||
|
||||
// Wait for stream to be visible in streams page with proper timeout
|
||||
try {
|
||||
const streamLocator = this.page.locator(`text="${streamName}"`).first();
|
||||
await streamLocator.scrollIntoViewIfNeeded({ timeout: 20000 });
|
||||
testLogger.debug('Stream verified in streams page', { streamName });
|
||||
} catch (error) {
|
||||
testLogger.error('Stream not found in streams page', { streamName, error: error.message });
|
||||
throw new Error(`Stream ${streamName} not found in streams page after ingestion`);
|
||||
}
|
||||
testLogger.debug('Stream verified in streams page', { streamName });
|
||||
|
||||
// Step 2: Navigate to logs and verify stream is available in log search
|
||||
await this.navigateToLogs();
|
||||
await this.page.waitForTimeout(1000); // Wait after navigating back to logs
|
||||
|
||||
// Try a more direct approach - just check if we can see any streams at all
|
||||
await this.page.waitForTimeout(2000); // Wait after navigating back to logs
|
||||
|
||||
// Open the stream dropdown and search for the stream
|
||||
await this.page.waitForSelector(this.schemaLoadLocators.logSearchIndexSelectStream, { state: 'visible' });
|
||||
await this.page.locator(this.schemaLoadLocators.logSearchIndexSelectStream).click();
|
||||
await this.page.waitForLoadState('domcontentloaded');
|
||||
|
||||
// Look for our stream in the dropdown by partial text match
|
||||
const streamVisible = await this.page.getByText(streamName, { exact: false }).first().isVisible();
|
||||
if (!streamVisible) {
|
||||
testLogger.debug('Stream not visible in dropdown, trying refresh');
|
||||
await this.page.reload();
|
||||
await this.page.waitForLoadState('domcontentloaded');
|
||||
await this.page.waitForSelector(this.schemaLoadLocators.logSearchIndexSelectStream, { state: 'visible' });
|
||||
await this.page.locator(this.schemaLoadLocators.logSearchIndexSelectStream).click();
|
||||
}
|
||||
|
||||
// Click on the stream name directly
|
||||
await this.page.waitForTimeout(1000);
|
||||
|
||||
// Type the stream name to filter the dropdown
|
||||
await this.page.locator(this.schemaLoadLocators.logSearchIndexSelectStream).fill(streamName);
|
||||
await this.page.waitForTimeout(2000); // Wait for filtering to complete
|
||||
await this.page.waitForLoadState('networkidle', { timeout: 10000 }).catch(() => {});
|
||||
|
||||
// Wait for the stream to be visible in the dropdown
|
||||
// Find the stream in the filtered results and click it
|
||||
const streamLocator = this.page.getByText(streamName, { exact: false }).first();
|
||||
await streamLocator.waitFor({ state: 'visible', timeout: 15000 });
|
||||
await streamLocator.scrollIntoViewIfNeeded({ timeout: 20000 });
|
||||
await streamLocator.click();
|
||||
await this.page.waitForLoadState('networkidle', { timeout: 30000 });
|
||||
|
||||
|
||||
@@ -300,9 +300,14 @@ export class LogsPage {
|
||||
await this.page.waitForTimeout(1000);
|
||||
await this.page.waitForLoadState('networkidle', { timeout: 10000 }).catch(() => {});
|
||||
|
||||
// Wait for the stream to be visible in the dropdown
|
||||
// Type the stream name to filter the dropdown
|
||||
await this.page.locator(this.indexDropDown).fill(stream);
|
||||
await this.page.waitForTimeout(2000); // Wait for filtering to complete
|
||||
await this.page.waitForLoadState('networkidle', { timeout: 10000 }).catch(() => {});
|
||||
|
||||
// Find the stream in the filtered results and scroll it into view if needed
|
||||
const streamLocator = this.page.getByText(stream, { exact: true }).first();
|
||||
await streamLocator.waitFor({ state: 'visible', timeout: 15000 });
|
||||
await streamLocator.scrollIntoViewIfNeeded({ timeout: 15000 });
|
||||
await streamLocator.click();
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user