Skip to content

Commit

Permalink
Use unique queue names for tests
Browse files Browse the repository at this point in the history
  • Loading branch information
rustworthy committed Jan 27, 2024
1 parent a12e38a commit 83d0d05
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions tests/real/async/enterprise.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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())
Expand Down Expand Up @@ -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,
Expand Down Expand Up @@ -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;
Expand Down Expand Up @@ -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)
Expand Down

0 comments on commit 83d0d05

Please sign in to comment.