diff --git a/backend/windmill-queue/src/schedule.rs b/backend/windmill-queue/src/schedule.rs index a88e6e184f..c9970b0644 100644 --- a/backend/windmill-queue/src/schedule.rs +++ b/backend/windmill-queue/src/schedule.rs @@ -152,7 +152,11 @@ pub async fn push_scheduled_job<'c, R: rsmq_async::RsmqConnection + Send + 'c>( language, priority, }, - schedule.tag.or(tag), + if schedule.tag.as_ref().is_some_and(|x| x != "") { + schedule.tag + } else { + tag + }, timeout, ) }