skip first tick

Author: somtochiama

Cargo.lock

@@ -8,7 +8,6 @@ bytes = { workspace = true }
 compact_str = { workspace = true }
 corro-types = { path = "../corro-types" }
 eyre = { workspace = true }
-sqlite-pool = { path = "../sqlite-pool" }
 fallible-iterator = { workspace = true }
 futures = { workspace = true }
 hex = { workspace = true }

crates/corro-pg/Cargo.toml

@@ -320,7 +320,7 @@ fn parse_query(sql: &str) -> Result<VecDeque<ParsedCmd>, ParseError> {
                 break;
             }
             Err(e) => {
-                debug!("could not parse as sqlite {sql:?}: {e}");
+                debug!("could not parse statement ({sql:?}) as sqlite: {e}");
                 let stmts = sqlparser::parser::Parser::parse_sql(
                     &sqlparser::dialect::PostgreSqlDialect {},
                     normalized,

crates/corro-pg/src/lib.rs

@@ -773,7 +773,10 @@ async fn wait_conn_drop(tx: oneshot::Sender<CancellationToken>) {
     }
 
     let mut interval = tokio::time::interval(Duration::from_secs(5*60));
+    // skip first tick
+    interval.tick().await;
     let start = Instant::now();
+
     loop {
         tokio::select! {
             _ = cancel.cancelled() => {