Skip to content

Add task progression tracking in ddf console#330

Open
EdsonPetry wants to merge 15 commits intodatafusion-contrib:mainfrom
EdsonPetry:edson.petry/console-task-prog
Open

Add task progression tracking in ddf console#330
EdsonPetry wants to merge 15 commits intodatafusion-contrib:mainfrom
EdsonPetry:edson.petry/console-task-prog

Conversation

@EdsonPetry
Copy link
Contributor

@EdsonPetry EdsonPetry commented Jan 29, 2026

Summary

  • Added task progression tracking for workers via new GetTaskProgress RPC
  • Implemented console control gRPC service with RegisterWorkers RPC for worker discovery
    • Console now connects to workers once client runs query (see console/examples/console.md)
  • Refactored console into separate modules (console/src/main.rs, console/src/app.rs, console/src/ui.rs)

See console/examples/tpcds_runner.md and run TPC-DS query 99 for a good example of the console in action

Other changes

  • Re-exported TaskData
  • Add accessor methods for TaskData
  • Re-exported StageKey

Copy link
Collaborator

@gabotechs gabotechs left a comment

Choose a reason for hiding this comment

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

I have not done a full review of the PR, I just took a quick first look and everything looks really promising!

I just have one comment about one challenge that we might not have anticipated, that would require a relatively major adaptation probably in a separate PR, so for now I'll just leave that comment.

I think this is about to get a bit complicated in a very data structure/algorithmic way...

@EdsonPetry EdsonPetry force-pushed the edson.petry/console-task-prog branch from e42c4aa to a75598e Compare February 4, 2026 15:11
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.

2 participants