diff --git a/importer/job.go b/importer/job.go
index 1ac6d4c48cfeb936039e57b67912d42d49beefba..15ca40ff9c0773ac98ab790c9d6aec5939896551 100644
--- a/importer/job.go
+++ b/importer/job.go
@@ -77,10 +77,10 @@ func (job *Job) run() error {
 		// job.Cancel() only set the state to JobCanceled... so we simulate a canceled context here
 		return context.Canceled
 	}
-	close(job.subC.running)
 	job.StartedAt.set(time.Now())
 	job.im.dbgLog.Printf("running import for %s/%d from: %s", job.Group, job.ID, job.Source.String())
 	job.im.store.UpdateFileImportState(job.Group, job.ID, store.ImportRunning)
+	close(job.subC.running)
 
 	if err := job.initializeSource(); err != nil {
 		job.im.store.UpdateFileImportState(job.Group, job.ID, store.ImportAborted)