Skip to content

Commit

Permalink
Update DSM nodeJS tests for RabbitMQ (#3346)
Browse files Browse the repository at this point in the history
  • Loading branch information
piochelepiotr authored Nov 1, 2024
1 parent c846718 commit 86596aa
Showing 1 changed file with 2 additions and 6 deletions.
8 changes: 2 additions & 6 deletions tests/integrations/test_dsm.py
Original file line number Diff line number Diff line change
Expand Up @@ -151,11 +151,7 @@ def test_dsm_rabbitmq(self):
# There is currently no FNV-1 library availble for node.js
# So we are using a different algorithm for node.js for now
language_hashes = {
"nodejs": {
"producer": 5246740674878013159,
"consumer": 10215641161150038469,
"edge_tags_in": ("direction:in", f"topic:{DSM_ROUTING_KEY}", "type:rabbitmq"),
},
"nodejs": {"producer": 5246740674878013159, "consumer": 8116149247198652772,},
"default": {
"producer": 8945717757344503539,
"consumer": 247866491670975357,
Expand All @@ -166,7 +162,7 @@ def test_dsm_rabbitmq(self):

producer_hash = language_hashes.get(context.library.library, language_hashes.get("default"))["producer"]
consumer_hash = language_hashes.get(context.library.library, language_hashes.get("default"))["consumer"]
edge_tags_in = language_hashes.get(context.library.library, language_hashes.get("default"))["edge_tags_in"]
edge_tags_in = language_hashes.get("default")["edge_tags_in"]
edge_tags_out = language_hashes.get("default")["edge_tags_out"]

DsmHelper.assert_checkpoint_presence(
Expand Down

0 comments on commit 86596aa

Please sign in to comment.