@@ -184,11 +184,7 @@ func containersFromAPI(ctx context.Context, client CtrdClient) ([]Metadata, erro
184
184
for _ , ns := range nss {
185
185
// For each namespace returned by the API, get the containers metadata.
186
186
ctx := namespaces .WithNamespace (ctx , ns )
187
- ctrs , err := containersMetadata (ctx , client , ns , defaultContainerdRootfsPrefix )
188
- if err != nil {
189
- log .Errorf ("Could not get a list of containers from the containerd: %v" , err )
190
- return nil , err
191
- }
187
+ ctrs := containersMetadata (ctx , client , ns , defaultContainerdRootfsPrefix )
192
188
// Merge all containers metadata items for all namespaces into a single list.
193
189
metadata = append (metadata , ctrs ... )
194
190
}
@@ -205,7 +201,7 @@ func namespacesFromAPI(ctx context.Context, client CtrdClient) ([]string, error)
205
201
return nss , nil
206
202
}
207
203
208
- func containersMetadata (ctx context.Context , client CtrdClient , namespace string , defaultAbsoluteToBundlePath string ) ( []Metadata , error ) {
204
+ func containersMetadata (ctx context.Context , client CtrdClient , namespace string , defaultAbsoluteToBundlePath string ) []Metadata {
209
205
var containersMetadata []Metadata
210
206
211
207
taskService := client .TaskService ()
@@ -226,7 +222,7 @@ func containersMetadata(ctx context.Context, client CtrdClient, namespace string
226
222
227
223
containersMetadata = append (containersMetadata , md )
228
224
}
229
- return containersMetadata , nil
225
+ return containersMetadata
230
226
}
231
227
232
228
func taskMetadata (ctx context.Context , client CtrdClient , task * task.Process , namespace string , defaultAbsoluteToBundlePath string ) (Metadata , error ) {
0 commit comments