jyapayne/langflow
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

chore: suppress linter warning and rename variable in DataFrame operations (#8728)

Browse source 
* update ruff errors

* [autofix.ci] apply automated fixes

* Update events.py

---------

Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>
This commit is contained in:
Edwin Jose 2025-06-25 10:18:00 -05:00 • committed by GitHub
commit 0d74474e12
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 11 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/backend/base/langflow/base/agents/events.py
View file

@ -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

22
src/backend/base/langflow/components/processing/dataframe_operations.py
View file

@ -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)