Improve chart logging
This commit is contained in:
parent
8c4245a09d
commit
4a585e8920
|
@ -280,7 +280,7 @@ export default abstract class Chart<T extends Record<string, any>> {
|
||||||
// 初期ログデータを作成
|
// 初期ログデータを作成
|
||||||
data = this.getNewLog(null);
|
data = this.getNewLog(null);
|
||||||
|
|
||||||
logger.info(`${this.name}: Initial commit created`);
|
logger.info(`${this.name + (group ? `:${group}` : '')} (${span}): Initial commit created`);
|
||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
|
@ -292,14 +292,14 @@ export default abstract class Chart<T extends Record<string, any>> {
|
||||||
...Chart.convertObjectToFlattenColumns(data)
|
...Chart.convertObjectToFlattenColumns(data)
|
||||||
});
|
});
|
||||||
|
|
||||||
logger.info(`${this.name}: New commit created`);
|
logger.info(`${this.name + (group ? `:${group}` : '')} (${span}): New commit created`);
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
// duplicate key error
|
// duplicate key error
|
||||||
// 並列動作している他のチャートエンジンプロセスと処理が重なる場合がある
|
// 並列動作している他のチャートエンジンプロセスと処理が重なる場合がある
|
||||||
// その場合は再度最も新しいログを持ってくる
|
// その場合は再度最も新しいログを持ってくる
|
||||||
if (isDuplicateKeyValueError(e)) {
|
if (isDuplicateKeyValueError(e)) {
|
||||||
log = await this.getLatestLog(span, group) as Log;
|
log = await this.getLatestLog(span, group) as Log;
|
||||||
logger.info(`${this.name}: Commit duplicated`);
|
logger.info(`${this.name + (group ? `:${group}` : '')} (${span}): Commit duplicated`);
|
||||||
} else {
|
} else {
|
||||||
logger.error(e);
|
logger.error(e);
|
||||||
throw e;
|
throw e;
|
||||||
|
|
Loading…
Reference in New Issue