adding a test to validate new flag

Author: dagansandler

examples/threads/__init__.py

@@ -0,0 +1,19 @@
+import logging
+import threading
+
+from reportportal_client.steps import step
+
+log = logging.getLogger(__name__)
+
+
+def worker():
+    log.info("TEST_INFO")
+    log.debug("TEST_DEBUG")
+
+
+def test_log():
+    t = threading.Thread(target=worker)
+    log.info("TEST_BEFORE_THREADING")
+    with step("Some nesting where the thread logs should go"):
+        t.start()
+    t.join()

examples/threads/test_thread_logging.py

@@ -0,0 +1,32 @@
+from six.moves import mock
+
+from tests import REPORT_PORTAL_SERVICE
+from tests.helpers import utils
+
+
+@mock.patch('pytest_reportportal.rp_logging.RPClient')
+@mock.patch(REPORT_PORTAL_SERVICE)
+def test_rp_thread_logs_reporting(mock_client_init, mock_thread_client_init):
+    """Verify logs from threads are sent to correct items`.
+
+    :param mock_client_init: Pytest fixture
+    """
+    mock_client = mock_client_init.return_value
+    mock_thread_client = mock_thread_client_init.return_value
+
+    def init_thread_client(*_, **__):
+        from reportportal_client._local import set_current
+        set_current(mock_thread_client)
+        return mock_thread_client
+    mock_thread_client_init.side_effect = init_thread_client
+    result = utils.run_tests_with_client(
+        mock_client,
+        ['examples/threads/'],
+        args=["--rp-thread-logging"]
+    )
+
+    assert int(result) == 0, 'Exit code should be 0 (no errors)'
+    assert mock_client.start_launch.call_count == 1, \
+        '"start_launch" method was not called'
+    assert mock_client.log.call_count == 1
+    assert mock_thread_client.log.call_count == 2