fix delete job bug

Author: ChuckHend

core/src/init.rs

@@ -330,7 +330,7 @@ pub async fn cleanup_job(pool: &PgPool, job_name: &str) -> Result<(), VectorizeE
     // Delete pending PGMQ messages for this job
     // We search for messages where the job_name matches
     let delete_messages_query =
-        "DELETE FROM pgmq.vectorize_jobs WHERE message->>'job_name' = $1".to_string();
+        "DELETE FROM pgmq.q_vectorize_jobs WHERE message->>'job_name' = $1".to_string();
     match sqlx::query(&delete_messages_query)
         .bind(job_name)
         .execute(pool)

server/tests/tests.rs

@@ -1098,21 +1098,7 @@ async fn test_delete_job_with_pending_messages() {
     let cfg = vectorize_core::config::Config::from_env();
     let pool = sqlx::PgPool::connect(&cfg.database_url).await.unwrap();
 
-    let mut rng = rand::rng();
-    let test_num = rng.random_range(1..100000);
-    let table = format!("test_pending_msgs_{test_num}");
-
-    // Create table
-    sqlx::query(&format!(
-        "CREATE TABLE IF NOT EXISTS vectorize_test.{table} (
-                id SERIAL PRIMARY KEY, 
-                content TEXT, 
-                updated_at TIMESTAMPTZ DEFAULT NOW()
-            );"
-    ))
-    .execute(&pool)
-    .await
-    .unwrap();
+    let table = common::create_test_table().await;
 
     // Insert multiple rows
     for i in 0..10 {
@@ -1125,7 +1111,7 @@ async fn test_delete_job_with_pending_messages() {
         .unwrap();
     }
 
-    let job_name = format!("test_pending_{test_num}");
+    let job_name = format!("test_pending_{}", table);
 
     // Create a vectorize job
     let payload = json!({