formatting

csrc/aio/py_lib/deepspeed_aio_thread.cpp

@@ -29,7 +29,7 @@ void deepspeed_aio_thread_t::run()
         {
             std::unique_lock<std::mutex> lock(_work_sync._mutex);
             _work_sync._cond_var.wait(lock,
-                                       [this] { return (!_work_queue.empty() || _time_to_exit); });
+                                      [this] { return (!_work_queue.empty() || _time_to_exit); });
             if (!_work_queue.empty()) {
                 next_io_op = _work_queue.front();
                 _work_queue.pop();

csrc/aio/py_lib/deepspeed_py_io_handle.cpp

@@ -148,7 +148,7 @@ std::shared_ptr<struct io_op_desc_t> deepspeed_io_handle_t::_wait_for_aio_work()
     for (auto& ctxt : _thread_contexts) {
         std::unique_lock<std::mutex> lock(ctxt->_complete_sync._mutex);
         ctxt->_complete_sync._cond_var.wait(lock,
-                                             [ctxt] { return !ctxt->_complete_queue.empty(); });
+                                            [ctxt] { return !ctxt->_complete_queue.empty(); });
         completed_op = ctxt->_complete_queue.front();
         ctxt->_complete_queue.pop();
     }