Skip to content

Commit f59ecc8

Browse files
committed
VED-386: Fix lint error. Tidy up a couple of tests.
1 parent 3e8f6a9 commit f59ecc8

File tree

2 files changed

+12
-9
lines changed

2 files changed

+12
-9
lines changed

filenameprocessor/src/send_sqs_message.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,12 @@ def send_to_supplier_queue(message_body: dict, vaccine_type: str, supplier: str)
2727

2828

2929
def make_and_send_sqs_message(
30-
file_key: str, message_id: str, permission: list[str], vaccine_type: str, supplier: str, created_at_formatted_string: str
30+
file_key: str,
31+
message_id: str,
32+
permission: list[str],
33+
vaccine_type: str,
34+
supplier: str,
35+
created_at_formatted_string: str
3136
) -> None:
3237
"""Attempts to send a message to the SQS queue. Raises an exception if the message is not successfully sent."""
3338
message_body = {

filenameprocessor/tests/test_elasticache.py

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -29,16 +29,14 @@ def tearDown(self):
2929
"""Tear down the S3 buckets"""
3030
GenericTearDown(s3_client)
3131

32-
@patch("elasticache.redis_client")
33-
def test_get_supplier_permissions_from_cache(self, mock_redis_client):
34-
mock_redis_client.hget.return_value = json.dumps(["COVID19.CRUDS", "RSV.CRUDS"])
32+
@patch("elasticache.redis_client.hget", return_value=json.dumps(["COVID19.CRUDS", "RSV.CRUDS"]))
33+
def test_get_supplier_permissions_from_cache(self, mock_hget):
3534
result = get_supplier_permissions_from_cache("TEST_SUPPLIER")
3635
self.assertEqual(result, ["COVID19.CRUDS", "RSV.CRUDS"])
37-
mock_redis_client.hget.assert_called_once_with("supplier_permissions", "TEST_SUPPLIER")
36+
mock_hget.assert_called_once_with("supplier_permissions", "TEST_SUPPLIER")
3837

39-
@patch("elasticache.redis_client")
40-
def test_get_supplier_permissions_from_cache_not_found(self, mock_redis_client):
41-
mock_redis_client.hget.return_value = None
38+
@patch("elasticache.redis_client.hget", return_value=None)
39+
def test_get_supplier_permissions_from_cache_not_found(self, mock_hget):
4240
result = get_supplier_permissions_from_cache("TEST_SUPPLIER")
4341
self.assertEqual(result, [])
44-
mock_redis_client.hget.assert_called_once_with("supplier_permissions", "TEST_SUPPLIER")
42+
mock_hget.assert_called_once_with("supplier_permissions", "TEST_SUPPLIER")

0 commit comments

Comments
 (0)