don't apply immediately if we have queued items, only apply if job worker has all the capacity in the world. reduce apply timeout and apply queue

Author: jeromegn

crates/corro-agent/src/agent/handlers.rs

@@ -760,7 +760,7 @@ pub async fn handle_changes(
     // complicated loop to process changes efficiently w/ a max concurrency
     // and a minimum chunk size for bigger and faster SQLite transactions
     loop {
-        while (buf_cost >= max_changes_chunk || !queue.is_empty())
+        while (buf_cost >= max_changes_chunk || !queue.is_empty() && join_set.is_empty())
             && join_set.len() < MAX_CONCURRENT
         {
             // Process if we hit the chunk size OR if we have any items and available capacity

crates/corro-types/src/config.rs

@@ -8,7 +8,7 @@ pub const DEFAULT_GOSSIP_PORT: u16 = 4001;
 const DEFAULT_GOSSIP_IDLE_TIMEOUT: u32 = 30;
 
 const fn default_apply_queue() -> usize {
-    100
+    50
 }
 
 const fn default_wal_threshold() -> usize {
@@ -38,7 +38,7 @@ const fn default_small_channel() -> usize {
 }
 
 const fn default_apply_timeout() -> usize {
-    50
+    10
 }
 
 #[derive(Debug, Clone, Serialize, Deserialize)]