mirror of
https://code.forgejo.org/actions/checkout.git
synced 2024-11-27 14:39:16 +01:00
add options to set max attempts and intervals
This commit is contained in:
parent
2d7d9f7ff5
commit
4dca78049b
8 changed files with 85 additions and 3 deletions
12
README.md
12
README.md
|
@ -126,6 +126,18 @@ Please refer to the [release page](https://github.com/actions/checkout/releases/
|
||||||
# running from unless specified. Example URLs are https://github.com or
|
# running from unless specified. Example URLs are https://github.com or
|
||||||
# https://my-ghes-server.example.com
|
# https://my-ghes-server.example.com
|
||||||
github-server-url: ''
|
github-server-url: ''
|
||||||
|
|
||||||
|
# Maximum number of attempts
|
||||||
|
# Default: 3
|
||||||
|
max-attempts: ''
|
||||||
|
|
||||||
|
# Minimum number of seconds to wait before retrying
|
||||||
|
# Default: 10
|
||||||
|
min-retry-interval: ''
|
||||||
|
|
||||||
|
# Maximum number of seconds to wait before retrying
|
||||||
|
# Default: 20
|
||||||
|
max-retry-interval: ''
|
||||||
```
|
```
|
||||||
<!-- end usage -->
|
<!-- end usage -->
|
||||||
|
|
||||||
|
|
|
@ -84,4 +84,28 @@ describe('retry-helper tests', () => {
|
||||||
expect(info[2]).toBe('some error 2')
|
expect(info[2]).toBe('some error 2')
|
||||||
expect(info[3]).toMatch(/Waiting .+ seconds before trying again/)
|
expect(info[3]).toMatch(/Waiting .+ seconds before trying again/)
|
||||||
})
|
})
|
||||||
|
|
||||||
|
it('should be able to set max attempts', async () => {
|
||||||
|
let attempts = 0
|
||||||
|
let error: Error = null as unknown as Error
|
||||||
|
try {
|
||||||
|
retryHelper.config(5, 1, 5)
|
||||||
|
await retryHelper.execute(() => {
|
||||||
|
throw new Error(`some error ${++attempts}`)
|
||||||
|
})
|
||||||
|
} catch (err) {
|
||||||
|
error = err as Error
|
||||||
|
}
|
||||||
|
expect(error.message).toBe('some error 5')
|
||||||
|
expect(attempts).toBe(5)
|
||||||
|
expect(info).toHaveLength(6)
|
||||||
|
expect(info[0]).toBe('some error 1')
|
||||||
|
expect(info[1]).toMatch(/Waiting .+ seconds before trying again/)
|
||||||
|
expect(info[2]).toBe('some error 2')
|
||||||
|
expect(info[3]).toMatch(/Waiting .+ seconds before trying again/)
|
||||||
|
expect(info[4]).toBe('some error 3')
|
||||||
|
expect(info[5]).toMatch(/Waiting .+ seconds before trying again/)
|
||||||
|
expect(info[6]).toBe('some error 4')
|
||||||
|
expect(info[7]).toMatch(/Waiting .+ seconds before trying again/)
|
||||||
|
})
|
||||||
})
|
})
|
||||||
|
|
|
@ -98,6 +98,15 @@ inputs:
|
||||||
github-server-url:
|
github-server-url:
|
||||||
description: The base URL for the GitHub instance that you are trying to clone from, will use environment defaults to fetch from the same instance that the workflow is running from unless specified. Example URLs are https://github.com or https://my-ghes-server.example.com
|
description: The base URL for the GitHub instance that you are trying to clone from, will use environment defaults to fetch from the same instance that the workflow is running from unless specified. Example URLs are https://github.com or https://my-ghes-server.example.com
|
||||||
required: false
|
required: false
|
||||||
|
max-attempts:
|
||||||
|
description: Maximum number of attempts
|
||||||
|
default: 3
|
||||||
|
min-retry-interval:
|
||||||
|
description: Minimum number of seconds to wait before retrying
|
||||||
|
default: 10
|
||||||
|
max-retry-interval:
|
||||||
|
description: Maximum number of seconds to wait before retrying
|
||||||
|
default: 20
|
||||||
runs:
|
runs:
|
||||||
using: node20
|
using: node20
|
||||||
main: dist/index.js
|
main: dist/index.js
|
||||||
|
|
14
dist/index.js
vendored
14
dist/index.js
vendored
|
@ -1835,6 +1835,10 @@ function getInputs() {
|
||||||
// Determine the GitHub URL that the repository is being hosted from
|
// Determine the GitHub URL that the repository is being hosted from
|
||||||
result.githubServerUrl = core.getInput('github-server-url');
|
result.githubServerUrl = core.getInput('github-server-url');
|
||||||
core.debug(`GitHub Host URL = ${result.githubServerUrl}`);
|
core.debug(`GitHub Host URL = ${result.githubServerUrl}`);
|
||||||
|
// Retry
|
||||||
|
result.maxAttempts = parseInt(core.getInput('max-attempts') || '3');
|
||||||
|
result.minRetryInterval = parseInt(core.getInput('min-retry-interval') || '10');
|
||||||
|
result.maxRetryInterval = parseInt(core.getInput('max-retry-interval') || '20');
|
||||||
return result;
|
return result;
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
@ -1887,11 +1891,13 @@ const gitSourceProvider = __importStar(__nccwpck_require__(9210));
|
||||||
const inputHelper = __importStar(__nccwpck_require__(5480));
|
const inputHelper = __importStar(__nccwpck_require__(5480));
|
||||||
const path = __importStar(__nccwpck_require__(1017));
|
const path = __importStar(__nccwpck_require__(1017));
|
||||||
const stateHelper = __importStar(__nccwpck_require__(4866));
|
const stateHelper = __importStar(__nccwpck_require__(4866));
|
||||||
|
const retryHelper = __importStar(__nccwpck_require__(2155));
|
||||||
function run() {
|
function run() {
|
||||||
return __awaiter(this, void 0, void 0, function* () {
|
return __awaiter(this, void 0, void 0, function* () {
|
||||||
var _a;
|
var _a;
|
||||||
try {
|
try {
|
||||||
const sourceSettings = yield inputHelper.getInputs();
|
const sourceSettings = yield inputHelper.getInputs();
|
||||||
|
retryHelper.config(sourceSettings.maxAttempts, sourceSettings.minRetryInterval, sourceSettings.maxRetryInterval);
|
||||||
try {
|
try {
|
||||||
// Register problem matcher
|
// Register problem matcher
|
||||||
coreCommand.issueCommand('add-matcher', {}, path.join(__dirname, 'problem-matcher.json'));
|
coreCommand.issueCommand('add-matcher', {}, path.join(__dirname, 'problem-matcher.json'));
|
||||||
|
@ -2265,7 +2271,7 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, ge
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
Object.defineProperty(exports, "__esModule", ({ value: true }));
|
Object.defineProperty(exports, "__esModule", ({ value: true }));
|
||||||
exports.execute = exports.RetryHelper = void 0;
|
exports.config = exports.execute = exports.RetryHelper = void 0;
|
||||||
const core = __importStar(__nccwpck_require__(2186));
|
const core = __importStar(__nccwpck_require__(2186));
|
||||||
const defaultMaxAttempts = 3;
|
const defaultMaxAttempts = 3;
|
||||||
const defaultMinSeconds = 10;
|
const defaultMinSeconds = 10;
|
||||||
|
@ -2311,13 +2317,17 @@ class RetryHelper {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
exports.RetryHelper = RetryHelper;
|
exports.RetryHelper = RetryHelper;
|
||||||
|
let retryHelper = new RetryHelper();
|
||||||
function execute(action) {
|
function execute(action) {
|
||||||
return __awaiter(this, void 0, void 0, function* () {
|
return __awaiter(this, void 0, void 0, function* () {
|
||||||
const retryHelper = new RetryHelper();
|
|
||||||
return yield retryHelper.execute(action);
|
return yield retryHelper.execute(action);
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
exports.execute = execute;
|
exports.execute = execute;
|
||||||
|
function config(maxAttempts, minSeconds, maxSeconds) {
|
||||||
|
retryHelper = new RetryHelper(maxAttempts, minSeconds, maxSeconds);
|
||||||
|
}
|
||||||
|
exports.config = config;
|
||||||
|
|
||||||
|
|
||||||
/***/ }),
|
/***/ }),
|
||||||
|
|
|
@ -118,4 +118,19 @@ export interface IGitSourceSettings {
|
||||||
* User override on the GitHub Server/Host URL that hosts the repository to be cloned
|
* User override on the GitHub Server/Host URL that hosts the repository to be cloned
|
||||||
*/
|
*/
|
||||||
githubServerUrl: string | undefined
|
githubServerUrl: string | undefined
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Retry helper max attempts
|
||||||
|
*/
|
||||||
|
maxAttempts: number
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Retry helper min interval seconds
|
||||||
|
*/
|
||||||
|
minRetryInterval: number
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Retry helper max interval seconds
|
||||||
|
*/
|
||||||
|
maxRetryInterval: number
|
||||||
}
|
}
|
||||||
|
|
|
@ -161,5 +161,10 @@ export async function getInputs(): Promise<IGitSourceSettings> {
|
||||||
result.githubServerUrl = core.getInput('github-server-url')
|
result.githubServerUrl = core.getInput('github-server-url')
|
||||||
core.debug(`GitHub Host URL = ${result.githubServerUrl}`)
|
core.debug(`GitHub Host URL = ${result.githubServerUrl}`)
|
||||||
|
|
||||||
|
// Retry
|
||||||
|
result.maxAttempts = parseInt(core.getInput('max-attempts') || '3')
|
||||||
|
result.minRetryInterval = parseInt(core.getInput('min-retry-interval') || '10')
|
||||||
|
result.maxRetryInterval = parseInt(core.getInput('max-retry-interval') || '20')
|
||||||
|
|
||||||
return result
|
return result
|
||||||
}
|
}
|
||||||
|
|
|
@ -4,10 +4,12 @@ import * as gitSourceProvider from './git-source-provider'
|
||||||
import * as inputHelper from './input-helper'
|
import * as inputHelper from './input-helper'
|
||||||
import * as path from 'path'
|
import * as path from 'path'
|
||||||
import * as stateHelper from './state-helper'
|
import * as stateHelper from './state-helper'
|
||||||
|
import * as retryHelper from './retry-helper'
|
||||||
|
|
||||||
async function run(): Promise<void> {
|
async function run(): Promise<void> {
|
||||||
try {
|
try {
|
||||||
const sourceSettings = await inputHelper.getInputs()
|
const sourceSettings = await inputHelper.getInputs()
|
||||||
|
retryHelper.config(sourceSettings.maxAttempts, sourceSettings.minRetryInterval, sourceSettings.maxRetryInterval)
|
||||||
|
|
||||||
try {
|
try {
|
||||||
// Register problem matcher
|
// Register problem matcher
|
||||||
|
|
|
@ -55,7 +55,12 @@ export class RetryHelper {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
let retryHelper = new RetryHelper()
|
||||||
|
|
||||||
export async function execute<T>(action: () => Promise<T>): Promise<T> {
|
export async function execute<T>(action: () => Promise<T>): Promise<T> {
|
||||||
const retryHelper = new RetryHelper()
|
|
||||||
return await retryHelper.execute(action)
|
return await retryHelper.execute(action)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
export function config(maxAttempts: number, minSeconds: number, maxSeconds: number): void {
|
||||||
|
retryHelper = new RetryHelper(maxAttempts, minSeconds, maxSeconds)
|
||||||
|
}
|
||||||
|
|
Loading…
Reference in a new issue