fix: set HookRunReplication function in processRun and remove duplicate in runPipeline

Author: flarco

cmd/sling/sling_run.go

@@ -49,6 +49,9 @@ func processRun(c *g.CliSC) (ok bool, err error) {
 	showExamples := false
 	selectStreams := []string{}
 
+	// set function here due to scoping
+	sling.HookRunReplication = runReplication
+
 	// recover from panic
 	defer func() {
 		if r := recover(); r != nil {
@@ -633,9 +636,6 @@ func runPipeline(pipelineCfgPath string) (err error) {
 		Track("run")
 	}()
 
-	// set function here due to scoping
-	sling.HookRunReplication = runReplication
-
 	pipeline.Context = ctx
 	err = pipeline.Execute()