removing debug logs now that problem seems fixed

mdorier · mdorier · commit 68686f9b44dd · 2021-04-05T18:24:09.000+01:00
diff --git a/src/DistributedPipelineHandle.cpp b/src/DistributedPipelineHandle.cpp
@@ -110,7 +110,6 @@ void DistributedPipelineHandle::start(uint64_t iteration) {
                         retry = true;
                     }
                 } else {
-                    spdlog::debug("Pipeline started at {}", static_cast<std::string>(p.self->m_ph));
                     started.push_back(&p);
                 }
             }
@@ -121,7 +120,6 @@ void DistributedPipelineHandle::start(uint64_t iteration) {
             if(!ok) { // one RPC failed to be sent, send "abort to the
                 for(auto pipeline : started) {
                     try {
-                        spdlog::debug("Sending abort message to pipeline");
                         auto async_response = abort.on(pipeline->self->m_ph).async(pipeline->self->m_name, iteration);
                         async_responses.push_back(std::move(async_response));
                     } catch(...) {

Original file line number	Diff line number	Diff line change
`@@ -110,7 +110,6 @@ void DistributedPipelineHandle::start(uint64_t iteration) {`
`110`	`110`	`retry = true;`
`111`	`111`	`}`
`112`	`112`	`} else {`
`113`		`- spdlog::debug("Pipeline started at {}", static_cast<std::string>(p.self->m_ph));`
`114`	`113`	`started.push_back(&p);`
`115`	`114`	`}`
`116`	`115`	`}`
`@@ -121,7 +120,6 @@ void DistributedPipelineHandle::start(uint64_t iteration) {`
`121`	`120`	`if(!ok) { // one RPC failed to be sent, send "abort to the`
`122`	`121`	`for(auto pipeline : started) {`
`123`	`122`	`try {`
`124`		`- spdlog::debug("Sending abort message to pipeline");`
`125`	`123`	`auto async_response = abort.on(pipeline->self->m_ph).async(pipeline->self->m_name, iteration);`
`126`	`124`	`async_responses.push_back(std::move(async_response));`
`127`	`125`	`} catch(...) {`