Skip to content

Commit

Permalink
reorg files
Browse files Browse the repository at this point in the history
  • Loading branch information
yczhang-nv committed Sep 25, 2024
1 parent e1a95d3 commit 52ccfbe
Show file tree
Hide file tree
Showing 5 changed files with 4 additions and 10 deletions.
2 changes: 1 addition & 1 deletion python/morpheus/morpheus/_lib/cmake/libmorpheus.cmake
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@ include(GenerateExportHeader)
add_library(morpheus

# Keep these sorted!
src/controllers/monitor_controller.cpp
src/io/data_loader_registry.cpp
src/io/data_loader.cpp
src/io/deserializers.cpp
Expand Down Expand Up @@ -60,7 +61,6 @@ add_library(morpheus
src/stages/inference_client_stage.cpp
src/stages/kafka_source.cpp
src/stages/monitor.cpp
src/stages/monitor_controller.cpp
src/stages/preprocess_fil.cpp
src/stages/preprocess_nlp.cpp
src/stages/serialize.cpp
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@
#pragma once

#include "morpheus/export.h" // for MORPHEUS_EXPORT
#include "morpheus/stages/monitor_controller.hpp" // for MonitorController
#include "morpheus/controllers/monitor_controller.hpp" // for MonitorController

#include <indicators/progress_bar.hpp>
#include <mrc/segment/builder.hpp> // for Builder
Expand Down Expand Up @@ -50,9 +50,6 @@ class MORPHEUS_EXPORT MonitorStage : public mrc::pymrc::PythonNode<std::shared_p
using typename base_t::subscribe_fn_t;

MonitorStage(const std::string& description,
float smoothing,
const std::string& unit,
bool delayed_start,
std::optional<std::function<int(MessageT)>> determine_count_fn = std::nullopt);

private:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* limitations under the License.
*/

#include "morpheus/stages/monitor_controller.hpp"
#include "morpheus/controllers/monitor_controller.hpp"

#include "indicators/setting.hpp"

Expand Down
5 changes: 1 addition & 4 deletions python/morpheus/morpheus/_lib/src/stages/monitor.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -23,13 +23,10 @@ namespace morpheus {
// ****************** MonitorStage ************************ //
template <typename MessageT>
MonitorStage<MessageT>::MonitorStage(const std::string& description,
float smoothing,
const std::string& unit,
bool delayed_start,
std::optional<std::function<int(MessageT)>> determine_count_fn) :
base_t(base_t::op_factory_from_sub_fn(build_operator()))
{
m_monitor_controller = MonitorController<MessageT>(description, smoothing, unit, delayed_start, determine_count_fn);
m_monitor_controller = MonitorController<MessageT>(description, determine_count_fn);
}

template <typename MessageT>
Expand Down

0 comments on commit 52ccfbe

Please sign in to comment.