Fix

tembo-io · Sep 15, 2023 · 8be5c29 · 8be5c29
1 parent e255272
commit 8be5c29
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/core/src/query.rs b/core/src/query.rs
@@ -72,6 +72,7 @@ pub fn create_meta() -> String {
         "
         CREATE TABLE IF NOT EXISTS {PGMQ_SCHEMA}.meta (
             queue_name VARCHAR UNIQUE NOT NULL,
+            is_partitioned BOOLEAN NOT NULL,
             created_at TIMESTAMP WITH TIME ZONE DEFAULT now() NOT NULL
         );
         "

diff --git a/pgmq-rs/tests/pg_ext_integration_test.rs b/pgmq-rs/tests/pg_ext_integration_test.rs
@@ -19,6 +19,7 @@ fn replace_db_string(s: &str, replacement: &str) -> String {
 async fn init_queue_ext(qname: &str) -> pgmq::PGMQueueExt {
     let db_url = env::var("DATABASE_URL")
         .unwrap_or_else(|_| "postgres://postgres:postgres@localhost:5432/postgres".to_owned());
+    dbg!(db_url.clone());
     let queue = pgmq::PGMQueueExt::new(db_url.clone(), 2)
         .await
         .expect("failed to connect to postgres");