Use a separate action for bufsize test case.

Author: Kami

contrib/runners/python_runner/tests/unit/test_pythonrunner.py

@@ -63,6 +63,8 @@
 
 PRINT_CONFIG_ITEM_ACTION = os.path.join(tests_base.get_resources_path(), 'packs',
                                         'pythonactions/actions/print_config_item_doesnt_exist.py')
+PRINT_TO_STDOUT_STDERR_ACTION = os.path.join(tests_base.get_resources_path(), 'packs',
+                                      'pythonactions/actions/print_to_stdout_and_stderr.py')
 
 
 # Note: runner inherits parent args which doesn't work with tests since test pass additional
@@ -417,26 +419,19 @@ def test_real_time_output_streaming_bufsize(self):
                                   group='actionrunner')
 
             output_dbs = ActionExecutionOutput.get_all()
-            self.assertEqual(len(output_dbs), (index - 1) * 3)
+            self.assertEqual(len(output_dbs), (index - 1) * 4)
 
             runner = self._get_mock_runner_obj()
-            runner.runner_parameters = {'log_level': 'INFO'}
-            runner.entry_point = PASCAL_ROW_ACTION_PATH
+            runner.entry_point = PRINT_TO_STDOUT_STDERR_ACTION
             runner.pre_run()
-            (_, output, _) = runner.run({'row_index': 2})
+            (_, output, _) = runner.run({'stdout_count': 2, 'stderr_count': 2})
 
-            expected_stderr = ''.join([
-                'st2.actions.python.PascalRowAction: INFO     test info log message\n',
-                'st2.actions.python.PascalRowAction: ERROR    test error log message\n'
-            ])
-
-            self.assertEqual(output['stdout'], 'Pascal row action\n')
-            self.assertEqual(output['stderr'], expected_stderr)
-            self.assertEqual(output['result'], [1, 2, 1])
+            self.assertEqual(output['stdout'], 'stdout line 0\nstdout line 1\n')
+            self.assertEqual(output['stderr'], 'stderr line 0\nstderr line 1\n')
             self.assertEqual(output['exit_code'], 0)
 
             output_dbs = ActionExecutionOutput.get_all()
-            self.assertEqual(len(output_dbs), (index) * 3)
+            self.assertEqual(len(output_dbs), (index) * 4)
 
     @mock.patch('st2common.util.concurrency.subprocess_popen')
     def test_stdout_interception_and_parsing(self, mock_popen):

st2tests/st2tests/resources/packs/pythonactions/actions/print_to_stdout_and_stderr.py

@@ -0,0 +1,29 @@
+# Copyright 2019 Extreme Networks, Inc.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+from __future__ import absolute_import
+
+import sys
+
+from st2common.runners.base_action import Action
+from six.moves import range
+
+
+class PrintToStdoutAndStderrAction(Action):
+    def run(self, stdout_count=3, stderr_count=3):
+        for index in range(0, stdout_count):
+            sys.stdout.write('stdout line %s\n' % (index))
+
+        for index in range(0, stderr_count):
+            sys.stderr.write('stderr line %s\n' % (index))