Skip to content

Conversation

@guptapratykshh
Copy link
Contributor

@guptapratykshh guptapratykshh commented Dec 17, 2025

This PR introduces new dora node info command that offers detailed information about running nodes in dataflows. This makes it easier to monitor node status, connections, and resource usage.

The new command provides a clear view of any node in dataflow:

  • Status & Process Info: Shows the node's running status and process ID (PID).
  • Dataflow Context: Displays which dataflow the node belongs to, along with the daemon or machine it's running on.
  • Topology: Lists all input topics that the node subscribes to and the output topics it publishes.
  • Resource Metrics: Shows real-time CPU usage, memory consumption, and disk I/O statistics.

Resolves #1203

@guptapratykshh guptapratykshh force-pushed the feature/node-info-command-1203 branch from 6e4925c to 9874c2b Compare December 17, 2025 19:58
@guptapratykshh
Copy link
Contributor Author

Please review this PR. Thanks. @phil-opp

@haixuanTao
Copy link
Collaborator

Closing this as well because there is no way you can get cpu_usage from the daemon as it is currently implemented.

@haixuanTao haixuanTao closed this Dec 30, 2025
@guptapratykshh
Copy link
Contributor Author

I double-checked daemon/src/lib.rs and it looks like we're actually already grabbing CPU stats via sysinfo in
collect_and_send_metrics. The daemon refreshes this every few seconds and pushes it to the coordinator, so the data is there and ready to be displayed.

@phil-opp
Copy link
Collaborator

Yes, this was added as part of #1251

@phil-opp phil-opp reopened this Jan 14, 2026
@haixuanTao
Copy link
Collaborator

Ok my bad, didn't look at @1251

@guptapratykshh
Copy link
Contributor Author

any updates on this @phil-opp

Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Could you please remove the unrelated edits in this file?

pub struct Info {
/// Name of the node to inspect
#[clap(value_name = "NODE_NAME")]
node_name: NodeId,
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We're typically talking about node IDs, not names in Dora.

match format {
OutputFormat::Table => {
println!("Name: {}", selected_node.node_id);
println!("Status: Running");
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Why hardcode this? The node might not be running anymore.

@guptapratykshh guptapratykshh force-pushed the feature/node-info-command-1203 branch from 4f77f95 to 18aed9b Compare January 26, 2026 16:17
@guptapratykshh guptapratykshh force-pushed the feature/node-info-command-1203 branch from 18aed9b to 042c12e Compare January 26, 2026 16:49
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Implement dora node info Command

3 participants