mirror of
https://github.com/microsoft/playwright.git
synced 2024-12-13 17:14:02 +03:00
193c79a685
In some circumstances, dispatcher was waiting for all exisitng jobs to finish before scheduling a new one. This leads to unneded stalls. Instead, we can schedule jobs right away, if we have a worker available.
205 lines
7.2 KiB
TypeScript
205 lines
7.2 KiB
TypeScript
/**
|
|
* Copyright (c) Microsoft Corporation.
|
|
*
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
* you may not use this file except in compliance with the License.
|
|
* You may obtain a copy of the License at
|
|
*
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
* See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
*/
|
|
import path from 'path';
|
|
import { test, expect, stripAscii } from './playwright-test-fixtures';
|
|
|
|
test('it should not allow multiple tests with the same name per suite', async ({ runInlineTest }) => {
|
|
const result = await runInlineTest({
|
|
'tests/example.spec.js': `
|
|
const { test } = pwt;
|
|
test('i-am-a-duplicate', async () => {});
|
|
test('i-am-a-duplicate', async () => {});
|
|
`
|
|
});
|
|
expect(result.exitCode).toBe(1);
|
|
expect(result.output).toContain('duplicate test titles are not allowed');
|
|
expect(result.output).toContain(`- title: i-am-a-duplicate`);
|
|
expect(result.output).toContain(` - tests${path.sep}example.spec.js:6`);
|
|
expect(result.output).toContain(` - tests${path.sep}example.spec.js:7`);
|
|
});
|
|
|
|
test('it should enforce unique test names based on the describe block name', async ({ runInlineTest }) => {
|
|
const result = await runInlineTest({
|
|
'tests/example.spec.js': `
|
|
const { test } = pwt;
|
|
test.describe('hello', () => { test('my world', () => {}) });
|
|
test.describe('hello my', () => { test('world', () => {}) });
|
|
test('hello my world', () => {});
|
|
`
|
|
});
|
|
expect(result.exitCode).toBe(1);
|
|
expect(result.output).toContain('duplicate test titles are not allowed');
|
|
expect(result.output).toContain(`- title: hello my world`);
|
|
expect(result.output).toContain(` - tests${path.sep}example.spec.js:6`);
|
|
expect(result.output).toContain(` - tests${path.sep}example.spec.js:7`);
|
|
expect(result.output).toContain(` - tests${path.sep}example.spec.js:8`);
|
|
});
|
|
|
|
test('it should not allow a focused test when forbid-only is used', async ({ runInlineTest }) => {
|
|
const result = await runInlineTest({
|
|
'tests/focused-test.spec.js': `
|
|
const { test } = pwt;
|
|
test.only('i-am-focused', async () => {});
|
|
`
|
|
}, { 'forbid-only': true });
|
|
expect(result.exitCode).toBe(1);
|
|
expect(result.output).toContain('--forbid-only found a focused test.');
|
|
expect(result.output).toContain(`- tests${path.sep}focused-test.spec.js:6 > i-am-focused`);
|
|
});
|
|
|
|
test('it should not hang and report results when worker process suddenly exits', async ({ runInlineTest }) => {
|
|
const result = await runInlineTest({
|
|
'a.spec.js': `
|
|
const { test } = pwt;
|
|
test('passed1', () => {});
|
|
test('passed2', () => {});
|
|
test('failed1', () => { process.exit(0); });
|
|
test('skipped', () => {});
|
|
`
|
|
});
|
|
expect(result.exitCode).toBe(1);
|
|
expect(result.passed).toBe(2);
|
|
expect(result.failed).toBe(1);
|
|
expect(result.skipped).toBe(1);
|
|
expect(result.output).toContain('Worker process exited unexpectedly');
|
|
});
|
|
|
|
test('sigint should stop workers', async ({ runInlineTest }) => {
|
|
test.skip(process.platform === 'win32', 'No sending SIGINT on Windows');
|
|
|
|
const result = await runInlineTest({
|
|
'a.spec.js': `
|
|
const { test } = pwt;
|
|
test('interrupted1', async () => {
|
|
console.log('\\n%%SEND-SIGINT%%1');
|
|
await new Promise(f => setTimeout(f, 3000));
|
|
});
|
|
test('skipped1', async () => {
|
|
console.log('\\n%%skipped1');
|
|
});
|
|
`,
|
|
'b.spec.js': `
|
|
const { test } = pwt;
|
|
test('interrupted2', async () => {
|
|
console.log('\\n%%SEND-SIGINT%%2');
|
|
await new Promise(f => setTimeout(f, 3000));
|
|
});
|
|
test('skipped2', async () => {
|
|
console.log('\\n%%skipped2');
|
|
});
|
|
`,
|
|
}, { 'workers': 2 }, {}, { sendSIGINTAfter: 2 });
|
|
expect(result.exitCode).toBe(130);
|
|
expect(result.passed).toBe(0);
|
|
expect(result.failed).toBe(0);
|
|
expect(result.skipped).toBe(4);
|
|
expect(result.output).toContain('%%SEND-SIGINT%%1');
|
|
expect(result.output).toContain('%%SEND-SIGINT%%2');
|
|
expect(result.output).not.toContain('%%skipped1');
|
|
expect(result.output).not.toContain('%%skipped2');
|
|
});
|
|
|
|
test('should use the first occurring error when an unhandled exception was thrown', async ({ runInlineTest }) => {
|
|
const result = await runInlineTest({
|
|
'unhandled-exception.spec.js': `
|
|
const test = pwt.test.extend({
|
|
context: async ({}, test) => {
|
|
await test(123)
|
|
let errorWasThrownPromiseResolve = () => {}
|
|
const errorWasThrownPromise = new Promise(resolve => errorWasThrownPromiseResolve = resolve);
|
|
setTimeout(() => {
|
|
errorWasThrownPromiseResolve();
|
|
throw new Error('second error');
|
|
}, 0)
|
|
await errorWasThrownPromise;
|
|
},
|
|
page: async ({ context}, test) => {
|
|
throw new Error('first error');
|
|
await test(123)
|
|
},
|
|
});
|
|
|
|
test('my-test', async ({ page }) => { });
|
|
`
|
|
});
|
|
expect(result.exitCode).toBe(1);
|
|
expect(result.passed).toBe(0);
|
|
expect(result.failed).toBe(1);
|
|
expect(result.report.suites[0].specs[0].tests[0].results[0].error.message).toBe('first error');
|
|
});
|
|
|
|
test('worker interrupt should report errors', async ({ runInlineTest }) => {
|
|
test.skip(process.platform === 'win32', 'No sending SIGINT on Windows');
|
|
|
|
const result = await runInlineTest({
|
|
'a.spec.js': `
|
|
const test = pwt.test.extend({
|
|
throwOnTeardown: async ({}, use) => {
|
|
let reject;
|
|
await use(new Promise((f, r) => reject = r));
|
|
reject(new Error('INTERRUPT'));
|
|
},
|
|
});
|
|
test('interrupted', async ({ throwOnTeardown }) => {
|
|
console.log('\\n%%SEND-SIGINT%%');
|
|
await throwOnTeardown;
|
|
});
|
|
`,
|
|
}, {}, {}, { sendSIGINTAfter: 1 });
|
|
expect(result.exitCode).toBe(130);
|
|
expect(result.passed).toBe(0);
|
|
expect(result.failed).toBe(0);
|
|
expect(result.skipped).toBe(1);
|
|
expect(result.output).toContain('%%SEND-SIGINT%%');
|
|
expect(result.output).toContain('Error: INTERRUPT');
|
|
});
|
|
|
|
test('should not stall when workers are available', async ({ runInlineTest }) => {
|
|
const result = await runInlineTest({
|
|
'a.spec.js': `
|
|
const { test } = pwt
|
|
test('fails-1', async () => {
|
|
console.log('\\n%%fails-1-started');
|
|
await new Promise(f => setTimeout(f, 2000));
|
|
console.log('\\n%%fails-1-done');
|
|
expect(1).toBe(2);
|
|
});
|
|
test('passes-1', async () => {
|
|
console.log('\\n%%passes-1');
|
|
});
|
|
`,
|
|
'b.spec.js': `
|
|
const { test } = pwt
|
|
test('passes-2', async () => {
|
|
await new Promise(f => setTimeout(f, 1000));
|
|
console.log('\\n%%passes-2-started');
|
|
await new Promise(f => setTimeout(f, 3000));
|
|
console.log('\\n%%passes-2-done');
|
|
});
|
|
`,
|
|
}, { workers: 2 });
|
|
expect(result.exitCode).toBe(1);
|
|
expect(result.passed).toBe(2);
|
|
expect(result.failed).toBe(1);
|
|
expect(stripAscii(result.output).split('\n').filter(line => line.startsWith('%%'))).toEqual([
|
|
'%%fails-1-started',
|
|
'%%passes-2-started',
|
|
'%%fails-1-done',
|
|
'%%passes-1',
|
|
'%%passes-2-done',
|
|
]);
|
|
});
|