Merge pull request pulp#10 from mdellweg/collect_rq_coverage

Collect coverage from rq worker

.travis/script.sh

@@ -48,8 +48,8 @@ show_logs_and_return_non_zero() {
 }
 
 # Start services
-rq worker -n 'resource-manager@%h' -w 'pulpcore.tasking.worker.PulpWorker' -c 'pulpcore.rqconfig' >> ~/resource_manager.log 2>&1 &
-rq worker -n 'reserved-resource-worker-1@%h' -w 'pulpcore.tasking.worker.PulpWorker' -c 'pulpcore.rqconfig' >> ~/reserved_worker-1.log 2>&1 &
+rq worker -n 'resource-manager@%h' -w 'pulpcore.tests.functional.worker_with_coverage.PulpWorker' -c 'pulpcore.rqconfig' >> ~/resource_manager.log 2>&1 &
+rq worker -n 'reserved-resource-worker-1@%h' -w 'pulpcore.tests.functional.worker_with_coverage.CoveragePulpWorker' -c 'pulpcore.rqconfig' >> ~/reserved_worker-1.log 2>&1 &
 gunicorn pulpcore.tests.functional.content_with_coverage:server --bind 'localhost:8080' --worker-class 'aiohttp.GunicornWebWorker' -w 2 >> ~/content_app.log 2>&1 &
 coverage run $(which pulp-manager) runserver --noreload >> ~/django_runserver.log 2>&1 &
 wait_for_pulp 20

pulpcore/tests/functional/content_with_coverage.py

@@ -14,4 +14,4 @@ def finalize_coverage():
 
 atexit.register(finalize_coverage)
 
-from ...content import server  # noqa
+from pulpcore.content import server  # noqa

pulpcore/tests/functional/worker_with_coverage.py

@@ -0,0 +1,16 @@
+import sys
+import coverage
+
+from pulpcore.tasking.worker import PulpWorker
+
+
+class CoveragePulpWorker(PulpWorker):
+    def perform_job(self, job, queue):
+        cov = coverage.Coverage()
+        cov.start()
+
+        super().perform_job(job, queue)
+
+        print('writing coverage', file=sys.stderr)
+        cov.stop()
+        cov.save()