diff --git a/pkg/acquisition/acquisition.go b/pkg/acquisition/acquisition.go index 3c8f547d0..334de2c3d 100644 --- a/pkg/acquisition/acquisition.go +++ b/pkg/acquisition/acquisition.go @@ -241,7 +241,11 @@ func StartAcquisition(sources []DataSource, output chan types.Event, AcquisTomb return nil }) } - /*return only when acquisition is over (cat) or never (tail)*/ - err := AcquisTomb.Wait() - return err + // Don't wait if we have no sources, as it will hang forever + if len(sources) > 0 { + /*return only when acquisition is over (cat) or never (tail)*/ + err := AcquisTomb.Wait() + return err + } + return nil }