Closes #4872: Handling of loop logging for Ansible operators (#4970)

* Print to StdOut

Signed-off-by: Venkat Ramaraju <[email protected]>

* Parsing of verbosity

Signed-off-by: Venkat Ramaraju <[email protected]>

* Refactoring

Signed-off-by: Venkat Ramaraju <[email protected]>

* Handling errors

Signed-off-by: Venkat Ramaraju <[email protected]>

* Changing to assignments

Signed-off-by: Venkat Ramaraju <[email protected]>

* Handling of loops

Signed-off-by: Venkat Ramaraju <[email protected]>

* Missed return statement

Signed-off-by: Venkat Ramaraju <[email protected]>

* Some changes

Signed-off-by: Venkat Ramaraju <[email protected]>

* New changes

Signed-off-by: Venkat Ramaraju <[email protected]>

* Moved logging to log_events.go

Signed-off-by: Venkat Ramaraju <[email protected]>

* Changes

Signed-off-by: Venkat Ramaraju <[email protected]>

* New changes

Signed-off-by: Venkat Ramaraju <[email protected]>

Author: VenkatRamaraju

internal/ansible/events/log_events.go

@@ -92,6 +92,12 @@ func (l loggingEventHandler) Handle(ident string, u *unstructured.Unstructured,
 			l.mux.Unlock()
 			return
 		}
+		if e.Event == eventapi.EventRunnerItemOnOk {
+			l.mux.Lock()
+			l.logAnsibleStdOut(e)
+			l.mux.Unlock()
+			return
+		}
 		if e.Event == eventapi.EventRunnerOnFailed {
 			errKVs := []interface{}{
 				"EventData.Task", t,

internal/ansible/runner/eventapi/types.go

@@ -31,6 +31,8 @@ const (
 	EventRunnerOnFailed = "runner_on_failed"
 	// EventPlaybookOnStats - playbook has finished running.
 	EventPlaybookOnStats = "playbook_on_stats"
+	// EventRunnerItemOnOk - item finished with ok status.
+	EventRunnerItemOnOk = "runner_item_on_ok"
 
 	// Ansible Task Actions