wait between polling when Previous aws stack still exists
parent
e092789257
commit
040a184a5d
|
|
@ -3073,11 +3073,11 @@ class Kubernetes {
|
||||||
for (let index = 0; index < 3; index++) {
|
for (let index = 0; index < 3; index++) {
|
||||||
try {
|
try {
|
||||||
cloud_runner_logger_1.default.log(`Job spec creating 1`);
|
cloud_runner_logger_1.default.log(`Job spec creating 1`);
|
||||||
yield new Promise((promise) => setTimeout(promise, 5000));
|
yield new Promise((promise) => setTimeout(promise, 15000));
|
||||||
cloud_runner_logger_1.default.log(`Job spec creating 2`);
|
cloud_runner_logger_1.default.log(`Job spec creating 2`);
|
||||||
yield new Promise((promise) => setTimeout(promise, 5000));
|
yield new Promise((promise) => setTimeout(promise, 15000));
|
||||||
cloud_runner_logger_1.default.log(`Job spec creating 3`);
|
cloud_runner_logger_1.default.log(`Job spec creating 3`);
|
||||||
yield new Promise((promise) => setTimeout(promise, 5000));
|
yield new Promise((promise) => setTimeout(promise, 15000));
|
||||||
const jobSpec = kubernetes_job_spec_factory_1.default.getJobSpec(commands, image, mountdir, workingdir, environment, secrets, this.buildGuid, this.buildParameters, this.secretName, this.pvcName, this.jobName, k8s);
|
const jobSpec = kubernetes_job_spec_factory_1.default.getJobSpec(commands, image, mountdir, workingdir, environment, secrets, this.buildGuid, this.buildParameters, this.secretName, this.pvcName, this.jobName, k8s);
|
||||||
cloud_runner_logger_1.default.log(`Job spec created`);
|
cloud_runner_logger_1.default.log(`Job spec created`);
|
||||||
yield new Promise((promise) => setTimeout(promise, 15000));
|
yield new Promise((promise) => setTimeout(promise, 15000));
|
||||||
|
|
@ -3106,6 +3106,7 @@ class Kubernetes {
|
||||||
yield this.kubeClient.deleteNamespacedPod(this.podName, this.namespace);
|
yield this.kubeClient.deleteNamespacedPod(this.podName, this.namespace);
|
||||||
yield this.kubeClient.deleteNamespacedSecret(this.secretName, this.namespace);
|
yield this.kubeClient.deleteNamespacedSecret(this.secretName, this.namespace);
|
||||||
yield new Promise((promise) => setTimeout(promise, 15000));
|
yield new Promise((promise) => setTimeout(promise, 15000));
|
||||||
|
cloud_runner_logger_1.default.log('cleaned up Secret, Job and Pod');
|
||||||
}
|
}
|
||||||
catch (error) {
|
catch (error) {
|
||||||
if (error.response.body.reason === `not found`) {
|
if (error.response.body.reason === `not found`) {
|
||||||
|
|
|
||||||
File diff suppressed because one or more lines are too long
|
|
@ -163,11 +163,11 @@ class Kubernetes implements ProviderInterface {
|
||||||
for (let index = 0; index < 3; index++) {
|
for (let index = 0; index < 3; index++) {
|
||||||
try {
|
try {
|
||||||
CloudRunnerLogger.log(`Job spec creating 1`);
|
CloudRunnerLogger.log(`Job spec creating 1`);
|
||||||
await new Promise((promise) => setTimeout(promise, 5000));
|
await new Promise((promise) => setTimeout(promise, 15000));
|
||||||
CloudRunnerLogger.log(`Job spec creating 2`);
|
CloudRunnerLogger.log(`Job spec creating 2`);
|
||||||
await new Promise((promise) => setTimeout(promise, 5000));
|
await new Promise((promise) => setTimeout(promise, 15000));
|
||||||
CloudRunnerLogger.log(`Job spec creating 3`);
|
CloudRunnerLogger.log(`Job spec creating 3`);
|
||||||
await new Promise((promise) => setTimeout(promise, 5000));
|
await new Promise((promise) => setTimeout(promise, 15000));
|
||||||
const jobSpec = KubernetesJobSpecFactory.getJobSpec(
|
const jobSpec = KubernetesJobSpecFactory.getJobSpec(
|
||||||
commands,
|
commands,
|
||||||
image,
|
image,
|
||||||
|
|
@ -208,6 +208,7 @@ class Kubernetes implements ProviderInterface {
|
||||||
await this.kubeClient.deleteNamespacedPod(this.podName, this.namespace);
|
await this.kubeClient.deleteNamespacedPod(this.podName, this.namespace);
|
||||||
await this.kubeClient.deleteNamespacedSecret(this.secretName, this.namespace);
|
await this.kubeClient.deleteNamespacedSecret(this.secretName, this.namespace);
|
||||||
await new Promise((promise) => setTimeout(promise, 15000));
|
await new Promise((promise) => setTimeout(promise, 15000));
|
||||||
|
CloudRunnerLogger.log('cleaned up Secret, Job and Pod');
|
||||||
} catch (error: any) {
|
} catch (error: any) {
|
||||||
if (error.response.body.reason === `not found`) {
|
if (error.response.body.reason === `not found`) {
|
||||||
return;
|
return;
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue