Fix operator-framework#4530: not able to test ansible operator locally

Signed-off-by: rashmigottipati <[email protected]>

Author: rashmigottipati

internal/ansible/runner/runner.go

@@ -48,6 +48,8 @@ const (
 	// to the ansible-runner command. This will override the value for a particular CR.
 	// Example usage "ansible.sdk.operatorframework.io/verbosity: 5"
 	AnsibleVerbosityAnnotation = "ansible.sdk.operatorframework.io/verbosity"
+
+	ansibleRunnerBin = "ansible-runner"
 )
 
 // Runner - a runnable that should take the parameters and name and namespace
@@ -128,6 +130,10 @@ func New(watch watches.Watch, runnerArgs string) (Runner, error) {
 		return nil, err
 	}
 
+	if _, err := exec.LookPath(ansibleRunnerBin); err != nil {
+		return nil, err
+	}
+
 	switch {
 	case watch.Playbook != "":
 		path = watch.Playbook
@@ -277,11 +283,16 @@ func (r *runner) Run(ident string, u *unstructured.Unstructured, kubeconfig stri
 		// link the current run to the `latest` directory under artifacts
 		currentRun := filepath.Join(inputDir.Path, "artifacts", ident)
 		latestArtifacts := filepath.Join(inputDir.Path, "artifacts", "latest")
-		if _, err = os.Lstat(latestArtifacts); err == nil {
-			if err = os.Remove(latestArtifacts); err != nil {
-				logger.Error(err, "Error removing the latest artifacts symlink")
+		if _, err = os.Lstat(latestArtifacts); err != nil {
+			if !errors.Is(err, os.ErrNotExist) {
+				logger.Error(err, "Latest artifacts dir doesn't exist")
+				return
 			}
+		} else if err = os.Remove(latestArtifacts); err != nil {
+			logger.Error(err, "Error removing the latest artifacts symlink")
+			return
 		}
+
 		if err = os.Symlink(currentRun, latestArtifacts); err != nil {
 			logger.Error(err, "Error symlinking latest artifacts")
 		}