diff --git a/src/backend/base/langflow/base/agents/events.py b/src/backend/base/langflow/base/agents/events.py index 62c130503..3d9cb4359 100644 --- a/src/backend/base/langflow/base/agents/events.py +++ b/src/backend/base/langflow/base/agents/events.py @@ -220,10 +220,6 @@ async def handle_on_tool_end( # Update the map reference tool_blocks_map[tool_key] = updated_tool_content - for content in agent_message.content_blocks[0].contents: - if isinstance(content, ToolContent): - header_title = content.header.get("title", "N/A") if content.header else "None" - return agent_message, new_start_time return agent_message, start_time diff --git a/src/backend/base/langflow/components/processing/dataframe_operations.py b/src/backend/base/langflow/components/processing/dataframe_operations.py index d07034ea8..3d24f751d 100644 --- a/src/backend/base/langflow/components/processing/dataframe_operations.py +++ b/src/backend/base/langflow/components/processing/dataframe_operations.py @@ -165,29 +165,29 @@ class DataFrameOperationsComponent(Component): return build_config def perform_operation(self) -> DataFrame: - df = self.df.copy() + df_copy = self.df.copy() op = self.operation if op == "Filter": - return self.filter_rows_by_value(df) + return self.filter_rows_by_value(df_copy) if op == "Sort": - return self.sort_by_column(df) + return self.sort_by_column(df_copy) if op == "Drop Column": - return self.drop_column(df) + return self.drop_column(df_copy) if op == "Rename Column": - return self.rename_column(df) + return self.rename_column(df_copy) if op == "Add Column": - return self.add_column(df) + return self.add_column(df_copy) if op == "Select Columns": - return self.select_columns(df) + return self.select_columns(df_copy) if op == "Head": - return self.head(df) + return self.head(df_copy) if op == "Tail": - return self.tail(df) + return self.tail(df_copy) if op == "Replace Value": - return self.replace_values(df) + return self.replace_values(df_copy) if op == "Drop Duplicates": - return self.drop_duplicates(df) + return self.drop_duplicates(df_copy) msg = f"Unsupported operation: {op}" logger.error(msg) raise ValueError(msg)