We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a57a537 commit 52aa859Copy full SHA for 52aa859
1 file changed
tests/test_worker.py
@@ -75,13 +75,13 @@ def test_worker_pipeline_session_file(
75
worker.ingest_session_file(test_session_file, frame_selection="0")
76
77
# Check for results
78
- if worker.has_next_result():
79
- result = worker.get_next_result(timeout=5000)
80
- assert isinstance(result, cuvis.WorkerResult)
81
- assert isinstance(result.mesu, cuvis.Measurement)
+ result = worker.get_next_result(timeout=5000)
+ assert isinstance(result, cuvis.WorkerResult)
+ assert isinstance(result.mesu, cuvis.Measurement)
82
finally:
83
# Clean up
84
worker.stop_processing()
+ worker.drop_all_queued()
85
86
87
def test_worker_state_queries():
0 commit comments