diff --git a/libs/dmf-node/src/node_runner.cpp b/libs/dmf-node/src/node_runner.cpp
index 1bee049..397acce 100644
--- a/libs/dmf-node/src/node_runner.cpp
+++ b/libs/dmf-node/src/node_runner.cpp
@@ -120,6 +120,7 @@ spdlog::info("Created flow writer on port '{}' flow {} (created={})", port_id, f
         flow_resources.push_back({port_id, writer, nullptr});
         node->set_writer_config(port_id, config_info);
         node->on_add_writer(port_id, writer);
+        return {{"ok", true}, {"created", created}};
     });
 
     control_server->register_command("add_reader", [&](const nlohmann::json& msg) -> nlohmann::json {
@@ -138,6 +139,7 @@ spdlog::info("Created flow reader on port '{}' flow {}", port_id, flow_id);
         mxlFlowReaderGetConfigInfo(reader, &config);
         node->set_reader_config(port_id, config);
         node->on_add_reader(port_id, reader);
+        return {{"ok", true}};
     });
 
     control_server->register_command("remove_writer", [&](const nlohmann::json& msg) -> nlohmann::json {