get rid of duplicate counter variable

2026-05-15 07:48:38 -05:00 · 2018-06-05 15:54:48 -04:00
parent 26ffad11a5
commit 16696a6fea
3 changed files with 4 additions and 6 deletions
@@ -1006,7 +1006,7 @@ class BaseTask(Task):
                if stdout_handle:
                    stdout_handle.flush()
                    stdout_handle.close()
-                    event_ct = getattr(stdout_handle, '_event_ct', 0)
+                    event_ct = getattr(stdout_handle, '_counter', 0)
                logger.info('%s finished running, producing %s events.',
                            instance.log_format, event_ct)
            except Exception: