Skip to content

Commit

Permalink
check for flag in the start
Browse files Browse the repository at this point in the history
  • Loading branch information
ahmed-nour-fdc committed Aug 20, 2024
1 parent 450d45c commit c710fb5
Showing 1 changed file with 16 additions and 15 deletions.
31 changes: 16 additions & 15 deletions services/cd-service/pkg/repository/transformer.go
Original file line number Diff line number Diff line change
Expand Up @@ -3747,31 +3747,32 @@ func (c *envReleaseTrain) Transform(
return "", prognosis.Error
}
if prognosis.SkipCause != nil {
if !c.WriteCommitData {
return renderEnvironmentSkipCause(prognosis.SkipCause), nil
}
for appName := range prognosis.AppsPrognoses {
release, err := state.GetLastRelease(ctx, transaction, state.Filesystem, appName)
if err != nil {
return "", fmt.Errorf("error getting latest release for app '%s' - %v", appName, err)
}
releaseDir := releasesDirectoryWithVersion(state.Filesystem, appName, release)
newEvent := createLockPreventedDeploymentEvent(appName, c.Env, prognosis.FirstLockMessage, "environment")
if c.WriteCommitData {
if state.DBHandler.ShouldUseOtherTables() {
commitID, err := getCommitID(ctx, transaction, state, state.Filesystem, release, releaseDir, appName)
if err != nil {
logger.FromContext(ctx).Sugar().Warnf("could not write event data - continuing. %v", fmt.Errorf("getCommitIDFromReleaseDir %v", err))
} else {
gen := getGenerator(ctx)
eventUuid := gen.Generate()
err = state.DBHandler.DBWriteLockPreventedDeploymentEvent(ctx, transaction, c.TransformerEslVersion, eventUuid, commitID, newEvent)
if err != nil {
return "", GetCreateReleaseGeneralFailure(err)
}
}
if state.DBHandler.ShouldUseOtherTables() {
commitID, err := getCommitID(ctx, transaction, state, state.Filesystem, release, releaseDir, appName)
if err != nil {
logger.FromContext(ctx).Sugar().Warnf("could not write event data - continuing. %v", fmt.Errorf("getCommitIDFromReleaseDir %v", err))
} else {
if err := addEventForRelease(ctx, state.Filesystem, releaseDir, newEvent); err != nil {
return "", err
gen := getGenerator(ctx)
eventUuid := gen.Generate()
err = state.DBHandler.DBWriteLockPreventedDeploymentEvent(ctx, transaction, c.TransformerEslVersion, eventUuid, commitID, newEvent)
if err != nil {
return "", GetCreateReleaseGeneralFailure(err)
}
}
} else {
if err := addEventForRelease(ctx, state.Filesystem, releaseDir, newEvent); err != nil {
return "", err
}
}
}

Expand Down

0 comments on commit c710fb5

Please sign in to comment.