@@ -74,7 +74,7 @@ func main() {
74
74
// Variable to store if the run was successful. If it wasn't we don't remove orphans.
75
75
successfullRun := true
76
76
// Variable to store failed sourcesFalse
77
- encounteredErrors := map [string ]bool {}
77
+ encounteredErrors := map [string ]error {}
78
78
79
79
// Go through all sources and sync data
80
80
var wg sync.WaitGroup
@@ -104,7 +104,7 @@ func main() {
104
104
if err != nil {
105
105
ssotLogger .Error (sourceCtx , err )
106
106
successfullRun = false
107
- encounteredErrors [sourceName ] = true
107
+ encounteredErrors [sourceName ] = err
108
108
return
109
109
}
110
110
ssotLogger .Infof (sourceCtx , "Successfully initialized source %s" , constants .CheckMark )
@@ -115,7 +115,7 @@ func main() {
115
115
if err != nil {
116
116
successfullRun = false
117
117
ssotLogger .Error (sourceCtx , err )
118
- encounteredErrors [sourceName ] = true
118
+ encounteredErrors [sourceName ] = err
119
119
return
120
120
}
121
121
ssotLogger .Infof (sourceCtx , "Source synced successfully %s" , constants .CheckMark )
@@ -148,8 +148,8 @@ func main() {
148
148
seconds ,
149
149
)
150
150
} else {
151
- for source := range encounteredErrors {
152
- ssotLogger .Infof (mainCtx , "%s syncing of source %s failed" , constants .WarningSign , source )
151
+ for source , err := range encounteredErrors {
152
+ ssotLogger .Infof (mainCtx , "%s syncing of source %s failed with: %v " , constants .WarningSign , source , err )
153
153
}
154
154
os .Exit (1 )
155
155
}
0 commit comments