Add these nodes with the pipeline builder: pipeline.add(name="...").<node>(...). Each entry lists the node’s configuration parameters. See the Pipeline reference for add, run, and lifecycle methods.
ai_fill_pdf — AI Fill PDF
Fill out a PDF with form fields using AI. The AI will understand and fill each field using provided context. To convert your PDF to have fillable input fields, use: https://www.sejda.com/pdf-forms
pipeline.add( name = "node" ).ai_fill_pdf( provider = "anthropic" , context = "..." , file = ... )
Parameters
Whether to select specific pages to fill
The model provider anthropic, azure, bedrock, cohere, custom, fireworks, google, groq, openai, perplexity, together, xai
The specific model for filling the PDF MiniMaxAI/MiniMax-M2.5, MiniMaxAI/MiniMax-M2.7, Qwen/QwQ-32B-Preview, Qwen/Qwen2.5-72B-Instruct-Turbo-lora, Qwen/Qwen2.5-7B-Instruct-Turbo, Qwen/Qwen3-235B-A22B-Instruct-2507-tput, Qwen/Qwen3-235B-A22B-fp8-tput, Qwen/Qwen3-Coder-480B-A35B-Instruct-FP8, Qwen/Qwen3-VL-8B-Instruct, Qwen/Qwen3.5-397B-A17B, Qwen/Qwen3.5-9B, Qwen/Qwen3.6-Plus, accounts/fireworks/models/deepseek-v4-pro, accounts/fireworks/models/glm-5p1, accounts/fireworks/models/gpt-oss-120b, accounts/fireworks/models/kimi-k2p5, accounts/fireworks/models/kimi-k2p6, accounts/fireworks/models/minimax-m2p7, accounts/fireworks/models/qwen3-235b-a22b, accounts/fireworks/models/qwen3p5-397b-a17b, accounts/fireworks/models/qwen3p6-plus, amazon.nova-lite-v1:0, amazon.nova-micro-v1:0, amazon.nova-pro-v1:0, amazon.titan-text-express-v1, amazon.titan-text-lite-v1, chatgpt-4o-latest, claude-3-5-haiku-20241022, claude-3-7-sonnet-20250219, claude-3-haiku-20240307, claude-haiku-4-5-20251001, claude-opus-4-1-20250805, claude-opus-4-20250514, claude-opus-4-5-20251101, claude-opus-4-6, claude-opus-4-7, claude-opus-4-8, claude-sonnet-4-20250514, claude-sonnet-4-5, claude-sonnet-4-6, command-nightly, command-r-08-2024, command-r-plus-08-2024, deepcogito/cogito-v2-1-671b, deepseek-ai/DeepSeek-R1-Distill-Llama-70B, deepseek-ai/DeepSeek-V3, deepseek-ai/DeepSeek-V4-Pro, deepseek-ai/deepseek-llm-67b-chat, gemini-2.0-flash-001, gemini-2.0-flash-lite-preview-02-05, gemini-2.5-flash, gemini-2.5-pro, gemini-3-flash-preview, gemini-3-pro-preview, gemini-3.1-flash-lite-preview, gemini-3.1-pro-preview, gemini-3.5-flash, gemma2-9b-it, google/gemma-2-27b-it, google/gemma-2-9b-it, google/gemma-2b-it, google/gemma-3n-E4B-it, google/gemma-4-31B-it, gpt-3.5-turbo, gpt-4, gpt-4-turbo, gpt-4-turbo-2024-04-09, gpt-4.1, gpt-4.1-mini, gpt-4.1-nano, gpt-4o, gpt-4o-2024-08-06, gpt-4o-mini, gpt-5, gpt-5-mini, gpt-5-nano, gpt-5.1, gpt-5.1-codex, gpt-5.1-codex-mini, gpt-5.2, gpt-5.3-codex, gpt-5.4, gpt-5.4-mini, gpt-5.4-nano, gpt-5.5, grok-2, grok-2-vision, grok-3-beta, grok-3-fast-beta, grok-3-mini-beta, grok-3-mini-fast-beta, grok-4, grok-4-0629, grok-4-0709, grok-4-fast-non-reasoning, grok-4-fast-reasoning, grok-4-latest, llama-3.1-8b-instant, llama-3.3-70b-versatile, meta-llama/Llama-3-70b-chat-hf, meta-llama/Llama-3-8b-chat-hf, meta-llama/Llama-3.2-11B-Vision-Instruct-Turbo, meta-llama/Llama-3.2-3B-Instruct-Turbo, meta-llama/Llama-3.2-90B-Vision-Instruct-Turbo, meta-llama/Llama-3.3-70B-Instruct-Turbo, meta-llama/Llama-4-Maverick-17B-128E-Instruct-FP8, meta-llama/Llama-4-Scout-17B-16E-Instruct, meta-llama/Meta-Llama-3-70B-Instruct-Lite, meta-llama/Meta-Llama-3-70B-Instruct-Turbo, meta-llama/Meta-Llama-3-8B-Instruct-Lite, meta-llama/Meta-Llama-3-8B-Instruct-Turbo, meta-llama/Meta-Llama-3.1-405B-Instruct-Turbo, meta-llama/Meta-Llama-3.1-70B-Instruct-Turbo, meta-llama/Meta-Llama-3.1-8B-Instruct-Turbo, meta.llama3-8b-instruct-v1:0, mistralai/Mistral-7B-Instruct-v0.1, mistralai/Mistral-7B-Instruct-v0.2, mistralai/Mistral-7B-Instruct-v0.3, mistralai/Mixtral-8x22B-Instruct-v0.1, mistralai/Mixtral-8x7B-Instruct-v0.1, mixtral-8x7b-32768, moonshotai/Kimi-K2-Instruct, moonshotai/Kimi-K2.5, moonshotai/Kimi-K2.6, o1, o3, o3-mini, o4-mini, openai/gpt-oss-120b, openai/gpt-oss-20b, perplexity-ai/r1-1776, r1-1776, sonar, sonar-deep-research, sonar-pro, sonar-reasoning-pro, us.anthropic.claude-haiku-4-5-20251001-v1:0, us.anthropic.claude-opus-4-1-20250805-v1:0, us.anthropic.claude-opus-4-5-20251101-v1:0, us.anthropic.claude-opus-4-6-v1, us.anthropic.claude-sonnet-4-20250514-v1:0, us.anthropic.claude-sonnet-4-5-20250929-v1:0, us.anthropic.claude-sonnet-4-6, us.meta.llama3-1-70b-instruct-v1:0, us.meta.llama3-1-8b-instruct-v1:0, us.meta.llama3-2-11b-instruct-v1:0, us.meta.llama3-2-1b-instruct-v1:0, us.meta.llama3-2-3b-instruct-v1:0, us.meta.llama3-2-90b-instruct-v1:0, zai-org/GLM-4.5-Air-FP8, zai-org/GLM-5, zai-org/GLM-5.1
Context used by LLM to fill PDF fields
The PDF with form fields to be filled
ai_filter_list — AI Filter List
Filter items in a list given a specific AI condition. Example, Filter (Red, White, Boat) by whether it is a color: (Red, White)
pipeline.add( name = "node" ).ai_filter_list( provider = "anthropic" , ai_condition = "..." , filter_by = ... , list_to_filter = ... )
Parameters
Choose whether to filter a single list or filter by another list
One of: another, single
The model provider anthropic, azure, bedrock, cohere, custom, fireworks, google, groq, openai, perplexity, together, xai
The specific model for filtering MiniMaxAI/MiniMax-M2.5, MiniMaxAI/MiniMax-M2.7, Qwen/QwQ-32B-Preview, Qwen/Qwen2.5-72B-Instruct-Turbo-lora, Qwen/Qwen2.5-7B-Instruct-Turbo, Qwen/Qwen3-235B-A22B-Instruct-2507-tput, Qwen/Qwen3-235B-A22B-fp8-tput, Qwen/Qwen3-Coder-480B-A35B-Instruct-FP8, Qwen/Qwen3-VL-8B-Instruct, Qwen/Qwen3.5-397B-A17B, Qwen/Qwen3.5-9B, Qwen/Qwen3.6-Plus, accounts/fireworks/models/deepseek-v4-pro, accounts/fireworks/models/glm-5p1, accounts/fireworks/models/gpt-oss-120b, accounts/fireworks/models/kimi-k2p5, accounts/fireworks/models/kimi-k2p6, accounts/fireworks/models/minimax-m2p7, accounts/fireworks/models/qwen3-235b-a22b, accounts/fireworks/models/qwen3p5-397b-a17b, accounts/fireworks/models/qwen3p6-plus, amazon.nova-lite-v1:0, amazon.nova-micro-v1:0, amazon.nova-pro-v1:0, amazon.titan-text-express-v1, amazon.titan-text-lite-v1, chatgpt-4o-latest, claude-3-5-haiku-20241022, claude-3-7-sonnet-20250219, claude-3-haiku-20240307, claude-haiku-4-5-20251001, claude-opus-4-1-20250805, claude-opus-4-20250514, claude-opus-4-5-20251101, claude-opus-4-6, claude-opus-4-7, claude-opus-4-8, claude-sonnet-4-20250514, claude-sonnet-4-5, claude-sonnet-4-6, command-nightly, command-r-08-2024, command-r-plus-08-2024, deepcogito/cogito-v2-1-671b, deepseek-ai/DeepSeek-R1-Distill-Llama-70B, deepseek-ai/DeepSeek-V3, deepseek-ai/DeepSeek-V4-Pro, deepseek-ai/deepseek-llm-67b-chat, gemini-2.0-flash-001, gemini-2.0-flash-lite-preview-02-05, gemini-2.5-flash, gemini-2.5-pro, gemini-3-flash-preview, gemini-3-pro-preview, gemini-3.1-flash-lite-preview, gemini-3.1-pro-preview, gemini-3.5-flash, gemma2-9b-it, google/gemma-2-27b-it, google/gemma-2-9b-it, google/gemma-2b-it, google/gemma-3n-E4B-it, google/gemma-4-31B-it, gpt-3.5-turbo, gpt-4, gpt-4-turbo, gpt-4-turbo-2024-04-09, gpt-4.1, gpt-4.1-mini, gpt-4.1-nano, gpt-4o, gpt-4o-2024-08-06, gpt-4o-mini, gpt-5, gpt-5-mini, gpt-5-nano, gpt-5.1, gpt-5.1-codex, gpt-5.1-codex-mini, gpt-5.2, gpt-5.3-codex, gpt-5.4, gpt-5.4-mini, gpt-5.4-nano, gpt-5.5, grok-2, grok-2-vision, grok-3-beta, grok-3-fast-beta, grok-3-mini-beta, grok-3-mini-fast-beta, grok-4, grok-4-0629, grok-4-0709, grok-4-fast-non-reasoning, grok-4-fast-reasoning, grok-4-latest, llama-3.1-8b-instant, llama-3.3-70b-versatile, meta-llama/Llama-3-70b-chat-hf, meta-llama/Llama-3-8b-chat-hf, meta-llama/Llama-3.2-11B-Vision-Instruct-Turbo, meta-llama/Llama-3.2-3B-Instruct-Turbo, meta-llama/Llama-3.2-90B-Vision-Instruct-Turbo, meta-llama/Llama-3.3-70B-Instruct-Turbo, meta-llama/Llama-4-Maverick-17B-128E-Instruct-FP8, meta-llama/Llama-4-Scout-17B-16E-Instruct, meta-llama/Meta-Llama-3-70B-Instruct-Lite, meta-llama/Meta-Llama-3-70B-Instruct-Turbo, meta-llama/Meta-Llama-3-8B-Instruct-Lite, meta-llama/Meta-Llama-3-8B-Instruct-Turbo, meta-llama/Meta-Llama-3.1-405B-Instruct-Turbo, meta-llama/Meta-Llama-3.1-70B-Instruct-Turbo, meta-llama/Meta-Llama-3.1-8B-Instruct-Turbo, meta.llama3-8b-instruct-v1:0, mistralai/Mistral-7B-Instruct-v0.1, mistralai/Mistral-7B-Instruct-v0.2, mistralai/Mistral-7B-Instruct-v0.3, mistralai/Mixtral-8x22B-Instruct-v0.1, mistralai/Mixtral-8x7B-Instruct-v0.1, mixtral-8x7b-32768, moonshotai/Kimi-K2-Instruct, moonshotai/Kimi-K2.5, moonshotai/Kimi-K2.6, o1, o3, o3-mini, o4-mini, openai/gpt-oss-120b, openai/gpt-oss-20b, perplexity-ai/r1-1776, r1-1776, sonar, sonar-deep-research, sonar-pro, sonar-reasoning-pro, us.anthropic.claude-haiku-4-5-20251001-v1:0, us.anthropic.claude-opus-4-1-20250805-v1:0, us.anthropic.claude-opus-4-5-20251101-v1:0, us.anthropic.claude-opus-4-6-v1, us.anthropic.claude-sonnet-4-20250514-v1:0, us.anthropic.claude-sonnet-4-5-20250929-v1:0, us.anthropic.claude-sonnet-4-6, us.meta.llama3-1-70b-instruct-v1:0, us.meta.llama3-1-8b-instruct-v1:0, us.meta.llama3-2-11b-instruct-v1:0, us.meta.llama3-2-1b-instruct-v1:0, us.meta.llama3-2-3b-instruct-v1:0, us.meta.llama3-2-90b-instruct-v1:0, zai-org/GLM-4.5-Air-FP8, zai-org/GLM-5, zai-org/GLM-5.1
Write in natural language the condition to filter each item in the list
The items to filter the list by
If true, output a blank value for values that do not meet the filter condition. If false, nothing will be outputted
ai_operations — Leverage AI for various tasks
Leverage AI for various tasks
pipeline.add( name = "node" ).ai_operations()
Parameters
append_files — Append Files
Append files together in successive fashion
pipeline.add( name = "node" ).append_files()
Parameters
selected_files
AcceptsFileList
default: "[]"
categorizer — Categorizer
Categorize text using AI into custom-defined buckets
pipeline.add( name = "node" ).categorizer( provider = "anthropic" , text = "..." )
Parameters
Include the AI’s justification for its score
The model provider anthropic, aws, azure, bedrock, cohere, custom, fireworks, google, groq, openai, perplexity, together, xai
The specific model for categorization MiniMaxAI/MiniMax-M2.5, MiniMaxAI/MiniMax-M2.7, Qwen/QwQ-32B-Preview, Qwen/Qwen2.5-72B-Instruct-Turbo-lora, Qwen/Qwen2.5-7B-Instruct-Turbo, Qwen/Qwen3-235B-A22B-Instruct-2507-tput, Qwen/Qwen3-235B-A22B-fp8-tput, Qwen/Qwen3-Coder-480B-A35B-Instruct-FP8, Qwen/Qwen3-VL-8B-Instruct, Qwen/Qwen3.5-397B-A17B, Qwen/Qwen3.5-9B, Qwen/Qwen3.6-Plus, accounts/fireworks/models/deepseek-v4-pro, accounts/fireworks/models/glm-5p1, accounts/fireworks/models/gpt-oss-120b, accounts/fireworks/models/kimi-k2p5, accounts/fireworks/models/kimi-k2p6, accounts/fireworks/models/minimax-m2p7, accounts/fireworks/models/qwen3-235b-a22b, accounts/fireworks/models/qwen3p5-397b-a17b, accounts/fireworks/models/qwen3p6-plus, amazon.nova-lite-v1:0, amazon.nova-micro-v1:0, amazon.nova-pro-v1:0, amazon.titan-text-express-v1, amazon.titan-text-lite-v1, chatgpt-4o-latest, claude-3-5-haiku-20241022, claude-3-7-sonnet-20250219, claude-3-haiku-20240307, claude-haiku-4-5-20251001, claude-opus-4-1-20250805, claude-opus-4-20250514, claude-opus-4-5-20251101, claude-opus-4-6, claude-opus-4-7, claude-opus-4-8, claude-sonnet-4-20250514, claude-sonnet-4-5, claude-sonnet-4-6, command-nightly, command-r-08-2024, command-r-plus-08-2024, deepcogito/cogito-v2-1-671b, deepseek-ai/DeepSeek-R1-Distill-Llama-70B, deepseek-ai/DeepSeek-V3, deepseek-ai/DeepSeek-V4-Pro, deepseek-ai/deepseek-llm-67b-chat, gemini-2.0-flash-001, gemini-2.0-flash-lite-preview-02-05, gemini-2.5-flash, gemini-2.5-pro, gemini-3-flash-preview, gemini-3-pro-preview, gemini-3.1-flash-lite-preview, gemini-3.1-pro-preview, gemini-3.5-flash, gemma2-9b-it, google/gemma-2-27b-it, google/gemma-2-9b-it, google/gemma-2b-it, google/gemma-3n-E4B-it, google/gemma-4-31B-it, gpt-3.5-turbo, gpt-4, gpt-4-turbo, gpt-4-turbo-2024-04-09, gpt-4.1, gpt-4.1-mini, gpt-4.1-nano, gpt-4o, gpt-4o-2024-08-06, gpt-4o-mini, gpt-5, gpt-5-mini, gpt-5-nano, gpt-5.1, gpt-5.1-codex, gpt-5.1-codex-mini, gpt-5.2, gpt-5.3-codex, gpt-5.4, gpt-5.4-mini, gpt-5.4-nano, gpt-5.5, grok-2, grok-2-vision, grok-3-beta, grok-3-fast-beta, grok-3-mini-beta, grok-3-mini-fast-beta, grok-4, grok-4-0629, grok-4-0709, grok-4-fast-non-reasoning, grok-4-fast-reasoning, grok-4-latest, llama-3.1-8b-instant, llama-3.3-70b-versatile, meta-llama/Llama-3-70b-chat-hf, meta-llama/Llama-3-8b-chat-hf, meta-llama/Llama-3.2-11B-Vision-Instruct-Turbo, meta-llama/Llama-3.2-3B-Instruct-Turbo, meta-llama/Llama-3.2-90B-Vision-Instruct-Turbo, meta-llama/Llama-3.3-70B-Instruct-Turbo, meta-llama/Llama-4-Maverick-17B-128E-Instruct-FP8, meta-llama/Llama-4-Scout-17B-16E-Instruct, meta-llama/Meta-Llama-3-70B-Instruct-Lite, meta-llama/Meta-Llama-3-70B-Instruct-Turbo, meta-llama/Meta-Llama-3-8B-Instruct-Lite, meta-llama/Meta-Llama-3-8B-Instruct-Turbo, meta-llama/Meta-Llama-3.1-405B-Instruct-Turbo, meta-llama/Meta-Llama-3.1-70B-Instruct-Turbo, meta-llama/Meta-Llama-3.1-8B-Instruct-Turbo, meta.llama3-8b-instruct-v1:0, mistralai/Mistral-7B-Instruct-v0.1, mistralai/Mistral-7B-Instruct-v0.2, mistralai/Mistral-7B-Instruct-v0.3, mistralai/Mixtral-8x22B-Instruct-v0.1, mistralai/Mixtral-8x7B-Instruct-v0.1, mixtral-8x7b-32768, moonshotai/Kimi-K2-Instruct, moonshotai/Kimi-K2.5, moonshotai/Kimi-K2.6, o1, o3, o3-mini, o4-mini, openai/gpt-oss-120b, openai/gpt-oss-20b, perplexity-ai/r1-1776, r1-1776, sonar, sonar-deep-research, sonar-pro, sonar-reasoning-pro, us.anthropic.claude-haiku-4-5-20251001-v1:0, us.anthropic.claude-opus-4-1-20250805-v1:0, us.anthropic.claude-opus-4-5-20251101-v1:0, us.anthropic.claude-opus-4-6-v1, us.anthropic.claude-sonnet-4-20250514-v1:0, us.anthropic.claude-sonnet-4-5-20250929-v1:0, us.anthropic.claude-sonnet-4-6, us.meta.llama3-1-70b-instruct-v1:0, us.meta.llama3-1-8b-instruct-v1:0, us.meta.llama3-2-11b-instruct-v1:0, us.meta.llama3-2-1b-instruct-v1:0, us.meta.llama3-2-3b-instruct-v1:0, us.meta.llama3-2-90b-instruct-v1:0, zai-org/GLM-4.5-Air-FP8, zai-org/GLM-5, zai-org/GLM-5.1
The text that will be categorized
Provide any additional context or instructions
fields
ListType | list[List[Dict[str, Any]]] | list[NameDescription]
default: "[]"
The fields to be categorized
The maximum number of tokens to generate
The temperature of the model
combine_list — Combine List
Combine multiple lists into one list. Final list is ordered in the order of the input lists.
pipeline.add( name = "node" ).combine_list( list = ... )
Parameters
The type of the list agent, any, audio, bool, dataframe, file, float, image, int32, json, knowledge_base, path, string, timestamp, vec<file>, vec<string>
list
ListType | list[List[Any]] | list[List[List[Any]]]
required
List to be combined
combine_text — Combine Text
Combine text inputs into a singular output.
pipeline.add( name = "node" ).combine_text( text = ... )
Parameters
create_list — Create List
Create a list from input texts. Final list is ordered in the order of the inputs.
pipeline.add( name = "node" ).create_list( list = ... )
Parameters
The type of the list agent, any, audio, bool, dataframe, file, float, image, int32, json, knowledge_base, path, string, timestamp, vec<file>, vec<string>
list
ListType | list[Any] | list[List[Any]]
required
Value to be added to the list
csv_reader — CSV Reader
Read the contents from a CSV file and output a list of the data for each column.
pipeline.add( name = "node" ).csv_reader( selected_file = ... , sheet = "..." )
Parameters
The type of file to read.
One of: CSV, EXCEL
The Excel sheet to read from.
manual_columns
ListType | list[ColumnItem] | list[List[Dict[str, Any]]]
default: "[]"
Define the name(s) of the columns that you want to read
columns
ListType | list[ColumnItem]
default: "[]"
Define the name(s) of the columns that you want to read
csv_to_excel — CSV To Excel
Convert a CSV file into XLSX.
pipeline.add( name = "node" ).csv_to_excel()
Parameters
One of: center, centerContinuous, distributed, fill, general, justify, left, right
One of: bottom, center, distributed, justify, top
csv_writer — CSV Writer
Create a CSV from data.
pipeline.add( name = "node" ).csv_writer()
Parameters
Whether to create a new CSV or update an existing one.
One of: new, old
Whether to load the CSV from a file or a string.
One of: file, text
columns
ListType | list[ListNameTypeValue] | list[List[Dict[str, Any]]]
default: "[]"
The columns to write to the CSV.
custom_smtp_email_sender — Custom Smtp Email Sender
Send emails using a custom SMTP server configuration
pipeline.add( name = "node" ).custom_smtp_email_sender( email_subject = "..." , recipient_email = "..." , sender_email = "..." , sender_password = "..." )
Parameters
One of: SSL, STARTTLS, TLS
dataframe_aggregate — Dataframe Aggregate
Aggregate data from a dataframe.
pipeline.add( name = "node" ).dataframe_aggregate( aggregation_column = "..." , aggregation_type = "AVG" , dataframe = ... , group_by_columns = ... )
Parameters
The type of dataframe to be used
One of: table
Select a numeric column (integer or decimal) to perform aggregation
The aggregation to perform
One of: AVG, COUNT, MAX, MIN, SUM
The dataframe to aggregate
dataframe_get_schema — Dataframe Get Schema
Get the schema of a dataframe including columns, types, and constraints.
pipeline.add( name = "node" ).dataframe_get_schema( dataframe = ... )
Parameters
The type of dataframe to be used
One of: table
The dataframe to get schema from
dataframe_nl_query — Dataframe NL Query
Execute natural language queries on dataframes.
pipeline.add( name = "node" ).dataframe_nl_query( dataframe = ... , nlquery = "..." )
Parameters
The type of dataframe to be used
One of: table
The dataframe to query using natural language
Ask a question about your data in natural language. Example: What are the top 10 rows?
dataframe_operations — Dataframe Operations
Dataframe Operations
pipeline.add( name = "node" ).dataframe_operations()
Parameters
dataframe_raw_query — Dataframe Raw Query
Execute custom queries on dataframes.
pipeline.add( name = "node" ).dataframe_raw_query( query = "..." , dataframe = ... , preload = True )
Parameters
The type of dataframe to be used
One of: table
SQL query to execute on the dataframe. Use {df} as the table name placeholder. Example: SELECT * FROM {df} limit 10;
Whether to preload dataframe instead of lazy load
dataframe_read_columns — Dataframe Read Columns
Read columns from a dataframe.
pipeline.add( name = "node" ).dataframe_read_columns( column_name = "..." , dataframe = ... )
Parameters
The expected type of the column values any, audio, bool, file, float, image, int32, knowledge_base, list<file>, list<string>, string, timestamp
The type of dataframe to be used
One of: table
The name of the column to read
duplicate_list — Duplicate List
Create a new list by duplicating a single item with the size of the new list either matching the size of another list, or a specified size.
pipeline.add( name = "node" ).duplicate_list( input_field = ... , list_size_to_match = ... , list_size = 0 )
Parameters
Check this box if you want to manually specify the list size. In this case ‘Match List Size’ will not be used.
The type of the list agent, any, audio, bool, dataframe, file, float, image, int32, json, knowledge_base, path, string, timestamp, vec<file>, vec<string>
input_field
Any | ListType | list[Any]
required
Item to duplicate
The size of the list you want to match
Send email notifications from no-reply@vectorshiftmail.com
pipeline.add( name = "node" ).email_notification( email_subject = "..." , recipient_email = "..." )
Parameters
email_validator — Validate an email address
Validate an email address
pipeline.add( name = "node" ).email_validator( api_key = "..." , email_to_validate = "..." )
Parameters
The validation model to use
One of: custom-validator, regex
The email you want to validate
The validation provider to use
One of: debounce, hunter
excel_cell_reader — Excel Cell Reader
Read data from an Excel cell.
pipeline.add( name = "node" ).excel_cell_reader( cell_index = "..." , selected_file = ... , sheet = "..." )
Parameters
excel_cell_writer — Excel Cell Writer
Write data to an Excel cell.
pipeline.add( name = "node" ).excel_cell_writer( cell_index = "..." , cell_value = "..." , selected_file = ... , sheet = "..." )
Parameters
Whether to set the vertical alignment of the cell.
Whether to set the horizontal alignment of the cell.
Whether to set the fill color of the cell.
The value to write to the cell.
The fill color of the cell.
The horizontal alignment of the cell.
One of: center, centerContinuous, distributed, fill, general, justify, left, right
The vertical alignment of the cell.
One of: bottom, center, distributed, justify, top
excel_file_reader — Excel File Reader
Read data from an Excel file.
pipeline.add( name = "node" ).excel_file_reader( selected_file = ... )
Parameters
Whether to read a single sheet from the Excel file.
Whether to read the formatting of the cell.
Whether to read the formula of the cell.
excel_operations — Process and manipulate Excel files
Process and manipulate Excel files
pipeline.add( name = "node" ).excel_operations()
Parameters
excel_sheets_reader — Excel Sheets Reader
Get list of all sheet names from an Excel file.
pipeline.add( name = "node" ).excel_sheets_reader( selected_file = ... )
Parameters
excel_writer — Excel Writer
Write data to an Excel sheet.
pipeline.add( name = "node" ).excel_writer( cell_start_index = "..." , cell_values = ... , selected_file = ... , sheet = "..." )
Parameters
Whether to set the vertical alignment of the cells.
Whether to set the horizontal alignment of the cells.
Whether to set the fill color of the cells.
The cell to start writing from.
The values to write to the cells.
The fill color of the cells.
The horizontal alignment of the cells.
One of: center, centerContinuous, distributed, fill, general, justify, left, right
The vertical alignment of the cells.
One of: bottom, center, distributed, justify, top
Extract key pieces of information or a list of information from a input text.
pipeline.add( name = "node" ).extract_data( text = "..." , fields = ... , processed_outputs = ... )
Parameters
fields
ListType | list[List[Dict[str, Any]]] | list[NameTypeDescription]
required
Extract data to a CSV using AI
pipeline.add( name = "node" ).extract_to_table( file = ... , text_for_extraction = "..." )
Parameters
One of: gpt-4o, gpt-4o-2024-08-06, gpt-4o-mini
manual_columns
ListType | list[ColumnEntry] | list[List[Dict[str, Any]]]
default: "[]"
file_operations — Process and manipulate files
Process and manipulate files
pipeline.add( name = "node" ).file_operations()
Parameters
file_to_text — File To Text
Convert data from type File to type Text
pipeline.add( name = "node" ).file_to_text( file = ... )
Parameters
Whether to chunk the text into smaller pieces.
Use a password to decrypt the file.
The file to convert to text.
The type of file parser to use.
One of: contextual_ai, default, docling, llama_parse, mistral_ocr, reducto, textract
The password to decrypt the file.
The overlap of each chunk of text.
The size of each chunk of text.
filter_list — Filter List
Filter items in a list given a specific condition. Example, Filter (Red, White, Blue) by (100, 95, 80)>90 is (Red, White)
pipeline.add( name = "node" ).filter_list( condition_type = "Equal" , filter_by = ... , list_to_filter = ... , output_blank_value = True )
Parameters
Choose whether to filter a single list or filter by another list
One of: another, single
The type of the list agent, any, audio, bool, dataframe, file, float, image, int32, json, knowledge_base, path, string, timestamp, vec<file>, vec<string>
The type of condition to apply Equal, GreaterThan, IsEmpty, IsFalse, IsNotEmpty, IsTrue, LessThan, TextContains, TextDoesNotContains, TextDoesNotEndWith, TextDoesNotStartWith, TextEndsWith, TextStartsWith, VecContainsItem, VecDoesNotContainsItem
The value to compare the list items against
filter_by
ListType | list[Any] | list[List[Any]]
required
The items to filter the list by
list_to_filter
ListType | list[Any] | list[List[Any]]
required
The list to filter
If true, output a blank value for values that do not meet the filter condition. If false, nothing will be outputted
find_and_replace — Find And Replace
Find and replace words in a given text
pipeline.add( name = "node" ).find_and_replace( text_to_manipulate = "..." )
Parameters
replacements
ListType | list[FindReplace] | list[List[Dict[str, Any]]]
default: "[]"
flatten_list — Flatten List
Flatten list of lists into a single list. For example, [[a, b], [c, d]] becomes [a,b,c,d].
pipeline.add( name = "node" ).flatten_list( list_of_lists = ... )
Parameters
The type of the list agent, any, audio, bool, dataframe, file, float, image, int32, json, knowledge_base, path, string, timestamp, vec<file>, vec<string>
list_of_lists
ListType | list[List[Any]] | list[List[List[Any]]]
required
List of lists to be flattened
generate_chart — Generate Chart
Use this to generate a chart from. Convert a tabular file, dataframe or table to a chart or graph visualization. Supports bar, line, pie, scatter, and donut charts/graphs.
pipeline.add( name = "node" ).generate_chart( dataframe = ... , dataframe_column_names = "..." , dataframe_type = "csv" , title = "..." )
Parameters
The type of chart to generate (bar, line, pie, scatter, donut)
One of: bar, donut, line, pie, scatter, time_series
How to aggregate values when there are multiple data points per category
One of: average, count, max, min, sum
A brief description or subtitle explaining what the chart shows
The dataframe to visualize as a chart. In case of csv, the input should be a properly formatted valid csv string with appropriate headers. When chaining from a tool that returned a CSV file (e.g. fetch_ratios.table), set dataframe_type=“file” and pass $action.<id>.table — never paste the upstream formatted_text/XML here.
Actual column names from the dataframe. It should be a string representing the comma separated list of column names.
The type of dataframe to be used. Only available options are table, csv, md, json, file.
One of: csv, file, json, md, table
Where to display the chart legend
One of: bottom, hidden, left, right, top
The order to sort the data
One of: ascending, descending
The title to display on the chart
The column name to use for the X-axis (categories). Must EXACTLY match (case-sensitive) one of the column names from the CSV header.
The label to display on the X-axis. Defaults to the field name if not provided.
Column name(s) for Y-axis values. Must EXACTLY match (case-sensitive) column name(s) from the CSV header. For multi-series charts (multiple lines/bars), use comma-separated names like ‘revenue,profit,cost’.
The label to display on the Y-axis
Currency symbol (only used with currency format)
One of: “, eur, gbp, jpy, usd
Initial time period tab selection
One of: 1m, 1y, 5y, 6m, max, ytd
How to format values
One of: currency, number, percent, ratio
Comma-separated icon URLs for each series (company logos, game art, product images, etc.), in same order as y_axis_fields. Leave empty for no icons.
Comma-separated display names for each Y-axis field, in same order as y_axis_fields (e.g. ‘MSFT,NVDA’ for tickers, ‘Halo,Fortnite’ for games, ‘US,EU,APAC’ for regions).
Set to ‘true’ to show Original/% Change toggle
Scale suffix for values
One of: “, b, k, m, t
get_list_item — Get List Item
Get a value from a list given an index. The first item in the list is index 0.
pipeline.add( name = "node" ).get_list_item( index = 0 , list = ... )
Parameters
The type of the list agent, any, audio, bool, dataframe, file, float, image, int32, json, knowledge_base, path, string, timestamp, vec<file>, vec<string>
The index of the item to retrieve
list
ListType | list[Any] | list[List[Any]]
required
The list to retrieve the item from
join_list_item — Join List Item
Join a list of items into a single piece of text. For example, with / as the separator, [‘a’, ‘b’, ‘c’] becomes ‘a/b/c’
pipeline.add( name = "node" ).join_list_item( list = ... )
Parameters
Separate each line in the final output with a new line
The type of the list agent, any, audio, bool, dataframe, file, float, image, int32, json, knowledge_base, path, string, timestamp, vec<file>, vec<string>
Use a specified character to join list items into a single string
list
ListType | list[Any] | list[List[Any]]
required
List of items to be joined
json_operations — JSON Operations
Read, create, and update JSON data
pipeline.add( name = "node" ).json_operations()
Parameters
list_deduplicator — List Deduplicator
Remove duplicate items from a list. Outputs a list of unique items.
pipeline.add( name = "node" ).list_deduplicator( list = ... )
Parameters
The type of the list
One of: bool, float, int32, string, timestamp
list
ListType | list[Any] | list[List[Any]]
required
The list to deduplicate
list_operations — Process and manipulate lists
Process and manipulate lists
pipeline.add( name = "node" ).list_operations()
Parameters
list_trimmer — List Trimmer
Trim a list to just the sections you want. Enter enter the number of items or specify the section of the list that you want to keep.
pipeline.add( name = "node" ).list_trimmer( end_index = 0 , list = ... , start_index = 0 , item_to_keep = 0 )
Parameters
Check this to specify a section of the list to keep. Leave unchecked to keep a specified number of items from the start.
The type of the list agent, any, audio, bool, dataframe, file, float, image, int32, json, knowledge_base, path, string, timestamp, vec<file>, vec<string>
The ending index of the section to keep (exclusive).
list
ListType | list[Any] | list[List[Any]]
required
The list to trim
The starting index of the section to keep (inclusive). The first item of the list is index 0.
Check this to specify a section of the list to keep. Leave unchecked to keep a specified number of items.
notifications — Notifications
Send alerts and notifications via different channels
pipeline.add( name = "node" ).notifications()
Parameters
read_json_values — Read JSON Values
Read values from a JSON object based on a provided key(s).
pipeline.add( name = "node" ).read_json_values( json_string = "..." , keys = ... , processed_outputs = ... )
Parameters
keys
ListType | list[KeyItem] | list[List[Dict[str, Any]]]
required
rename_file — Rename File
Rename an existing file, assigning a new name along with the file extension.
pipeline.add( name = "node" ).rename_file( file = ... , new_name = "..." )
Parameters
sales_data_enrichment — Sales Data Enrichment
Enhance sales data with validation and enrichment processes
pipeline.add( name = "node" ).sales_data_enrichment()
Parameters
scorer — Scorer
Assign a numerical score based on predefined criteria to quantitatively assess a given entity.
pipeline.add( name = "node" ).scorer( provider = "anthropic" , text = "..." , criteria = "..." )
Parameters
Include the AI’s justification for its score
The model provider anthropic, azure, bedrock, cohere, custom, fireworks, google, groq, openai, perplexity, together, xai
The specific model for scoring MiniMaxAI/MiniMax-M2.5, MiniMaxAI/MiniMax-M2.7, Qwen/QwQ-32B-Preview, Qwen/Qwen2.5-72B-Instruct-Turbo-lora, Qwen/Qwen2.5-7B-Instruct-Turbo, Qwen/Qwen3-235B-A22B-Instruct-2507-tput, Qwen/Qwen3-235B-A22B-fp8-tput, Qwen/Qwen3-Coder-480B-A35B-Instruct-FP8, Qwen/Qwen3-VL-8B-Instruct, Qwen/Qwen3.5-397B-A17B, Qwen/Qwen3.5-9B, Qwen/Qwen3.6-Plus, accounts/fireworks/models/deepseek-v4-pro, accounts/fireworks/models/glm-5p1, accounts/fireworks/models/gpt-oss-120b, accounts/fireworks/models/kimi-k2p5, accounts/fireworks/models/kimi-k2p6, accounts/fireworks/models/minimax-m2p7, accounts/fireworks/models/qwen3-235b-a22b, accounts/fireworks/models/qwen3p5-397b-a17b, accounts/fireworks/models/qwen3p6-plus, amazon.nova-lite-v1:0, amazon.nova-micro-v1:0, amazon.nova-pro-v1:0, amazon.titan-text-express-v1, amazon.titan-text-lite-v1, chatgpt-4o-latest, claude-3-5-haiku-20241022, claude-3-7-sonnet-20250219, claude-3-haiku-20240307, claude-haiku-4-5-20251001, claude-opus-4-1-20250805, claude-opus-4-20250514, claude-opus-4-5-20251101, claude-opus-4-6, claude-opus-4-7, claude-opus-4-8, claude-sonnet-4-20250514, claude-sonnet-4-5, claude-sonnet-4-6, command-nightly, command-r-08-2024, command-r-plus-08-2024, deepcogito/cogito-v2-1-671b, deepseek-ai/DeepSeek-R1-Distill-Llama-70B, deepseek-ai/DeepSeek-V3, deepseek-ai/DeepSeek-V4-Pro, deepseek-ai/deepseek-llm-67b-chat, gemini-2.0-flash-001, gemini-2.0-flash-lite-preview-02-05, gemini-2.5-flash, gemini-2.5-pro, gemini-3-flash-preview, gemini-3-pro-preview, gemini-3.1-flash-lite-preview, gemini-3.1-pro-preview, gemini-3.5-flash, gemma2-9b-it, google/gemma-2-27b-it, google/gemma-2-9b-it, google/gemma-2b-it, google/gemma-3n-E4B-it, google/gemma-4-31B-it, gpt-3.5-turbo, gpt-4, gpt-4-turbo, gpt-4-turbo-2024-04-09, gpt-4.1, gpt-4.1-mini, gpt-4.1-nano, gpt-4o, gpt-4o-2024-08-06, gpt-4o-mini, gpt-5, gpt-5-mini, gpt-5-nano, gpt-5.1, gpt-5.1-codex, gpt-5.1-codex-mini, gpt-5.2, gpt-5.3-codex, gpt-5.4, gpt-5.4-mini, gpt-5.4-nano, gpt-5.5, grok-2, grok-2-vision, grok-3-beta, grok-3-fast-beta, grok-3-mini-beta, grok-3-mini-fast-beta, grok-4, grok-4-0629, grok-4-0709, grok-4-fast-non-reasoning, grok-4-fast-reasoning, grok-4-latest, llama-3.1-8b-instant, llama-3.3-70b-versatile, meta-llama/Llama-3-70b-chat-hf, meta-llama/Llama-3-8b-chat-hf, meta-llama/Llama-3.2-11B-Vision-Instruct-Turbo, meta-llama/Llama-3.2-3B-Instruct-Turbo, meta-llama/Llama-3.2-90B-Vision-Instruct-Turbo, meta-llama/Llama-3.3-70B-Instruct-Turbo, meta-llama/Llama-4-Maverick-17B-128E-Instruct-FP8, meta-llama/Llama-4-Scout-17B-16E-Instruct, meta-llama/Meta-Llama-3-70B-Instruct-Lite, meta-llama/Meta-Llama-3-70B-Instruct-Turbo, meta-llama/Meta-Llama-3-8B-Instruct-Lite, meta-llama/Meta-Llama-3-8B-Instruct-Turbo, meta-llama/Meta-Llama-3.1-405B-Instruct-Turbo, meta-llama/Meta-Llama-3.1-70B-Instruct-Turbo, meta-llama/Meta-Llama-3.1-8B-Instruct-Turbo, meta.llama3-8b-instruct-v1:0, mistralai/Mistral-7B-Instruct-v0.1, mistralai/Mistral-7B-Instruct-v0.2, mistralai/Mistral-7B-Instruct-v0.3, mistralai/Mixtral-8x22B-Instruct-v0.1, mistralai/Mixtral-8x7B-Instruct-v0.1, mixtral-8x7b-32768, moonshotai/Kimi-K2-Instruct, moonshotai/Kimi-K2.5, moonshotai/Kimi-K2.6, o1, o3, o3-mini, o4-mini, openai/gpt-oss-120b, openai/gpt-oss-20b, perplexity-ai/r1-1776, r1-1776, sonar, sonar-deep-research, sonar-pro, sonar-reasoning-pro, us.anthropic.claude-haiku-4-5-20251001-v1:0, us.anthropic.claude-opus-4-1-20250805-v1:0, us.anthropic.claude-opus-4-5-20251101-v1:0, us.anthropic.claude-opus-4-6-v1, us.anthropic.claude-sonnet-4-20250514-v1:0, us.anthropic.claude-sonnet-4-5-20250929-v1:0, us.anthropic.claude-sonnet-4-6, us.meta.llama3-1-70b-instruct-v1:0, us.meta.llama3-1-8b-instruct-v1:0, us.meta.llama3-2-11b-instruct-v1:0, us.meta.llama3-2-1b-instruct-v1:0, us.meta.llama3-2-3b-instruct-v1:0, us.meta.llama3-2-90b-instruct-v1:0, zai-org/GLM-4.5-Air-FP8, zai-org/GLM-5, zai-org/GLM-5.1
The text that will be scored
Provide any additional context or instructions
The criteria that the text will be scored
sms_notification — Send text message notifications
Send text message notifications
pipeline.add( name = "node" ).sms_notification( message = "..." , phone_number = "..." )
Parameters
sort_csv — Sort CSV
Sort a CSV based on a column
pipeline.add( name = "node" ).sort_csv( file = ... )
Parameters
Whether the file is a variable.
Whether the CSV has headers.
The index of the column to sort by.
Whether to reverse the sort.
split_text — Split Text
Takes input text and separate it into a List of texts based on the delimiter.
pipeline.add( name = "node" ).split_text( text = "..." , character = "..." )
Parameters
The delimiter to split the text on
One of: character(s), newline, space
The character(s) to split the text on
summarizer — Summarizer
Summarize large texts using AI.
pipeline.add( name = "node" ).summarizer( provider = "anthropic" , text = "..." )
Parameters
The model provider anthropic, aws, azure, bedrock, cohere, custom, fireworks, google, groq, openai, perplexity, together, xai
The specific model for summarization MiniMaxAI/MiniMax-M2.5, MiniMaxAI/MiniMax-M2.7, Qwen/QwQ-32B-Preview, Qwen/Qwen2.5-72B-Instruct-Turbo-lora, Qwen/Qwen2.5-7B-Instruct-Turbo, Qwen/Qwen3-235B-A22B-Instruct-2507-tput, Qwen/Qwen3-235B-A22B-fp8-tput, Qwen/Qwen3-Coder-480B-A35B-Instruct-FP8, Qwen/Qwen3-VL-8B-Instruct, Qwen/Qwen3.5-397B-A17B, Qwen/Qwen3.5-9B, Qwen/Qwen3.6-Plus, accounts/fireworks/models/deepseek-v4-pro, accounts/fireworks/models/glm-5p1, accounts/fireworks/models/gpt-oss-120b, accounts/fireworks/models/kimi-k2p5, accounts/fireworks/models/kimi-k2p6, accounts/fireworks/models/minimax-m2p7, accounts/fireworks/models/qwen3-235b-a22b, accounts/fireworks/models/qwen3p5-397b-a17b, accounts/fireworks/models/qwen3p6-plus, amazon.nova-lite-v1:0, amazon.nova-micro-v1:0, amazon.nova-pro-v1:0, amazon.titan-text-express-v1, amazon.titan-text-lite-v1, chatgpt-4o-latest, claude-3-5-haiku-20241022, claude-3-7-sonnet-20250219, claude-3-haiku-20240307, claude-haiku-4-5-20251001, claude-opus-4-1-20250805, claude-opus-4-20250514, claude-opus-4-5-20251101, claude-opus-4-6, claude-opus-4-7, claude-opus-4-8, claude-sonnet-4-20250514, claude-sonnet-4-5, claude-sonnet-4-6, command-nightly, command-r-08-2024, command-r-plus-08-2024, deepcogito/cogito-v2-1-671b, deepseek-ai/DeepSeek-R1-Distill-Llama-70B, deepseek-ai/DeepSeek-V3, deepseek-ai/DeepSeek-V4-Pro, deepseek-ai/deepseek-llm-67b-chat, gemini-2.0-flash-001, gemini-2.0-flash-lite-preview-02-05, gemini-2.5-flash, gemini-2.5-pro, gemini-3-flash-preview, gemini-3-pro-preview, gemini-3.1-flash-lite-preview, gemini-3.1-pro-preview, gemini-3.5-flash, gemma2-9b-it, google/gemma-2-27b-it, google/gemma-2-9b-it, google/gemma-2b-it, google/gemma-3n-E4B-it, google/gemma-4-31B-it, gpt-3.5-turbo, gpt-4, gpt-4-turbo, gpt-4-turbo-2024-04-09, gpt-4.1, gpt-4.1-mini, gpt-4.1-nano, gpt-4o, gpt-4o-2024-08-06, gpt-4o-mini, gpt-5, gpt-5-mini, gpt-5-nano, gpt-5.1, gpt-5.1-codex, gpt-5.1-codex-mini, gpt-5.2, gpt-5.3-codex, gpt-5.4, gpt-5.4-mini, gpt-5.4-nano, gpt-5.5, grok-2, grok-2-vision, grok-3-beta, grok-3-fast-beta, grok-3-mini-beta, grok-3-mini-fast-beta, grok-4, grok-4-0629, grok-4-0709, grok-4-fast-non-reasoning, grok-4-fast-reasoning, grok-4-latest, llama-3.1-8b-instant, llama-3.3-70b-versatile, meta-llama/Llama-3-70b-chat-hf, meta-llama/Llama-3-8b-chat-hf, meta-llama/Llama-3.2-11B-Vision-Instruct-Turbo, meta-llama/Llama-3.2-3B-Instruct-Turbo, meta-llama/Llama-3.2-90B-Vision-Instruct-Turbo, meta-llama/Llama-3.3-70B-Instruct-Turbo, meta-llama/Llama-4-Maverick-17B-128E-Instruct-FP8, meta-llama/Llama-4-Scout-17B-16E-Instruct, meta-llama/Meta-Llama-3-70B-Instruct-Lite, meta-llama/Meta-Llama-3-70B-Instruct-Turbo, meta-llama/Meta-Llama-3-8B-Instruct-Lite, meta-llama/Meta-Llama-3-8B-Instruct-Turbo, meta-llama/Meta-Llama-3.1-405B-Instruct-Turbo, meta-llama/Meta-Llama-3.1-70B-Instruct-Turbo, meta-llama/Meta-Llama-3.1-8B-Instruct-Turbo, meta.llama3-8b-instruct-v1:0, mistralai/Mistral-7B-Instruct-v0.1, mistralai/Mistral-7B-Instruct-v0.2, mistralai/Mistral-7B-Instruct-v0.3, mistralai/Mixtral-8x22B-Instruct-v0.1, mistralai/Mixtral-8x7B-Instruct-v0.1, mixtral-8x7b-32768, moonshotai/Kimi-K2-Instruct, moonshotai/Kimi-K2.5, moonshotai/Kimi-K2.6, o1, o3, o3-mini, o4-mini, openai/gpt-oss-120b, openai/gpt-oss-20b, perplexity-ai/r1-1776, r1-1776, sonar, sonar-deep-research, sonar-pro, sonar-reasoning-pro, us.anthropic.claude-haiku-4-5-20251001-v1:0, us.anthropic.claude-opus-4-1-20250805-v1:0, us.anthropic.claude-opus-4-5-20251101-v1:0, us.anthropic.claude-opus-4-6-v1, us.anthropic.claude-sonnet-4-20250514-v1:0, us.anthropic.claude-sonnet-4-5-20250929-v1:0, us.anthropic.claude-sonnet-4-6, us.meta.llama3-1-70b-instruct-v1:0, us.meta.llama3-1-8b-instruct-v1:0, us.meta.llama3-2-11b-instruct-v1:0, us.meta.llama3-2-1b-instruct-v1:0, us.meta.llama3-2-3b-instruct-v1:0, us.meta.llama3-2-90b-instruct-v1:0, zai-org/GLM-4.5-Air-FP8, zai-org/GLM-5, zai-org/GLM-5.1
The text to be summarized
table — Table
Table
pipeline.add( name = "node" ).table()
Parameters
table_add_columns — Table Add Columns
Add one or more columns to a table.
pipeline.add( name = "node" ).table_add_columns( table = ... , columns = ... )
Parameters
table_add_row — Table Add Row
Add New Row to Table.
pipeline.add( name = "node" ).table_add_row( table = ... )
Parameters
table_aggregate — Table Aggregate
Aggregate data from a table.
pipeline.add( name = "node" ).table_aggregate( aggregation_column = "..." , aggregation_type = "AVG" , dataframe = ... , group_by_columns = ... )
Parameters
One of: AVG, COUNT, MAX, MIN, SUM
table_delete_columns — Table Delete Columns
Delete one or more columns from a table.
pipeline.add( name = "node" ).table_delete_columns( table = ... , columns = ... )
Parameters
table_delete_values — Table Delete Values
Delete rows matching a filter.
pipeline.add( name = "node" ).table_delete_values( table = ... , filters = "..." )
Parameters
table_read_columns — Table Read Columns
Select column in table to read as list.
pipeline.add( name = "node" ).table_read_columns( column_name = "..." , dataframe = ... )
Parameters
The expected type of the column values any, audio, bool, file, float, image, int32, knowledge_base, list<file>, list<string>, string, timestamp
The name of the column to read
table_rename_column — Table Rename Column
Rename a column in a table.
pipeline.add( name = "node" ).table_rename_column( table = ... , column = "..." , new_name = "..." )
Parameters
table_update_values — Table Update Values
Update the values in rows matching a filter.
pipeline.add( name = "node" ).table_update_values( table = ... , filters = "..." , values = ... )
Parameters
text_formatter — Text Formatter
Format text based off a specified formatter
pipeline.add( name = "node" ).text_formatter( text = "..." , max_num_token = 0 )
Parameters
formatter
str
default: "'To Uppercase'"
The formatter to apply to the text
One of: To Lowercase, To Propercase, To Uppercase, Trim Spaces, Truncate
The maximum number of tokens to truncate the text to
text_manipulation — Process and manipulate text
Process and manipulate text
pipeline.add( name = "node" ).text_manipulation()
Parameters
text_to_file — Text To File
Convert data from type Text to type File.
pipeline.add( name = "node" ).text_to_file( text = "..." , file_name = "..." )
Parameters
translator — Translator
Translate text from one language to another.
pipeline.add( name = "node" ).translator( provider = "anthropic" , text = "..." )
Parameters
The model provider anthropic, azure, bedrock, cohere, custom, fireworks, google, groq, openai, perplexity, together, xai
The specific model for translation MiniMaxAI/MiniMax-M2.5, MiniMaxAI/MiniMax-M2.7, Qwen/QwQ-32B-Preview, Qwen/Qwen2.5-72B-Instruct-Turbo-lora, Qwen/Qwen2.5-7B-Instruct-Turbo, Qwen/Qwen3-235B-A22B-Instruct-2507-tput, Qwen/Qwen3-235B-A22B-fp8-tput, Qwen/Qwen3-Coder-480B-A35B-Instruct-FP8, Qwen/Qwen3-VL-8B-Instruct, Qwen/Qwen3.5-397B-A17B, Qwen/Qwen3.5-9B, Qwen/Qwen3.6-Plus, accounts/fireworks/models/deepseek-v4-pro, accounts/fireworks/models/glm-5p1, accounts/fireworks/models/gpt-oss-120b, accounts/fireworks/models/kimi-k2p5, accounts/fireworks/models/kimi-k2p6, accounts/fireworks/models/minimax-m2p7, accounts/fireworks/models/qwen3-235b-a22b, accounts/fireworks/models/qwen3p5-397b-a17b, accounts/fireworks/models/qwen3p6-plus, amazon.nova-lite-v1:0, amazon.nova-micro-v1:0, amazon.nova-pro-v1:0, amazon.titan-text-express-v1, amazon.titan-text-lite-v1, chatgpt-4o-latest, claude-3-5-haiku-20241022, claude-3-7-sonnet-20250219, claude-3-haiku-20240307, claude-haiku-4-5-20251001, claude-opus-4-1-20250805, claude-opus-4-20250514, claude-opus-4-5-20251101, claude-opus-4-6, claude-opus-4-7, claude-opus-4-8, claude-sonnet-4-20250514, claude-sonnet-4-5, claude-sonnet-4-6, command-nightly, command-r-08-2024, command-r-plus-08-2024, deepcogito/cogito-v2-1-671b, deepseek-ai/DeepSeek-R1-Distill-Llama-70B, deepseek-ai/DeepSeek-V3, deepseek-ai/DeepSeek-V4-Pro, deepseek-ai/deepseek-llm-67b-chat, gemini-2.0-flash-001, gemini-2.0-flash-lite-preview-02-05, gemini-2.5-flash, gemini-2.5-pro, gemini-3-flash-preview, gemini-3-pro-preview, gemini-3.1-flash-lite-preview, gemini-3.1-pro-preview, gemini-3.5-flash, gemma2-9b-it, google/gemma-2-27b-it, google/gemma-2-9b-it, google/gemma-2b-it, google/gemma-3n-E4B-it, google/gemma-4-31B-it, gpt-3.5-turbo, gpt-4, gpt-4-turbo, gpt-4-turbo-2024-04-09, gpt-4.1, gpt-4.1-mini, gpt-4.1-nano, gpt-4o, gpt-4o-2024-08-06, gpt-4o-mini, gpt-5, gpt-5-mini, gpt-5-nano, gpt-5.1, gpt-5.1-codex, gpt-5.1-codex-mini, gpt-5.2, gpt-5.3-codex, gpt-5.4, gpt-5.4-mini, gpt-5.4-nano, gpt-5.5, grok-2, grok-2-vision, grok-3-beta, grok-3-fast-beta, grok-3-mini-beta, grok-3-mini-fast-beta, grok-4, grok-4-0629, grok-4-0709, grok-4-fast-non-reasoning, grok-4-fast-reasoning, grok-4-latest, llama-3.1-8b-instant, llama-3.3-70b-versatile, meta-llama/Llama-3-70b-chat-hf, meta-llama/Llama-3-8b-chat-hf, meta-llama/Llama-3.2-11B-Vision-Instruct-Turbo, meta-llama/Llama-3.2-3B-Instruct-Turbo, meta-llama/Llama-3.2-90B-Vision-Instruct-Turbo, meta-llama/Llama-3.3-70B-Instruct-Turbo, meta-llama/Llama-4-Maverick-17B-128E-Instruct-FP8, meta-llama/Llama-4-Scout-17B-16E-Instruct, meta-llama/Meta-Llama-3-70B-Instruct-Lite, meta-llama/Meta-Llama-3-70B-Instruct-Turbo, meta-llama/Meta-Llama-3-8B-Instruct-Lite, meta-llama/Meta-Llama-3-8B-Instruct-Turbo, meta-llama/Meta-Llama-3.1-405B-Instruct-Turbo, meta-llama/Meta-Llama-3.1-70B-Instruct-Turbo, meta-llama/Meta-Llama-3.1-8B-Instruct-Turbo, meta.llama3-8b-instruct-v1:0, mistralai/Mistral-7B-Instruct-v0.1, mistralai/Mistral-7B-Instruct-v0.2, mistralai/Mistral-7B-Instruct-v0.3, mistralai/Mixtral-8x22B-Instruct-v0.1, mistralai/Mixtral-8x7B-Instruct-v0.1, mixtral-8x7b-32768, moonshotai/Kimi-K2-Instruct, moonshotai/Kimi-K2.5, moonshotai/Kimi-K2.6, o1, o3, o3-mini, o4-mini, openai/gpt-oss-120b, openai/gpt-oss-20b, perplexity-ai/r1-1776, r1-1776, sonar, sonar-deep-research, sonar-pro, sonar-reasoning-pro, us.anthropic.claude-haiku-4-5-20251001-v1:0, us.anthropic.claude-opus-4-1-20250805-v1:0, us.anthropic.claude-opus-4-5-20251101-v1:0, us.anthropic.claude-opus-4-6-v1, us.anthropic.claude-sonnet-4-20250514-v1:0, us.anthropic.claude-sonnet-4-5-20250929-v1:0, us.anthropic.claude-sonnet-4-6, us.meta.llama3-1-70b-instruct-v1:0, us.meta.llama3-1-8b-instruct-v1:0, us.meta.llama3-2-11b-instruct-v1:0, us.meta.llama3-2-1b-instruct-v1:0, us.meta.llama3-2-3b-instruct-v1:0, us.meta.llama3-2-90b-instruct-v1:0, zai-org/GLM-4.5-Air-FP8, zai-org/GLM-5, zai-org/GLM-5.1
The text to be translated
source_language
str
default: "'Detect Language'"
The language of the input text Afrikaans, Albanian, Amharic, Arabic, Armenian, Assamese, Aymara, Azerbaijani, Bambara, Basque, Belarusian, Bengali, Bhojpuri, Bosnian, Bulgarian, Catalan, Cebuano, Chichewa, Chinese Simplified, Chinese Traditional, Corsican, Croatian, Czech, Danish, Detect Language, Divehi, Dogri, Dutch, English, Esperanto, Estonian, Ewe, Filipino, Finnish, French, Frisian, Galician, Ganda, Georgian, German, Greek, Guarani, Gujarati, Haitian Creole, Hausa, Hawaiian, Hebrew, Hindi, Hmong, Hungarian, Icelandic, Igbo, Iloko, Indonesian, Irish Gaelic, Italian, Japanese, Javanese, Kannada, Kazakh, Khmer, Kinyarwanda, Konkani, Korean, Krio, Kurdish [Kurmanji], Kurdish [Sorani], Kyrgyz, Lao, Latin, Latvian, Lingala, Lithuanian, Luxembourgish, Macedonian, Maithili, Malagasy, Malay, Malayalam, Maltese, Maori, Marathi, Meiteilon Manipuri, Mizo, Mongolian, Myanmar [Burmese], Nepali, Northern Sotho, Norwegian, Odia Oriya, Oromo, Pashto, Persian, Polish, Portuguese, Punjabi, Quechua, Romanian, Russian, Samoan, Sanskrit, Scots Gaelic, Serbian, Sesotho, Shona, Sindhi, Sinhala, Slovak, Slovenian, Somali, Spanish, Sundanese, Swahili, Swedish, Tajik, Tamil, Tatar, Telugu, Thai, Tigrinya, Tsonga, Turkish, Turkmen, Twi, Ukrainian, Urdu, Uyghur, Uzbek, Vietnamese, Welsh, Xhosa, Yiddish, Yoruba, Zulu
The language to translate to Afrikaans, Albanian, Amharic, Arabic, Armenian, Assamese, Aymara, Azerbaijani, Bambara, Basque, Belarusian, Bengali, Bhojpuri, Bosnian, Bulgarian, Catalan, Cebuano, Chichewa, Chinese Simplified, Chinese Traditional, Corsican, Croatian, Czech, Danish, Divehi, Dogri, Dutch, English, Esperanto, Estonian, Ewe, Filipino, Finnish, French, Frisian, Galician, Ganda, Georgian, German, Greek, Guarani, Gujarati, Haitian Creole, Hausa, Hawaiian, Hebrew, Hindi, Hmong, Hungarian, Icelandic, Igbo, Iloko, Indonesian, Irish Gaelic, Italian, Japanese, Javanese, Kannada, Kazakh, Khmer, Kinyarwanda, Konkani, Korean, Krio, Kurdish [Kurmanji], Kurdish [Sorani], Kyrgyz, Lao, Latin, Latvian, Lingala, Lithuanian, Luxembourgish, Macedonian, Maithili, Malagasy, Malay, Malayalam, Maltese, Maori, Marathi, Meiteilon Manipuri, Mizo, Mongolian, Myanmar [Burmese], Nepali, Northern Sotho, Norwegian, Odia Oriya, Oromo, Pashto, Persian, Polish, Portuguese, Punjabi, Quechua, Romanian, Russian, Samoan, Sanskrit, Scots Gaelic, Serbian, Sesotho, Shona, Sindhi, Sinhala, Slovak, Slovenian, Somali, Spanish, Sundanese, Swahili, Swedish, Tajik, Tamil, Tatar, Telugu, Thai, Tigrinya, Tsonga, Turkish, Turkmen, Twi, Ukrainian, Urdu, Uyghur, Uzbek, Vietnamese, Welsh, Xhosa, Yiddish, Yoruba, Zulu
write_json_value — Write JSON Value
Update a specific value in a JSON.
pipeline.add( name = "node" ).write_json_value( json_string = "..." )
Parameters
Whether to update the JSON value or create a new JSON
One of: new, old
fields
ListType | list[KeyValue] | list[List[Dict[str, Any]]]
default: "[]"