diff --git a/eliofile/eliofile.go b/eliofile/eliofile.go index 85d7de7..ecb46fa 100644 --- a/eliofile/eliofile.go +++ b/eliofile/eliofile.go @@ -93,7 +93,10 @@ func (f *ElioDateiFoo) ScanCsv(ctx context.Context, data chan<- CountryCsvData) f.mu.Lock() f.haveDone[v.filename] = time.Now() f.mu.Unlock() - f.process(ctx, v.filename, data) + //Max 5 Sekunden zum Abarbeiten eines Datensatzes + tctx, cancel := context.WithTimeout(ctx, time.Second*5) + f.process(tctx, v.filename, data) + cancel() } } }