From d3bee4fcc52a4e9328db3fca7bdfbc34abf9a6a3 Mon Sep 17 00:00:00 2001 From: derAnfaenger Date: Fri, 10 Nov 2017 12:43:53 +0100 Subject: [PATCH] queue_processors: Exclude various lines from coverage. The os.mkdir call is straightforward and doesn't testing. Workers relying on LoopQueueProcessingWorker are tested with its consume method that exists solely for this purpose. --- zerver/worker/queue_processors.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/zerver/worker/queue_processors.py b/zerver/worker/queue_processors.py index 719f1a49ca..368a74e586 100644 --- a/zerver/worker/queue_processors.py +++ b/zerver/worker/queue_processors.py @@ -142,7 +142,7 @@ class QueueProcessingWorker: except Exception: self._log_problem() if not os.path.exists(settings.QUEUE_ERROR_DIR): - os.mkdir(settings.QUEUE_ERROR_DIR) + os.mkdir(settings.QUEUE_ERROR_DIR) # nocoverage fname = '%s.errors' % (self.queue_name,) fn = os.path.join(settings.QUEUE_ERROR_DIR, fname) line = u'%s\t%s\n' % (time.asctime(), ujson.dumps(data)) @@ -174,7 +174,7 @@ class QueueProcessingWorker: class LoopQueueProcessingWorker(QueueProcessingWorker): sleep_delay = 0 - def start(self) -> None: + def start(self) -> None: # nocoverage while True: # TODO: Probably it'd be better to share code with consume_wrapper() events = self.q.drain_queue(self.queue_name, json=True)