Fixing redis queue for tests by adding prefix (#921)

* fixing redis queue for tests by adding prefix

* changing queue prefix for redis prefix so that it fixes it for all redis keys for tests

* Revert "changing queue prefix for redis prefix so that it fixes it for all redis keys for tests"

This reverts commit 32ff62d.

.env.test

@@ -10,6 +10,7 @@ SQS_BACKFILL_QUEUE_URL=http://127.0.0.1:4566/000000000000/test-backfill
 SQS_BACKFILL_QUEUE_REGION=us-west-1
 SQS_PUSH_QUEUE_URL=http://127.0.0.1:4566/000000000000/test-push
 SQS_PUSH_QUEUE_REGION=us-west-1
+BULL_QUEUE_PREFIX=bulltest
 
 MICROS_AWS_REGION=us-west-1
 

src/config/env.ts

@@ -87,6 +87,7 @@ export interface EnvVars {
 	GIT_BRANCH_NAME?: string;
 	GITHUB_REPO_URL: string;
 	DEPLOYMENT_DATE: string;
+	BULL_QUEUE_PREFIX?: string;
 
 	// Test Vars
 	ATLASSIAN_SECRET?: string;

src/worker/queues.ts

@@ -5,6 +5,7 @@ import * as Sentry from "@sentry/node";
 import statsd from "../config/statsd";
 import { getLogger } from "../config/logger";
 import {metricError, redisQueueMetrics} from "../config/metric-names";
+import envVars from "../config/env";
 
 const client = new Redis(getRedisInfo("client"));
 const subscriber = new Redis(getRedisInfo("subscriber"));
@@ -26,6 +27,7 @@ const getQueueOptions = (timeout: number): QueueOptions => {
 			removeOnComplete: true,
 			removeOnFail: true
 		},
+		prefix: envVars.BULL_QUEUE_PREFIX,
 		settings: {
 			// lockDuration must be greater than the timeout, so that it doesn't get processed again prematurely
 			lockDuration: timeout + 500