Closed discord9 closed 1 month ago
The recent changes enhance error handling and flow management across the catalog and SQL modules. New error variants provide detailed reporting for various scenarios, while the SQL parser and query functionalities now support SHOW FLOWS
statements. This integration streamlines flow oversight and improves overall error diagnostics, making the system more robust and user-friendly.
Files | Change Summary |
---|---|
src/catalog/src/error.rs |
Added new error variants (ListFlows , FlowInfoNotFound , Json ) with specific fields and updated StatusCode mappings. |
src/catalog/src/system_schema/information_schema/flows.rs |
Introduced flow metadata management, defining structures and methods for information_schema.flows and implementing record batch processing. |
src/query/src/sql.rs |
Enhanced SQL module with flow management capabilities, including the show_flows function and integration of flow-related data. |
src/sql/src/parsers/show_parser.rs |
Implemented parsing for SHOW FLOWS statements, along with test cases to validate the new parsing logic. |
In the heart of our code, new flows arise,
With errors detailed, no more disguise.
Show the paths that data flows take,
SQL and schema, a perfect handshake.
Here's to progress, in every byte,
Better queries, our system's light. 🌟
Thank you for using CodeRabbit. We offer it for free to the OSS community and would appreciate your support in helping us grow. If you find it useful, would you consider giving us a shout-out on your favorite social media?
Attention: Patch coverage is 40.83770%
with 226 lines
in your changes missing coverage. Please review.
Project coverage is 84.78%. Comparing base (
8ab6136
) to head (fd48160
). Report is 3 commits behind head on main.
Don't forget to update the documents @discord9
I hereby agree to the terms of the GreptimeDB CLA.
Refer to a related PR or issue link (optional)
What's changed and what's your intention?
add a
FLOWS
table showing all active flow jobs, it contains all field inFlowInfoValue
andFlowId
as columns, for complex type inFlowInfoValue
, it just got serde to json string, it looks like this:and
SHOW FLOWS
:sqlness test are also added
Checklist
Summary by CodeRabbit
New Features
SHOW FLOWS
queries, enabling users to list and manage flows.information_schema
to include additional fields for enhanced flow management.Bug Fixes
Tests
SHOW FLOWS
statements to ensure accurate parsing and functionality.