Skip to content

Commit d42ae29

Browse files
committed
wip
1 parent 706a059 commit d42ae29

File tree

1 file changed

+5
-9
lines changed

1 file changed

+5
-9
lines changed

src/utils/localstack-status.ts

Lines changed: 5 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -58,16 +58,16 @@ export function createLocalStackStatusTracker(
5858
});
5959

6060
emitter.on((newStatus) => {
61-
outputChannel.info(`localstack=${newStatus}`);
61+
outputChannel.trace(`[localstack-status] localstack=${newStatus}`);
6262

6363
if (newStatus === "running") {
6464
healthCheckStatusTracker.stop();
6565
}
6666
});
6767

6868
containerStatusTracker.onChange((newContainerStatus) => {
69-
outputChannel.info(
70-
`container=${newContainerStatus} (localstack=${status})`,
69+
outputChannel.trace(
70+
`[localstack-status] container=${newContainerStatus} (localstack=${status})`,
7171
);
7272

7373
if (newContainerStatus === "running" && status !== "running") {
@@ -159,20 +159,16 @@ function createHealthStatusTracker(
159159
};
160160

161161
let enqueueAgain = false;
162-
163162
const enqueueUpdateStatus = () => {
164163
if (healthCheckTimeout) {
165164
return;
166165
}
167166

168-
healthCheckTimeout = setTimeout(() => {
167+
healthCheckTimeout = setInterval(() => {
169168
void fetchAndUpdateStatus().then(() => {
170169
if (!enqueueAgain) {
171170
return;
172171
}
173-
174-
healthCheckTimeout = undefined;
175-
enqueueUpdateStatus();
176172
});
177173
}, 1_000);
178174
};
@@ -188,7 +184,7 @@ function createHealthStatusTracker(
188184
stop() {
189185
status = undefined;
190186
enqueueAgain = false;
191-
clearTimeout(healthCheckTimeout);
187+
clearInterval(healthCheckTimeout);
192188
healthCheckTimeout = undefined;
193189
},
194190
onChange(callback) {

0 commit comments

Comments
 (0)