From af0c896768f534563127188bc1ca6acf7c06c34f Mon Sep 17 00:00:00 2001 From: Ivan Santiago Paunovic Date: Fri, 29 Oct 2021 10:46:29 -0300 Subject: [PATCH] logs to debug on windows without a VM Signed-off-by: Ivan Santiago Paunovic --- launch_pytest/launch_pytest/fixture.py | 7 +++++++ launch_pytest/test/launch_pytest/tools/test_process.py | 4 ++++ 2 files changed, 11 insertions(+) diff --git a/launch_pytest/launch_pytest/fixture.py b/launch_pytest/launch_pytest/fixture.py index 103214633..178ab0e5a 100644 --- a/launch_pytest/launch_pytest/fixture.py +++ b/launch_pytest/launch_pytest/fixture.py @@ -72,19 +72,26 @@ def get_event_loop_fixture(*, scope='function', overridable=True): @pytest.fixture(scope=scope) def event_loop(): """Create an event loop instance for each test case.""" + import sys + import traceback loop = asyncio.get_event_loop_policy().new_event_loop() policy = asyncio.get_event_loop_policy() try: old_loop = policy.get_event_loop() if old_loop is not loop: old_loop.close() + print('bye event loop 2', file=sys.stderr) + traceback.print_stack() except RuntimeError: # Swallow this, since it's probably bad event loop hygiene. pass policy.set_event_loop(loop) + print('new event loop', file=sys.stderr) yield loop loop.close() asyncio.set_event_loop_policy(None) + print('bye event loop 1', file=sys.stderr) + traceback.print_stack() if overridable: event_loop._launch_pytest_overridable_fixture = True event_loop._launch_pytest_fixture_scope = scope diff --git a/launch_pytest/test/launch_pytest/tools/test_process.py b/launch_pytest/test/launch_pytest/tools/test_process.py index 396ac285d..fd2113629 100644 --- a/launch_pytest/test/launch_pytest/tools/test_process.py +++ b/launch_pytest/test/launch_pytest/tools/test_process.py @@ -27,6 +27,7 @@ time.sleep(5) """ +import sys @pytest.fixture def dut(): @@ -39,6 +40,7 @@ def dut(): @launch_pytest.fixture def launch_description(dut): + print('new launch description', file=sys.stderr) return launch.LaunchDescription([ dut, ]) @@ -46,6 +48,7 @@ def launch_description(dut): @pytest.mark.launch(fixture=launch_description) async def test_async_process_tools(dut, launch_context): + print('test async', file=sys.stderr) await tools.wait_for_start(launch_context, dut, timeout=10) def check_output(output): assert output == 'hello\n' await tools.wait_for_output( @@ -59,6 +62,7 @@ def check_stderr(err): assert err == 'world\n' @pytest.mark.launch(fixture=launch_description) def test_sync_process_tools(dut, launch_context): + print('test sync', file=sys.stderr) tools.wait_for_start_sync(launch_context, dut, timeout=10) def check_output(output): assert output == 'hello\n' tools.wait_for_output_sync(