From ed08c49564309ff7e0aa9a587d4359a8f6d9ce2d Mon Sep 17 00:00:00 2001 From: serpilliere Date: Sun, 13 Mar 2016 22:30:29 +0100 Subject: Test: simple output --- test/utils/testset.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) (limited to 'test/utils/testset.py') diff --git a/test/utils/testset.py b/test/utils/testset.py index 54df732c..e510ff6e 100644 --- a/test/utils/testset.py +++ b/test/utils/testset.py @@ -1,9 +1,10 @@ import os import subprocess import sys +import time from multiprocessing import cpu_count, Queue, Process -from test import Test +from test import Test class Message(object): "Message exchanged in the TestSet message queue" @@ -136,6 +137,7 @@ class TestSet(object): test = todo_queue.get() if test is None: break + test.start_time = time.time() message_queue.put(MessageTaskNew(test)) # Go to the expected directory -- cgit 1.4.1 From e21cdd93c7352bc9d8f31d920b8b9596caaa7444 Mon Sep 17 00:00:00 2001 From: Fabrice Desclaux Date: Wed, 6 Apr 2016 09:24:08 +0200 Subject: Test/testset: autopep8 --- test/utils/testset.py | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) (limited to 'test/utils/testset.py') diff --git a/test/utils/testset.py b/test/utils/testset.py index e510ff6e..4336f4fa 100644 --- a/test/utils/testset.py +++ b/test/utils/testset.py @@ -6,30 +6,38 @@ from multiprocessing import cpu_count, Queue, Process from test import Test + class Message(object): + "Message exchanged in the TestSet message queue" pass class MessageTaskNew(Message): + "Stand for a new task" + def __init__(self, task): self.task = task class MessageTaskDone(Message): + "Stand for a task done" + def __init__(self, task, error): self.task = task self.error = error class MessageClose(Message): + "Close the channel" pass class TestSet(object): + "Manage a set of test" def __init__(self, base_dir): @@ -40,7 +48,7 @@ class TestSet(object): self.base_dir = base_dir # Init internals - self.task_done_cb = lambda tst, err: None # On task done callback + self.task_done_cb = lambda tst, err: None # On task done callback self.task_new_cb = lambda tst: None # On new task callback self.todo_queue = Queue() # Tasks to do self.message_queue = Queue() # Messages with workers -- cgit 1.4.1