diff --git a/include/mscclpp/core.hpp b/include/mscclpp/core.hpp
index 50a922bc3..1e0ec46ea 100644
--- a/include/mscclpp/core.hpp
+++ b/include/mscclpp/core.hpp
@@ -707,7 +707,7 @@ class Communicator {
   /// @param allRanks The ranks of all processes involved in the collective.
   /// @param config The configuration for the local endpoint.
   /// @return std::shared_ptr<NvlsConnection> A shared pointer to the NVLS connection.
-  std::shared_ptr<NvlsConnection> connctNvlsCollective(std::vector<int> allRanks, EndpointConfig config);
+  std::shared_ptr<NvlsConnection> connectNvlsCollective(std::vector<int> allRanks, EndpointConfig config);
 
   /// Get the remote rank a connection is connected to.
   ///
diff --git a/python/mscclpp/core_py.cpp b/python/mscclpp/core_py.cpp
index 1a1cd2780..df90cc3cf 100644
--- a/python/mscclpp/core_py.cpp
+++ b/python/mscclpp/core_py.cpp
@@ -189,7 +189,7 @@ void register_core(nb::module_& m) {
       .def("recv_memory_on_setup", &Communicator::recvMemoryOnSetup, nb::arg("remoteRank"), nb::arg("tag"))
       .def("connect_on_setup", &Communicator::connectOnSetup, nb::arg("remoteRank"), nb::arg("tag"),
            nb::arg("localConfig"))
-      .def("connct_nvls_collective", &Communicator::connctNvlsCollective, nb::arg("allRanks"), nb::arg("config"))
+      .def("connct_nvls_collective", &Communicator::connectNvlsCollective, nb::arg("allRanks"), nb::arg("config"))
       .def("remote_rank_of", &Communicator::remoteRankOf)
       .def("tag_of", &Communicator::tagOf)
       .def("setup", &Communicator::setup);
diff --git a/src/communicator.cc b/src/communicator.cc
index d0fb07a23..bd6a246d3 100644
--- a/src/communicator.cc
+++ b/src/communicator.cc
@@ -105,8 +105,8 @@ MSCCLPP_API_CPP NonblockingFuture<std::shared_ptr<Connection>> Communicator::con
   return NonblockingFuture<std::shared_ptr<Connection>>(connector->connectionPromise_.get_future());
 }
 
-MSCCLPP_API_CPP std::shared_ptr<NvlsConnection> Communicator::connctNvlsCollective(std::vector<int> allRanks,
-                                                                                   EndpointConfig config) {
+MSCCLPP_API_CPP std::shared_ptr<NvlsConnection> Communicator::connectNvlsCollective(std::vector<int> allRanks,
+                                                                                    EndpointConfig config) {
   auto bootstrap = this->bootstrap();
   int rank = bootstrap->getRank();
   bool isRoot = false;