feat: Add DataFrame and Data type passthrough support for RunFlow#7
Open
mihirathale98 wants to merge 14 commits intomainfrom
Open
feat: Add DataFrame and Data type passthrough support for RunFlow#7mihirathale98 wants to merge 14 commits intomainfrom
mihirathale98 wants to merge 14 commits intomainfrom
Conversation
Adds OAuth authentication capability for HTTP-based MCP servers: - Added enable_oauth toggle and oauth_url input fields - Implemented _get_oauth_token method using MCPOAuthClient - Inject Authorization header for HTTP-based servers when OAuth is enabled - Handle 401 errors by clearing OAuth token for re-authentication - Improved error handling for ExceptionGroup/TaskGroup errors
- Changed from process_tweaks_on_graph to process_tweaks for proper tweak application - Added _normalize_input_value method to handle Message/Data objects from wired components - Updated update_input_types to ensure Message type is accepted for ChatInput/TextInput connections - Rewrote _run_flow_with_cached_graph to apply tweaks to flow data before Graph creation - Added _infer_input_type to detect input type from vertex ID - Added _get_parent_input_value_by_type for auto-forwarding parent inputs to sub-flows - Enhanced _build_inputs_from_tweaks with input type inference and parent value forwarding
- Added ChatGoogleGenAI wrapper in base/models that bridges google-genai SDK with LangChain - Updated Vertex AI component to use new SDK wrapper instead of langchain-google-vertexai - Added thinking_level dropdown for Gemini 3 reasoning depth configuration - Implements feature parity with ChatVertexAI: tool calling, structured output, multimodal, streaming - Updated default model to gemini-3-flash-preview - Changed default location to "global" for Gemini 3 compatibility
…t-patch feat: Add OAuth support for MCP HTTP-based servers
fix: Improve RunFlow component tweak handling and input normalization
…nent-patch feat: Add Gemini 3 support via google-genai SDK for Vertex AI
- Add Transpose: flip rows and columns - Add Reset Index: reset to default integer index - Add Set Index: set a column as the DataFrame index - Add Fill NA: fill missing values with specified value - Add Drop NA: remove rows with missing values - Add Sample: random sampling of rows with optional seed - Add Slice: get rows by index range - Add Unique Values: get unique values from a column Uses safe DataFrame conversion pattern to avoid NaN issues with Langflow's custom DataFrame class.
…tions-enhancement feat: Add 8 new DataFrame operations for enhanced data manipulation
…e-id-passing feat: add trace id to langlfow cli
- Remove input_types=[] from ChatInput to allow incoming Message connections - Add update_input_types() call in update_build_config_from_graph so RunFlow dynamic inputs accept Message type - Preserve lists in _normalize_input_value to prevent files=[] from being converted to string '[]' which caused ChatOutputResponse validation errors Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
fix: Enable ChatInput wiring to RunFlow and fix list serialization
- Add _get_data_entry_vertices() to detect components with unconnected DataFrame/Data inputs - Add _get_data_fields_from_vertex() to extract field configs with 'other' type mapped to Any - Update should_skip_field() to not skip 'other' type fields when they have a value - Add handler in process_field_parameters() for 'other' type fields from tweaks This enables DataFrame and Data objects to be passed through RunFlow tweaks to subflow components without requiring string conversion.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
1 participant
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Summary
Changes
run_flow.py: Add_get_data_entry_vertices()and_get_data_fields_from_vertex()methodsparam_handler.py: Updateshould_skip_field()andprocess_field_parameters()to handle 'other' type fieldsTest plan