small docfix, upgrade workflows

firstbatchxyz · Sep 9, 2024 · f97657d · f97657d
1 parent d8cfba0
commit f97657d
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 7 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -45,7 +45,7 @@ sha3 = "0.10.8"
 fastbloom-rs = "0.5.9"
 
 # workflows
-ollama-workflows = { git = "https://github.com/andthattoo/ollama-workflows", rev = "aaa887e" }
+ollama-workflows = { git = "https://github.com/andthattoo/ollama-workflows", rev = "66e46d2" }
 
 # peer-to-peer
 libp2p = { git = "https://github.com/anilaltuner/rust-libp2p.git", rev = "7ce9f9e", features = [

diff --git a/src/p2p/behaviour.rs b/src/p2p/behaviour.rs
@@ -41,8 +41,6 @@ fn create_kademlia_behavior(local_peer_id: PeerId) -> kad::Behaviour<MemoryStore
     const QUERY_TIMEOUT_SECS: u64 = 5 * 60;
     const RECORD_TTL_SECS: u64 = 30;
 
-    // TODO: use versioning here?
-
     let mut cfg = Config::new(P2P_KADEMLIA_PROTOCOL);
     cfg.set_query_timeout(Duration::from_secs(QUERY_TIMEOUT_SECS))
         .set_record_ttl(Some(Duration::from_secs(RECORD_TTL_SECS)));

diff --git a/src/p2p/client.rs b/src/p2p/client.rs
@@ -226,7 +226,7 @@ impl P2PClient {
                     log::warn!("Local node is listening on {}", address);
                 }
                 SwarmEvent::ExternalAddrConfirmed { address } => {
-                    log::warn!("External address confirmed: {}", address);
+                    log::info!("External address confirmed: {}", address);
                 }
                 event => log::trace!("Unhandled Swarm Event: {:?}", event),
             }
@@ -245,7 +245,7 @@ impl P2PClient {
         // check protocol string
         if info.protocol_version != P2P_PROTOCOL_STRING {
             log::warn!(
-                "Identify: Peer {} has different Identify protocol: (have {}, want {})",
+                "Identify: Peer {} has different Identify protocol: (them {}, you {})",
                 peer_id,
                 info.protocol_version,
                 P2P_PROTOCOL_STRING
@@ -274,7 +274,7 @@ impl P2PClient {
                     .add_address(&peer_id, addr);
             } else {
                 log::warn!(
-                    "Identify: Peer {} has different Kademlia version: (have {}, want {})",
+                    "Identify: Peer {} has different Kademlia version: (them {}, you {})",
                     peer_id,
                     kad_protocol,
                     P2P_KADEMLIA_PROTOCOL