Skip to content

Commit 43baa17

Browse files
committed
Fix deployment connection signal sent before updating status
1 parent cb0155a commit 43baa17

File tree

2 files changed

+2
-7
lines changed

2 files changed

+2
-7
lines changed

src/service/storage/deployment.cc

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -308,8 +308,6 @@ namespace service {
308308
deployLog->info("== Project deployment complete ==");
309309
deployLog->info("====================================");
310310

311-
global::connections->complete(projectId, true);
312-
313311
deployment.setStatus(enumToStr(DeploymentStatus::SUCCESS));
314312

315313
// Cleanup previous data
@@ -328,8 +326,6 @@ namespace service {
328326
deployLog->error("!! Project deployment failed !!");
329327
deployLog->error("!!================================!!");
330328

331-
global::connections->complete(projectId, false);
332-
333329
deployment.setStatus(enumToStr(DeploymentStatus::ERROR));
334330

335331
remove_all(deploymentDir);
@@ -338,6 +334,8 @@ namespace service {
338334
remove_all(clonePath);
339335
co_await global::database->updateModel(deployment);
340336

337+
global::connections->complete(projectId, result == ProjectError::OK);
338+
341339
co_return co_await completeTask<std::tuple<std::optional<Deployment>, ProjectError>>(taskKey, {deployment, result});
342340
}
343341

src/service/storage/storage.cc

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -169,9 +169,6 @@ namespace service {
169169
vProject->setDefaultVersion(*defaultProject);
170170
co_return TaskResult<ProjectBasePtr>{std::make_shared<ResolvedProject>(*vProject)};
171171
}
172-
if (!co_await defaultProject->hasVersion(*version)) {
173-
logger.error("Failed to find existing version '{}' for '{}'", *version, project.getValueOfId());
174-
}
175172
}
176173

177174
if (!defaultProject) {

0 commit comments

Comments
 (0)