mirror of
https://github.com/elastic/kibana.git
synced 2025-04-24 17:59:23 -04:00
[SLOs] Schedule now rollup transform after creation (#188104)
## Summary Schedule now rollup transforms after creation !!
This commit is contained in:
parent
6b0d628053
commit
b20c75b85d
1 changed files with 13 additions and 0 deletions
|
@ -91,6 +91,7 @@ export class DefaultTransformManager implements TransformManager {
|
|||
this.esClient.transform.startTransform({ transform_id: transformId }, { ignore: [409] }),
|
||||
{ logger: this.logger }
|
||||
);
|
||||
await this.scheduleNowTransform(transformId);
|
||||
} catch (err) {
|
||||
this.logger.error(`Cannot start SLO transform [${transformId}]`);
|
||||
throw err;
|
||||
|
@ -128,4 +129,16 @@ export class DefaultTransformManager implements TransformManager {
|
|||
throw err;
|
||||
}
|
||||
}
|
||||
|
||||
async scheduleNowTransform(transformId: TransformId) {
|
||||
this.esClient.transform
|
||||
.scheduleNowTransform({ transform_id: transformId })
|
||||
.then(() => {
|
||||
this.logger.info(`SLO transform [${transformId}] scheduled now successfully`);
|
||||
})
|
||||
.catch((e) => {
|
||||
this.logger.error(`Cannot schedule now SLO transform [${transformId}]`);
|
||||
this.logger.error(e);
|
||||
});
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue