adding back deferred stop
@@ -45,7 +45,6 @@ func (r *SkaffoldRunner) doDev(ctx context.Context, out io.Writer) error {
switch {
case r.changeSet.needsReload:
- r.forwarderManager.Stop()
return ErrorConfigurationChanged
case len(r.changeSet.needsResync) > 0:
for _, s := range r.changeSet.needsResync {
@@ -84,6 +83,7 @@ func (r *SkaffoldRunner) Dev(ctx context.Context, out io.Writer, artifacts []*la
defer r.logger.Stop()
r.createForwarder(out)
+ defer r.forwarderManager.Stop()
// Watch artifacts
for i := range artifacts {
