diff --git a/explorer/scan/local_scanner.go b/explorer/scan/local_scanner.go index e7ab34aeb4..139a78464e 100644 --- a/explorer/scan/local_scanner.go +++ b/explorer/scan/local_scanner.go @@ -312,6 +312,7 @@ func (s *LocalScanner) distributeJob(job *Job, ctx context.Context, upstream *up multiprogress.Open() }() scanGroup.Wait() + providers.Coordinator.Shutdown() return reporter.Reports(), finished, nil } diff --git a/providers/runtime.go b/providers/runtime.go index 5d35fbaafb..8b23f69800 100644 --- a/providers/runtime.go +++ b/providers/runtime.go @@ -69,7 +69,8 @@ func (r *Runtime) Close() { log.Error().Err(err).Msg("failed to save recording") } - r.coordinator.Close(r.Provider.Instance) + // TODO: ideally, we try to close the provider here but only if there are no more assets that need it + // r.coordinator.Close(r.Provider.Instance) r.schema.Close() }