[common] Rename queue names

This code renames the names of Arthur queues: - create --> initial_fetch_jobs - update --> incremental_fetch_jobs - archive --> archive_jobs Tests have been updated accordingly. Signed-off-by: Valerio Cosentino <[email protected]>
chaoss · Oct 22, 2019 · eeaae76 · eeaae76
1 parent 60b05a9
commit eeaae76
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/arthur/common.py b/arthur/common.py
@@ -24,9 +24,9 @@
 
 CH_PUBSUB = 'ch_arthur'
 
-Q_ARCHIVE_JOBS = 'archive'
-Q_CREATION_JOBS = 'create'
-Q_UPDATING_JOBS = 'update'
+Q_ARCHIVE_JOBS = 'archive_jobs'
+Q_CREATION_JOBS = 'initial_fetch_jobs'
+Q_UPDATING_JOBS = 'incremental_fetch_jobs'
 Q_STORAGE_ITEMS = 'items'
 
 TIMEOUT = 3600 * 24

diff --git a/tests/test_server.py b/tests/test_server.py
@@ -32,6 +32,7 @@
 import rq
 
 from arthur.server import ArthurServer
+from arthur.common import Q_CREATION_JOBS
 
 from base import TestBaseRQ
 
@@ -372,7 +373,7 @@ def test_job(self, mock_utcnow):
             self.assertEqual(job['job_id'], job_task_result['job_id'])
             self.assertEqual(job['job_status'], 'finished')
             self.assertEqual(job['timeout'], 86400)
-            self.assertEqual(job['origin'], 'create')
+            self.assertEqual(job['origin'], Q_CREATION_JOBS)
             self.assertEqual(job['result'], job_task_result)
             self.assertEqual(job['log'], mock_logs)