diff --git a/path.go b/path.go
index 1043e6b5..e7ca05d6 100644
--- a/path.go
+++ b/path.go
@@ -59,7 +59,7 @@ func (pa *path) log(format string, args ...interface{}) {
 
 func (pa *path) onInit() {
 	if pa.source != nil {
-		go pa.source.run()
+		go pa.source.run(pa.source.state)
 	}
 
 	if pa.confp.RunOnInit != "" {
diff --git a/source.go b/source.go
index f7f038aa..1699e426 100644
--- a/source.go
+++ b/source.go
@@ -66,8 +66,8 @@ func newSource(p *program, path *path, confp *confPath) *source {
 
 func (s *source) isPublisher() {}
 
-func (s *source) run() {
-	s.applyState(s.state)
+func (s *source) run(initialState sourceState) {
+	s.applyState(initialState)
 
 outer:
 	for {