From 83d0d05dbd1ad5edc69cd668aa60e4220e44f3a0 Mon Sep 17 00:00:00 2001 From: Pavel Mikhalkevich Date: Sat, 27 Jan 2024 13:10:10 +0500 Subject: [PATCH] Use unique queue names for tests --- tests/real/async/enterprise.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/tests/real/async/enterprise.rs b/tests/real/async/enterprise.rs index 123b22b1..922a391b 100644 --- a/tests/real/async/enterprise.rs +++ b/tests/real/async/enterprise.rs @@ -91,7 +91,7 @@ async fn async_ent_unique_job() { // Reminder. Jobs are considered unique for kind + args + queue. // So the following two jobs, will be accepted by Faktory, since we // are not setting 'unique_for' when creating those jobs: - let queue_name = "ent_unique_job"; + let queue_name = "async_ent_unique_job"; let args = vec![Value::from("ISBN-13:9781718501850"), Value::from(100)]; let job1 = JobBuilder::new(job_type) .args(args.clone()) @@ -180,7 +180,7 @@ async fn async_ent_unique_job_until_success() { let url = learn_faktory_url(); - let queue_name = "ent_unique_job_until_success"; + let queue_name = "async_ent_unique_job_until_success"; let job_type = "order"; // the job will be being executed for at least 3 seconds, @@ -269,7 +269,7 @@ async fn async_ent_unique_job_until_start() { let url = learn_faktory_url(); - let queue_name = "ent_unique_job_until_start"; + let queue_name = "async_ent_unique_job_until_start"; let job_type = "order"; let difficulty_level = 3; let unique_for = 4; @@ -337,7 +337,7 @@ async fn async_ent_unique_job_bypass_unique_lock() { let url = learn_faktory_url(); let mut producer = AsyncProducer::connect(Some(&url)).await.unwrap(); - let queue_name = "ent_unique_job_bypass_unique_lock"; + let queue_name = "async_ent_unique_job_bypass_unique_lock"; let job1 = Job::builder("order") .queue(queue_name) .unique_for(60)