From e814f28039ce29db94301c0bc357a3939abfa268 Mon Sep 17 00:00:00 2001
From: AlanCoding <arominge@redhat.com>
Date: Fri, 6 Oct 2017 16:55:31 -0400
Subject: [PATCH] add logger statement for number of events

---
 awx/main/tasks.py        | 6 ++++++
 awx/main/utils/common.py | 2 ++
 2 files changed, 8 insertions(+)

diff --git a/awx/main/tasks.py b/awx/main/tasks.py
index 5dbadd4131..b27ce0e967 100644
--- a/awx/main/tasks.py
+++ b/awx/main/tasks.py
@@ -886,6 +886,12 @@ class BaseTask(LogErrorsTask):
             try:
                 stdout_handle.flush()
                 stdout_handle.close()
+                # If stdout_handle was wrapped with event filter, log data
+                if hasattr(stdout_handle, '_event_ct'):
+                    logger.info('%s finished running, producing %s events.',
+                                instance.log_format, stdout_handle._event_ct)
+                else:
+                    logger.info('%s finished running', instance.log_format)
             except Exception:
                 pass
 
diff --git a/awx/main/utils/common.py b/awx/main/utils/common.py
index 22183c33dd..c370769f84 100644
--- a/awx/main/utils/common.py
+++ b/awx/main/utils/common.py
@@ -818,6 +818,7 @@ class OutputEventFilter(object):
     def __init__(self, fileobj=None, event_callback=None, raw_callback=None):
         self._fileobj = fileobj
         self._event_callback = event_callback
+        self._event_ct = 0
         self._raw_callback = raw_callback
         self._counter = 1
         self._start_line = 0
@@ -872,6 +873,7 @@ class OutputEventFilter(object):
             self._start_line += n_lines
             if self._event_callback:
                 self._event_callback(event_data)
+                self._event_ct += 1
 
         if next_event_data.get('uuid', None):
             self._current_event_data = next_event_data