Skip to main content
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.

integration_airtable — Airtable

Airtable
pipeline.add(name="node").integration_airtable(base_id="...", integration=..., table_id="...")
Parameters
action
str
default:"''"
Select the action to perform
endpoint_0
str
One of: [endpoint_0.&lt;A&gt;]
base_id
str
required
Name of the Airtable base
filter_formula
str
default:"''"
Airtable formula to filter records (optional)
integration
AcceptsIntegration
required
limit
int
default:"10"
Maximum number of records to return (0 for all)
sort_ascending
str
default:"''"
Comma-separated field names to sort in ascending order (e.g., ‘Name, Email’)
sort_descending
str
default:"''"
Comma-separated field names to sort in descending order (e.g., ‘Priority, Date’)
table_id
str
required
Name of the table in the selected base
record_id
str
default:"''"
ID of the record to retrieve
download_attachments
str
default:"''"
Comma seperated values of attachment fields to download files from
condition
str
default:"''"
Conditional Operator
update_all_matches
bool
default:"False"
If enabled, updates all records matching the criteria. If disabled, updates only the first matching record
permission_level
str
default:"''"
Filter bases by permission levels (comma-separated if multiple selected) One of: comment, create, edit, read
return_all
bool
default:"False"
Return all bases without pagination. If false, uses the limit parameter

integration_algolia — Algolia

Algolia
pipeline.add(name="node").integration_algolia(integration=...)
Parameters
action
str
default:"''"
Select the action to perform One of: search_index
query
str
default:"''"
Keyword to be searched in the index
index
str
default:"''"
An index where the data used by Algolia is stored
integration
AcceptsIntegration
required
Connect to your account
return_mode
str
default:"'json'"
Choose between returning as chunks or JSON One of: chunks, json

integration_apify — Apify

Apify
pipeline.add(name="node").integration_apify(actor_id="...", integration=..., run_id="...", key="...")
Parameters
action
str
default:"''"
Select the action to perform
use_date
bool
default:"False"
Toggle to use dates
use_exact_date
bool
default:"False"
Switch between exact date range and relative dates
actor_id
str
required
Actor ID or a tilde-separated username and Actor name
integration
AcceptsIntegration
required
Connect to your account
run_id
str
required
The ID of the run to retrieve
key
str
required
The key of the record to be retrieved
store_id
str
required
The ID of the Key-Value Store
desc
bool
default:"True"
Whether to sort by startedAt in descending order
num_messages
int
default:"10"
Max number of results to return
offset
int
default:"0"
Number of items to skip at the start
status
str
default:"''"
Filter by run status
date_range
dict
default:"{}"
exact_date
dict
default:"{}"
dataset_id
str
required
Dataset ID or username~dataset-name
build
str
default:"''"
Actor build tag to run. Defaults to latest
input
str
default:"'{}'"
JSON input for the Actor run. If empty, uses default run configuration
memory
int
default:"1024"
Memory limit for the run, in megabytes. Example: 1024 (1GB), 2048 (2GB), 4096 (4GB)
timeout
int
default:"0"
Optional timeout for the run, in seconds. Example: 3600 (1 hour). Set to 0 or leave empty for no timeout (only sent to API if value > 0)
wait_for_finish
bool
default:"False"
Whether to wait for the run to finish before continuing
task_id
str
required
Task ID or a tilde-separated username and task name
url
str
required
URL to be scraped. Must start with http:// or https://

integration_apollo — Apollo

Apollo
pipeline.add(name="node").integration_apollo(integration=...)
Parameters
action
str
default:"''"
Select the action to perform One of: enrich_company, enrich_contact, fetch_companies
domain
str
default:"''"
Company domain
integration
AcceptsIntegration
required
Connect to your account
company_name
str
default:"''"
Name of the company to search
first_name_input
str
default:"''"
Contact’s first name
last_name_input
str
default:"''"
Contact’s last name
linkedin_url_input
str
default:"''"
Contact’s LinkedIn URL
keywords
str
default:"''"
Comma separated list of keywords the company should be associated with
location
str
default:"''"
Location of the company headquarters
max_size
str
default:"''"
Maximum number of employees in the company
min_size
str
default:"''"
Minimum number of employees in the company
num_results
str
default:"''"
Limit number of results

integration_asana — Asana

Asana
pipeline.add(name="node").integration_asana(text="...", integration=..., parent="...", tag="...")
Parameters
action
str
default:"''"
Select the action to perform
text
str
required
Text to search for in task names and descriptions
integration
AcceptsIntegration
required
Connect to your Asana account
parent
str
required
The task to create the subtask in
project
str
default:"''"
The project to create the task in
section
str
default:"''"
The section to create the task in
workspace
str
default:"''"
The Asana workspace
assignee
str
default:"''"
Email of the person to assign the task to
name
str
default:"''"
The name of the project to create
notes
str
default:"''"
Notes or description for the project
tag
str
required
The tag to add
task
str
default:"''"
The task to get details from
completed
bool
default:"False"
Whether to mark the task as completed
due_on
str
default:"''"
Due date for the task (YYYY-MM-DD format)
public
bool
default:"False"
Whether the project should be public
team
str
default:"''"
The team to create the project in
completed_since
AcceptsTimestamp
default:"-1"
Only return tasks completed after this time (optional)
archived
bool
default:"False"
Whether to include archived projects in the results
limit
int
default:"50"
Maximum number of projects to return (1-100)
target_project
str
default:"''"
The project to move the task to
target_section
str
default:"''"
The section within the project to move the task to (optional)
target_workspace
str
default:"''"
The Asana workspace to move the task to
user_gid
str
required
The global ID of the user to retrieve (optional, defaults to current user)
comment_gid
str
required
The global ID of the comment to remove

integration_aws_s_3 — AWS S3

AWS S3
pipeline.add(name="node").integration_aws_s_3(bucket_name="...", file=..., integration=..., object_key="...")
Parameters
action
str
default:"''"
Select the action to perform
bucket_name
str
required
Enter the name of the bucket to create
content_type
str
default:"''"
MIME type of the file (optional)
file
AcceptsFile
required
Select a file to upload
integration
AcceptsIntegration
required
Connect to your AWS account
metadata
str
default:"''"
Custom metadata as JSON
object_key
str
required
Enter the key (path) for the object
storage_class
str
default:"'STANDARD'"
Select the storage class One of: DEEP_ARCHIVE, GLACIER, ONEZONE_IA, REDUCED_REDUNDANCY, STANDARD, STANDARD_IA
destination_key
str
required
Select the folder and enter the filename
source_key
str
required
Select the source object
public_read_access
bool
default:"False"
Allow public read access to objects
region
str
required
AWS region for the bucket
versioning_enabled
bool
default:"False"
Enable object versioning for this bucket
max_results
int
default:"100"
Maximum number of results to return
search_query
str
required
Search for objects containing this text in their key
folder_name
str
required
Name of the new folder to create
parent_folder_id
str
default:"''"
Select the parent folder (optional - leave empty to create in bucket root)
force_delete
bool
default:"False"
Delete folder even if it contains files
max_keys
int
default:"10"
Maximum number of objects to return
prefix
str
default:"''"
Filter objects by prefix
delimiter
str
default:"'/'"
Delimiter for folder structure

integration_bland_ai — Bland AI

Bland AI
pipeline.add(name="node").integration_bland_ai(integration=...)
Parameters
action
str
default:"''"
Select the action to perform One of: call_a_number
model
str
default:"'enhanced'"
LLM model that the AI should use
temperature
str
default:"''"
A value between 0 and 1 that controls the randomness of the LLM. 0 will cause more deterministic outputs while 1 will cause more random
first_sentence
str
default:"''"
The first sentence the AI should speak during the call
integration
AcceptsIntegration
required
Connect to your account
pathway_id
str
default:"''"
This is the pathway ID for the pathway you have created on your dev portal.
phone_number
str
default:"''"
The phone number of the contact you want to call
task
str
default:"''"
The objective you want the AI to accomplish during the call
transfer_number
str
default:"''"
A phone number that the agent can transfer to under specific conditions - such as being asked to speak to a human or supervisor
wait_for_greeting
bool
default:"False"
When checked, the agent will wait for the call recipient to speak first before responding

integration_box — Box

Box
pipeline.add(name="node").integration_box(query="...", integration=..., limit=0, type="both")
Parameters
action
str
default:"''"
Select the action to perform
query
str
required
Search query to find files
file_extensions
list[str]
default:"[]"
Filter by file extensions (optional)
folder_id
str
default:"''"
Select the Folder to upload files to
integration
AcceptsIntegration
required
Connect to your account
limit
int
required
Maximum number of results to return (default: 10)
offset
int
default:"0"
Number of records to skip from the start. Must be a multiple of the limit value (e.g., if limit is 6, valid offsets are 0, 6, 12, …)
type
str
required
Type of item to search for One of: both, file, folder
destination_folder_id
str
required
Select the destination folder
file_id
str
required
Select the file to copy
new_name
str
default:"''"
Name for the copied file (optional)
folder_name
str
required
Name of the folder to create
parent_folder_id
str
required
Select the parent folder where the new folder will be created
description
str
default:"''"
Description for the folder (optional)
files
AcceptsFileList
required
The number of files to be appended. Files will be appended in successive fashion (e.g., file-1 first, then file-2, etc.)
recursive
bool
default:"False"
Delete folder and all its contents (use with caution)
access
str
default:"'open'"
Access level for the shared link One of: collaborators, company, open
can_download
bool
default:"True"
Whether users can download the file
can_preview
bool
default:"True"
Whether users can preview the file

integration_clickup — ClickUp

ClickUp
pipeline.add(name="node").integration_clickup(integration=..., num_messages=0, duration_minutes=0, start_time="...")
Parameters
action
str
default:"''"
Select the action to perform
use_date
bool
default:"False"
Filter tasks by created date range
use_exact_date
bool
default:"False"
Switch between exact date range and relative dates
archived
bool
default:"False"
Show archived tasks
assignees
str
default:"''"
Filter by assignee (requires Team, Space, Folder, and List to be selected first)
custom_fields
str
default:"''"
Custom field filters in JSON format: {“field_id”: “value”}
date_updated_gt
AcceptsTimestamp
default:"''"
Tasks updated after this date (YYYY-MM-DD)
date_updated_lt
AcceptsTimestamp
default:"''"
Tasks updated before this date (YYYY-MM-DD)
due_date_gt
AcceptsTimestamp
default:"''"
Tasks due after this date (YYYY-MM-DD)
due_date_lt
AcceptsTimestamp
default:"''"
Tasks due before this date (YYYY-MM-DD)
folder_id
str
default:"''"
The ID of the folder
include_closed
bool
default:"False"
Include closed tasks
include_markdown_description
bool
default:"False"
Include markdown description
integration
AcceptsIntegration
required
Connect to your account
list_id
str
default:"''"
The ID of the list where task will be created
num_messages
int
required
Specify the number of tasks to fetch
order_by
str
default:"''"
Sort tasks by field (created, updated, due_date, etc.)
reverse
bool
default:"False"
Reverse the sort order
space_id
str
default:"''"
The ID of the space
statuses
str
default:"''"
Filter by specific task statuses (requires Team, Space, Folder, and List to be selected first)
subtasks
bool
default:"False"
Include subtasks
tags
str
default:"''"
Filter by tag names
team_id
str
default:"''"
The ID of the team
assignee
str
default:"''"
Filter by assignee user ID
include_location_names
bool
default:"False"
Include location names
task_id
str
default:"''"
The ID of the task to read
time_entry_billable
bool
default:"False"
Mark time entry as billable
time_entry_description
str
default:"''"
Description of the time entry
duration_minutes
int
required
Duration in minutes
start_time
str
required
Start time for the time entry (ISO 8601 format)
time_entry_assignee
str
default:"''"
Assignee user ID for the time entry
time_entry_tags
str
default:"''"
Comma-separated list of tags or JSON objects
background_color
str
default:"'#ff0000'"
Background color for the tag(s) in hex format (applies to all tags if multiple)
foreground_color
str
default:"'#ffffff'"
Foreground (text) color for the tag(s) in hex format (applies to all tags if multiple)
tag_name
str
required
Name of the tag
time_entry_id
str
required
The ID of the time entry to delete
markdown_content
str
default:"''"
Task content in markdown format
notify_all
bool
default:"False"
Notify all members when task is created
parent_id
str
default:"''"
ID of the parent task (for subtasks)
task_assignees
str
default:"''"
List of assignee IDs
task_description
str
required
Description of the task
task_due_date
AcceptsTimestamp
default:"''"
Due date for the task (timestamp)
task_name
str
required
Name of the task
task_priority
str
default:"''"
Priority of the task One of: 1, 2, 3, 4
task_start_date
AcceptsTimestamp
default:"''"
Start date for the task (timestamp)
task_status
str
default:"''"
Status of the task
task_tags
str
default:"''"
List of tags for the task
time_estimate
int
default:"''"
Time estimate for the task in hours
custom_field_id
str
required
The ID of the custom field
custom_field_value
str
required
The value to set for the custom field
custom_task_ids
bool
default:"False"
Use custom task IDs
checklist_name
str
required
Name of the checklist
checklist_id
str
required
The ID of the checklist to delete
checklist_item_assignee
str
default:"''"
User ID to assign to this checklist item
checklist_item_name
str
required
Name of the checklist item
assign_user
str
default:"''"
User ID to assign to this comment
comment_on
str
required
Select where to add the comment One of: List, Task, View
comment_text
str
required
Content of the comment
view_id
str
default:"''"
The ID of the view to add comment to (required when Comment On is ‘View’)
folder_name
str
required
Name of the folder
goal_color
str
default:"''"
Color for the goal
goal_description
str
default:"''"
Description of the goal
goal_due_date
str
default:"''"
Due date for the goal (YYYY-MM-DD or RFC3339)
goal_multiple_owners
bool
default:"False"
Allow multiple owners
goal_name
str
required
Name of the goal
goal_owners
str
default:"''"
Comma-separated list of owner user IDs
goal_id
str
required
The ID of the goal to delete
key_result_list_ids
str
default:"''"
Comma-separated list of list IDs
key_result_name
str
required
Name of the key result
key_result_owners
str
default:"''"
Comma-separated list of owner user IDs
key_result_steps_end
int
default:"10"
Target value for the key result
key_result_steps_start
int
default:"0"
Starting value for the key result
key_result_task_ids
str
default:"''"
Comma-separated list of task IDs
key_result_type
str
default:"''"
Type of key result One of: automatic, boolean, currency, number, percentage
key_result_unit
str
default:"''"
Unit for the key result
enable_custom_fields
bool
default:"True"
Allow custom fields
enable_dependency_warnings
bool
default:"True"
Allow dependency warnings
enable_incomplete_warnings
bool
default:"True"
Allow incomplete warnings
enable_priority
bool
default:"True"
Allow priority
enable_tags
bool
default:"True"
Allow tags
enable_time_tracking
bool
default:"True"
Allow time tracking
space_multiple_assignees
bool
default:"True"
Allow multiple assignees
space_name
str
required
Name of the space
tag_background_color
str
default:"'#ffffff'"
Background color for the tag
tag_foreground_color
str
default:"'#000000'"
Foreground color for the tag
depends_on_task_id
str
required
The ID of the task that this task depends on
checklist_item_id
str
required
The ID of the checklist item to delete
limit
int
default:"10"
Maximum number of folders to retrieve
get_running
bool
default:"False"
Get currently running time entry
update_checklist_item_assignee
str
default:"''"
New assignee for the checklist item
update_checklist_item_name
str
default:"''"
New name for the checklist item
update_checklist_item_parent
str
default:"''"
New parent for the checklist item
update_checklist_item_resolved
bool
default:"False"
Mark checklist item as resolved
update_folder_name
str
required
New name for the folder
new_tag_name
str
default:"''"
New name for the tag
update_time_entry_billable
bool
default:"False"
Mark time entry as billable
update_time_entry_description
str
default:"''"
New description for the time entry
update_time_entry_duration_minutes
int
default:"60"
New duration in minutes
update_time_entry_start
str
default:"''"
New start time (RFC3339 format)
update_time_entry_task_id
str
default:"''"
New task ID for the time entry
folderless
bool
default:"False"
If enabled, create list at space root level without a folder
list_content
str
default:"''"
Description of the list
list_name
str
required
Name of the list
comment_id
str
required
The ID of the comment to update (comment under task or list)
key_result_id
str
required
The ID of the key result to delete
include_completed
bool
default:"False"
Include completed goals
date_range
dict
default:"{}"
pick the relative date range
exact_date
dict
default:"{}"
Pick the start and end dates
update_checklist_name
str
default:"''"
New name for the checklist
update_checklist_position
int
default:"0"
New position for the checklist
update_comment_assignee
str
default:"''"
User ID to assign the comment to
update_comment_resolved
bool
default:"False"
Mark the comment as resolved
update_comment_text
str
default:"''"
New content for the comment
update_goal_add_owners
str
default:"''"
Comma-separated list of owner user IDs to add
update_goal_color
str
default:"''"
New color for the goal
update_goal_description
str
default:"''"
New description for the goal
update_goal_due_date
str
default:"''"
New due date for the goal (YYYY-MM-DD or RFC3339)
update_goal_name
str
default:"''"
New name for the goal
update_goal_remove_owners
str
default:"''"
Comma-separated list of owner user IDs to remove
update_key_result_name
str
default:"''"
New name for the key result
update_key_result_note
str
default:"''"
New note for the key result
update_key_result_steps_current
int
default:"0"
Current progress value
update_key_result_steps_end
int
default:"10"
New target value
update_key_result_steps_start
int
default:"0"
New starting value
update_key_result_unit
str
default:"''"
New unit for the key result
update_list_content
str
default:"''"
New description for the list
update_list_name
str
default:"''"
New name for the list
remove_all_assignees
bool
default:"False"
If enabled, all assignees will be removed from the task
update_markdown_content
str
default:"''"
Task content in markdown format
update_parent_id
str
default:"''"
New parent task ID (for subtasks)
update_task_assignees
str
default:"''"
New list of assignee IDs (will not work if remove_assignees is enabled)
update_task_description
str
default:"''"
New description for the task
update_task_due_date
AcceptsTimestamp
default:"''"
New due date for the task (timestamp)
update_task_name
str
default:"''"
New name for the task
update_task_priority
str
default:"''"
New priority for the task One of: 1, 2, 3, 4
update_task_start_date
AcceptsTimestamp
default:"''"
New start date for the task (timestamp)
update_task_status
str
default:"''"
New status for the task
update_task_tags
str
default:"''"
New list of tags for the task
update_time_estimate
int
default:"''"
New time estimate for the task in hours

integration_cobalt — Cobalt

Cobalt
pipeline.add(name="node").integration_cobalt(cashflow_id="...", custom_field_id="...", integration=..., value=...)
Parameters
action
str
default:"''"
Select the action to perform
entity_scope
str
default:"'cashflow'"
Limit results to cashflows for this entity type One of: cashflow, company, deal, fund, portfolio
cashflow_id
str
required
Cobalt cashflow UID
custom_field_id
str
required
Custom field definition to record against
date
AcceptsTimestamp
default:"''"
Date the cashflow occurred
integration
AcceptsIntegration
required
Connect to your Cobalt account
value
float | str
required
Numeric value to record
company_id
str
default:"''"
Select a company
deal_id
str
default:"''"
Select a deal under the chosen fund
fund_id
str
default:"''"
Select a fund
aggregation_type
str
default:"''"
gross requires deal_id; net forbids it One of: gross, net
limit
int
required
Maximum number of portfolios to retrieve (ignored when Return All is on)
return_all
bool
required
Return every portfolio (ignores limit)
portfolio_id
str
default:"''"
Select a portfolio
as_of_date
AcceptsTimestamp
default:"''"
Snapshot date for the calculation (optional)
cashflow_type
str
default:"'net'"
Use net or gross cashflows in the calculation. Defaults to net. One of: gross, net
currency
str
default:"''"
ISO currency code (e.g. USD)
start_date
AcceptsTimestamp
default:"''"
Earliest date to include in the calculation (optional)
amount
float
required
Cashflow amount (positive for distribution, negative for contribution)
classification_uid
str
required
Cobalt cashflow classification
investment_currency_amount
float
default:"0"
Amount in the deal’s investment currency (optional)
note
str
default:"''"
Optional note attached to the cashflow
text
str
default:"''"
Plain text only — Cobalt rejects rich text via API
title
str
default:"''"
Title of the investment update
update_type_id
str
required
Cobalt investment update type
custom_field_ids
str
default:"''"
Accepts a single ID, a list, or a comma-separated string.
entity_id
str
required
Fund / Company / Deal / Cashflow UID. Accepts a single ID, a list, or a comma-separated string.
offset
int
default:"0"
Number of portfolios to skip (for paging)
end_date
AcceptsTimestamp
default:"''"
Latest date to include (when filter is enabled)
metric_set_id
str
required
Cobalt UID of the metric set to record against
use_date
bool
default:"False"
Apply the start/end date filter
update_type_ids
str
default:"''"
Update type UIDs to filter by. Accepts a single ID, a list, or a comma-separated string.
sort
str
default:"''"
Sort order for the returned portfolios One of: description, description:desc, name, name:desc, uid, uid:desc
acquisition_date
AcceptsTimestamp
default:"''"
Date the deal was acquired
commitment
float
default:"0"
Total commitment amount in the selected currency
currency_symbol
str
default:"''"
ISO currency code (e.g. USD)
exit_date
AcceptsTimestamp
default:"''"
Date the deal was exited (optional)
round_name
str
default:"''"
Funding round label
include_external
bool
default:"False"
Include deals from external funds/investors
order_by_field
str
default:"''"
Field to order results by One of: commitment, name
order_direction
str
default:"''"
The order to sort the data One of: asc, desc
metric_id
str
default:"''"
Filter sets to this metric definition
metric_scenario_id
str
default:"''"
Filter sets to this scenario (legacy metric system only)
fiscal_quarter_1
AcceptsTimestamp
default:"''"
End date of fiscal Q1
fiscal_quarter_2
AcceptsTimestamp
default:"''"
End date of fiscal Q2
fiscal_quarter_3
AcceptsTimestamp
default:"''"
End date of fiscal Q3
fiscal_quarter_4
AcceptsTimestamp
default:"''"
End date of fiscal Q4 (must equal Fiscal Year End)
fiscal_year_end
AcceptsTimestamp
default:"''"
Optional. If supplied, all four fiscal quarters must also be supplied and fiscal_year_end must equal fiscal_quarter_4
name
str
required
Name of the portfolio to create
fund_ids
str
default:"''"
Select funds from dropdown, or enter fund IDs comma-separated. Cannot be modified after creation.
custom_field_value_id
str
required
Cobalt UID of the custom field value to delete
update_id
str
required
Cobalt UID of the investment update
metric_value_id
str
required
Cobalt UID of the metric value to delete

integration_coda — Coda

Coda
pipeline.add(name="node").integration_coda(column_id="...", doc_id="...", integration=..., row_id="...")
Parameters
action
str
default:"''"
Select the Coda operation to perform
column_id
str
required
Choose the column to retrieve
doc_id
str
required
Choose the Coda document
integration
AcceptsIntegration
required
Connect to your Coda account
row_id
str
required
The ID of the row to retrieve
table_id
str
required
Choose the table to insert into
view_id
str
required
Choose the view to retrieve
limit
int
required
Maximum number of controls to return
use_column_names
bool
default:"True"
Return column names instead of IDs
cells
str
required
JSON object with column-value pairs to insert
key_columns
list[str]
default:"[]"
Optional key columns for upsert behavior
row_ids
list[str]
required
List of row IDs to delete
control_id
str
required
The ID of the control to retrieve
formula_id
str
required
The ID of the formula to retrieve

integration_copper — Copper

Copper
pipeline.add(name="node").integration_copper(integration=...)
Parameters
action
str
default:"''"
Select the action to perform One of: create_lead
email
str
default:"''"
The email of the lead
integration
AcceptsIntegration
required
Connect to your account
name
str
default:"''"
The name of the lead

integration_databricks — Databricks

Databricks
pipeline.add(name="node").integration_databricks(cluster_name="...", integration=..., node_type_id="...", num_workers=0)
Parameters
action
str
default:"''"
Select the action to perform
endpoint_0
str
One of: [endpoint_0.&lt;A&gt;]
autotermination_minutes
int
default:"120"
Auto-termination time in minutes ( Set to 0 to disable auto-termination )
cluster_name
str
required
Name of the cluster
enable_elastic_disk
bool
default:"True"
Enable elastic disk for the cluster
integration
AcceptsIntegration
required
Connect to your account
node_type_id
str
required
Node type for cluster instances
num_workers
int
required
Number of worker nodes
spark_version
str
required
Spark version for the cluster
catalog_name
str
default:"''"
Select the name of the Catalog
schema_name
str
default:"''"
Select the name of the Schema
table_name
str
required
Select the name of Table to insert the row
warehouse_id
str
default:"''"
Select the ID of the Warehouse to perform the action
cluster_id
str
required
ID of the cluster to delete
job_name
str
required
Name of the job
max_concurrent_runs
int
default:"1"
Maximum number of concurrent runs
notebook_path
str
required
Path to the notebook
timeout_seconds
int
default:"3600"
Timeout in seconds
file
AcceptsFile
required
File to upload
overwrite
bool
default:"False"
Overwrite existing file
path
str
required
Path of the directory to create
recursive
bool
default:"False"
Delete directory recursively
num_messages
int
required
Maximum number of clusters to retrieve
query
str
default:"''"
SQL query to execute against the Databricks SQL Warehouse
on_wait_timeout
str
default:"'CONTINUE'"
Action to take when timeout is reached One of: CANCEL, CONTINUE
wait_timeout
str
default:"'50s'"
Timeout for waiting for query completion (e.g., 30s, 1m, 5m)

integration_datadog — Datadog

Datadog
pipeline.add(name="node").integration_datadog(body="...", endpoint="...", integration=...)
Parameters
action
str
default:"''"
Select the HTTP method to use One of: delete, get, head, options, patch, post, put
body
str
required
Request body as JSON
endpoint
str
required
The API endpoint path (e.g., /api/v1/dashboard)
headers
str
default:"''"
Additional headers as JSON object (optional)
integration
AcceptsIntegration
required
Connect to your Datadog account
query_params
str
default:"''"
Query parameters as JSON object (optional)
data_path
str
default:"'data'"
JSON path to the array of results in the response (e.g., ‘data’, ‘monitors’, ‘dashboards’)
max_pages
int
default:"10"
Maximum number of pages to fetch (default: 10, set to 0 for unlimited)
page_size
int
default:"100"
Number of items per page (default: 100)
paginate
bool
default:"False"
Enable automatic pagination to fetch all results
pagination_type
str
default:"'offset'"
Type of pagination: ‘offset’ (page[offset]/page[limit]) or ‘cursor’ (page[cursor]) One of: cursor, offset

integration_discord — Discord

Discord
pipeline.add(name="node").integration_discord(integration=..., role_id="...", user_id="...", channel_id="...")
Parameters
action
str
default:"''"
Select the action to perform
guild_id
str
default:"''"
Select the Discord server
integration
AcceptsIntegration
required
Connect to your account
reason
str
default:"''"
Reason for adding the role (optional)
role_id
str
required
Select the role to add
user_id
str
required
ID of the user to add the role to
channel_id
str
required
Select the channel to delete
emoji
str
required
Emoji to react with (unicode or :name:)
message_id
str
required
ID of the message to delete
channel_name
str
default:"''"
Name of the channel to create
channel_type
str
default:"'text'"
Type of the channel to create One of: announcement, category, forum, stage, text, voice
topic
str
default:"''"
Topic for the channel (optional)
limit
int
default:"10"
Maximum number of channels to retrieve
after
str
default:"''"
Get messages after this message ID (optional)
before
str
default:"''"
Get messages before this message ID (optional)
message
str
required
The message to send
tts
bool
default:"False"
Whether the message should be read aloud

integration_docusign — DocuSign

DocuSign
pipeline.add(name="node").integration_docusign(integration=..., limit=0, envelope_id="...")
Parameters
action
str
default:"''"
Select the action to perform One of: create_envelope, get_envelope, list_envelopes, send_envelope, update_envelope
use_date
bool
default:"False"
Toggle to use date filtering
use_exact_date
bool
default:"False"
Switch between exact date range and relative dates
folder_ids
str
default:"''"
Filter by folder IDs (comma-separated)
include
str
default:"''"
Additional data to include (comma-separated: recipients, documents, custom_fields)
integration
AcceptsIntegration
required
Connect to your Docusign account
limit
int
required
Maximum number of envelopes to return (default: 10)
order
str
default:"'desc'"
Sort order One of: asc, desc
order_by
str
default:"''"
Field to sort by (e.g., created, sent, completed)
search_text
str
default:"''"
Search text to filter envelopes
status
str
default:"''"
Send immediately or save as draft One of: “, completed, created, declined, deleted, delivered, sent, voided
date_range
dict
default:"{}"
exact_date
dict
default:"{}"
add_date_signed
bool
default:"False"
Add a date signed field next to signature
add_signature
bool
default:"True"
Add a signature field for the first signer
cc_emails
str
default:"''"
Email(s) to receive a copy (comma-separated)
cc_names
str
default:"''"
Name(s) of CC recipients (comma-separated, same order as emails)
documents
AcceptsFileList
default:"[]"
Files to be signed (PDF, Word, etc.)
email_blurb
str
default:"''"
Body text of the envelope email
email_subject
str
default:"''"
Subject line of the envelope email
expire_after
int
default:"0"
Number of days until envelope expires (0 = use account default)
expire_enabled
bool
default:"False"
Enable envelope expiration
expire_warn
int
default:"0"
Days before expiration to warn signers (0 = use account default)
reminder_delay
int
default:"0"
Days to wait before sending first reminder (0 = use account default)
reminder_enabled
bool
default:"False"
Send automatic reminders to signers
reminder_frequency
int
default:"0"
Days between reminder emails (0 = use account default)
signature_anchor
str
default:"''"
Text in document to place signature near (overrides position)
signature_position
str
default:"'bottom_left'"
Where to place the signature on the first page One of: bottom_center, bottom_left, bottom_right, top_center, top_left, top_right
signer_can_sign_on_mobile
bool
default:"False"
Allow signers to sign on mobile devices
signer_emails
str
default:"''"
Email address(es) of signers (comma-separated for multiple)
signer_names
str
default:"''"
Full name(s) of signers (comma-separated, same order as emails)
template_id
str
default:"''"
Use a Docusign template instead of uploading documents
template_role_name
str
default:"''"
Role name from the template (e.g., Signer, Approver)
envelope_id
str
required
The envelope ID (UUID format) - get this from List Envelopes or Docusign
add_cc_email
str
default:"''"
Add a new CC recipient
add_cc_name
str
default:"''"
Name of the new CC recipient
add_documents
AcceptsFileList
default:"[]"
Add more documents to a draft envelope
add_signer_email
str
default:"''"
Add a new signer to a draft envelope
add_signer_name
str
default:"''"
Name of the new signer
purge_state
str
default:"''"
Purge documents from the envelope One of: “, documents_and_metadata, documents_only
resend_envelope
bool
default:"False"
Resend email notifications to recipients
voided_reason
str
default:"''"
Reason for voiding (required when status is voided)

integration_dropbox — Dropbox

Dropbox
pipeline.add(name="node").integration_dropbox(file=..., folder_id="...", integration=..., destination_folder_id="...")
Parameters
action
str
default:"''"
Select the action to perform
file
AcceptsFile
required
Content of the file to upload
folder_id
str
required
Select the folder where you want to post the file to
integration
AcceptsIntegration
required
Connect to your account
destination_folder_id
str
required
Select the destination folder
new_file_name
str
default:"''"
Name for the copied file
source_file_id
str
required
Select the file to copy
new_folder_name
str
default:"''"
Name for the copied folder
source_folder_id
str
default:"''"
Select folder to copy
include_deleted
bool
default:"False"
Include deleted files
include_subfolders
bool
default:"False"
Include files from subfolders
limit
int
default:"10"
Number of files to retrieve
recursive
bool
default:"False"
Whether to list folder contents recursively
file_types
str
default:"''"
Filter by file types (comma-separated)
include_shared_folders
bool
default:"False"
Include shared/team folders in search. If disabled, only personal folders will be searched, even if you specify a shared folder ID.
search_folder_id
str
default:"''"
Optional: Restrict search to specific folder. Paste folder ID from search results or folder listings (format: id:XXXXX for personal folders, ns:XXXXX for shared folders). Leave blank to search everywhere.
search_limit
int
default:"10"
Maximum number of search results
search_query
str
required
Query to search for files and folders
folder_name
str
default:"''"
Name of the folder to create
parent_folder_id
str
default:"''"
Select parent folder
delete_file_id
str
default:"''"
Select file to delete
file_path
str
default:"''"
Full path to the file. Personal folders: /folder/file.pdf | Shared folders: ns:namespace_id/file.pdf (copy from search results or folder listings)
read_file_id
str
default:"''"
Select file to read

integration_elasticsearch — Elasticsearch

Elasticsearch
pipeline.add(name="node").integration_elasticsearch(document="...", integration=..., confirm_delete=True, limit=0)
Parameters
action
str
default:"''"
Select the operation to perform
document
str
required
JSON document to index
document_id
str
default:"''"
Unique identifier for the document (optional - will be auto-generated if empty)
index
str
default:"''"
Elasticsearch index name
integration
AcceptsIntegration
required
Connect to your Elasticsearch cluster
upsert
bool
default:"False"
Create document if it doesn’t exist
confirm_delete
bool
required
Confirm that you want to delete this index and all its data
query
str
default:"''"
Elasticsearch query in JSON format (optional - defaults to match_all)
from_
int
default:"0"
limit
int
required
Maximum number of documents to return
mappings
str
default:"''"
Index mappings in JSON format (optional)
settings
str
default:"''"
Index settings in JSON format (optional)
include_system
bool
default:"False"
Include system indices (starting with .)
pattern
str
default:"'*'"
Index pattern to match (use * for all indices)

integration_figma — Figma

Figma
pipeline.add(name="node").integration_figma(emoji="...", file_key="...", integration=..., message="...")
Parameters
action
str
default:"''"
Select the action to perform
comment_id
str
default:"''"
Optional: Enter an existing comment ID to reply to it. Leave empty to create a new comment thread
emoji
str
required
The emoji shortcode to use as a reaction
file_key
str
required
Paste the full Figma URL or just the file key. Node IDs will be auto-extracted from URL
integration
AcceptsIntegration
required
Connect to your Figma account
message
str
required
The text content of your comment
node_id
str
default:"''"
Optional: Node ID to attach comment to (auto-extracted from URL if provided)
x
float
default:"0"
Optional: Horizontal position on the canvas (in pixels). Only used if no Node ID is provided
y
float
default:"0"
Optional: Vertical position on the canvas (in pixels). Only used if no Node ID is provided
depth
int
default:"1"
How deep to traverse the document tree (1 = Pages only, 2 = Pages + top-level objects, leave empty for full depth)
geometry
str
default:"''"
Set to ‘paths’ to include vector path data (leave empty to exclude)
node_ids
str
required
Comma-separated node IDs to retrieve (e.g., 0:1,1:2)
plugin_data
str
default:"''"
Comma-separated list of plugin IDs to include data for (optional)
version
str
default:"''"
Specific version ID to retrieve (optional, defaults to latest)
contents_only
bool
default:"False"
For PDF, omit surrounding empty space
download_images
bool
default:"False"
Download and return actual image files instead of just URLs
format
str
default:"'png'"
Image output format One of: jpg, pdf, png, svg
scale
float
default:"1.0"
Scale factor for the image (0.01 to 4.0)
svg_include_id
bool
default:"False"
Include ID attributes in SVG output
svg_outline_text
bool
default:"False"
Convert text to outlines in SVG output
svg_simplify_stroke
bool
default:"False"
Simplify strokes in SVG output
use_absolute_bounds
bool
default:"False"
Use full dimensions of the node regardless of cropping
as_md
bool
default:"False"
Return comment messages as markdown
branch_data
bool
default:"False"
Include branch metadata if the file is a branch
ids
str
default:"''"
Comma-separated list of node IDs to retrieve (optional, auto-extracted from URL if provided)

integration_fred — Fred

Fred
pipeline.add(name="node").integration_fred(category_id="...", integration=..., limit=0, release_id="...")
Parameters
action
str
default:"''"
Select the action to perform
use_date
bool
default:"False"
Toggle to filter by date range
use_exact_date
bool
default:"False"
Switch between exact date range and relative dates
return_all
bool
default:"False"
Return all results (ignores limit)
category_id
str
required
The ID of the category to retrieve. Use 0 for root category
exclude_tag_names
str
default:"''"
Exclude series with these tags (semicolon-separated)
integration
AcceptsIntegration
required
Connect to your FRED API account
limit
int
required
Maximum number of results to return
order_by
str
default:"'series_count'"
Order results by attribute
search_text
str
default:"''"
Search for tags containing this text
sort_order
str
default:"'desc'"
Sort order for results
tag_group_id
str
default:"'freq'"
Filter by tag group
tag_names
str
default:"''"
Filter by tag names (semicolon-separated)
release_id
str
required
The ID of the release to retrieve
series_search_text
str
required
Text to search for in series (required)
tag_search_text
str
default:"''"
Search for tags containing this text
series_id
str
required
The ID of the series to retrieve
filter_value
str
default:"''"
Value to filter by
filter_variable
str
default:"'frequency'"
Filter by attribute
search_type
str
default:"'full_text'"
Type of search to perform
source_id
str
required
The ID of the source to retrieve
include_release_dates_with_no_data
bool
default:"False"
Include release dates with no data available
aggregation_method
str
default:"'avg'"
Method for frequency aggregation
frequency
str
default:"'m'"
Frequency aggregation
observation_end
str
default:"''"
End date for observations (format: YYYY-MM-DD)
observation_start
str
default:"''"
Start date for observations (format: YYYY-MM-DD)
output_type
str
default:"'1'"
Output type for observations
units
str
default:"'lin'"
Data transformation
vintage_dates
str
default:"''"
Comma-separated vintage dates
end_time
str
default:"''"
End time for updates (format: HH:MM)
start_time
str
default:"''"
Start time for updates (format: HH:MM)
date_range
dict
default:"{}"
exact_date
dict
default:"{}"
element_id
int
default:"0"
The element ID to filter tables (0 for all)
include_observation_values
bool
default:"False"
Include observation values in the response
observation_date
str
default:"''"
Date for observation values (format: YYYY-MM-DD)

integration_github — Github

Github
pipeline.add(name="node").integration_github(integration=..., issue_number=0, num_messages=0, organization="...")
Parameters
action
str
default:"''"
Select the action to perform
use_date
bool
default:"False"
Toggle to use dates
use_exact_date
bool
default:"False"
Switch between exact date range and relative dates
direction
str
default:"''"
Sort direction One of: asc, desc
integration
AcceptsIntegration
required
Connect to your account
issue_number
int
required
Number of the issue to update
num_messages
int
required
Specify the number of repositories to fetch
owner
str
default:"''"
Owner of the repository
repository_name
str
default:"''"
Name of the repository to create
return_all
bool
default:"False"
Return all repositories, ignoring the number limit
sort
str
default:"''"
Sort repositories by One of: comments, created, interactions, popularity, reactions, updated
protected
bool
default:"False"
Filter by protected status
assignee
str
default:"''"
Assignee filter
creator
str
default:"''"
Creator filter
labels
str
default:"''"
Comma-separated list of labels
mentioned
str
default:"''"
Mentioned user filter
milestone
int | str
default:"''"
Milestone number
state
str
default:"''"
Issue state filter One of: all, closed, draft, merged, open
base
str
default:"''"
Base branch (target)
head
str
default:"''"
Head branch (source)
filter
str
default:"''"
Filter members by role
organization
str
required
Name of the organization
role
str
default:"''"
Filter by member role
affiliation
str
default:"''"
Affiliation filter
type
str
default:"''"
Repository type filter
visibility
str
default:"''"
Visibility filter
file_path
str
required
Path where the file will be created
file_sha
str
required
Current SHA of the file
update_author_email
str
default:"''"
Email of the author
update_author_name
str
default:"''"
Name of the author
update_branch_name
str
default:"''"
Branch to update the file on
update_commit_message
str
required
Commit message for the file update
update_committer_email
str
default:"''"
Email of the committer
update_committer_name
str
default:"''"
Name of the committer
update_file_content
str
required
New content of the file
author_email
str
default:"''"
Email of the author
author_name
str
default:"''"
Name of the author
branch_name
str
default:"''"
Branch to create the file on
commit_message
str
default:"''"
Message for the merge commit
committer_email
str
default:"''"
Email of the committer
committer_name
str
default:"''"
Name of the committer
file_content
str
required
Content of the file
draft
bool
default:"False"
Create as draft pull request
maintainer_can_modify
bool
default:"True"
Allow maintainer modifications
pull_request_body
str
default:"''"
Body content of the pull request
pull_request_title
str
required
Title of the pull request
delete_author_email
str
default:"''"
Email of the author
delete_author_name
str
default:"''"
Name of the author
delete_branch_name
str
default:"''"
Branch to delete the file from
delete_commit_message
str
required
Commit message for the file deletion
delete_committer_email
str
default:"''"
Email of the committer
delete_committer_name
str
default:"''"
Name of the committer
delete_file_sha
str
required
Current SHA of the file to delete
comment_body
str
required
Body content of the comment
comment_id
int
required
ID of the comment to update
update_comment_body
str
required
New body for the comment
source_branch
str
default:"''"
Source branch to create from
assignees
str
default:"''"
Comma-separated list of assignee usernames
issue_body
str
default:"''"
Body content of the issue
issue_title
str
required
Title of the issue
generate_release_notes
bool
default:"False"
Auto-generate release notes
prerelease
bool
default:"False"
Mark as prerelease
release_body
str
default:"''"
Description of the release
release_name
str
default:"''"
Name of the release
tag_name
str
required
Name of the tag for the release
target_commitish
str
default:"''"
Commitish value for the release
content_type
str
default:"''"
Content type for webhook payloads
insecure_ssl
bool
default:"False"
Allow insecure SSL
webhook_active
bool
default:"True"
Whether the webhook is active
webhook_events
str
default:"''"
Events to trigger webhook (comma-separated)
webhook_name
str
default:"''"
Name of the webhook
webhook_secret
str
default:"''"
Secret key for webhook security
webhook_url
str
required
URL to send webhook payloads to
release_id
int
required
ID of the release to update
webhook_id
int
required
ID of the webhook to update
date_range
dict
default:"{}"
pick the relative date range
exact_date
dict
default:"{}"
Pick the start and end dates
commit_title
str
default:"''"
Title for the merge commit
merge_method
str
default:"''"
Merge method to use
pull_request_number
int
required
Number of the pull request to update
sha
str
default:"''"
SHA that pull request head must match
ref
str
default:"''"
Branch, tag, or commit to read from
query
str
required
Search query for pull requests
limit
int
required
Maximum number of pull requests to return
update_assignees
str
default:"''"
New assignees for the issue
update_issue_body
str
default:"''"
New body for the issue
update_issue_state
str
default:"''"
New state for the issue
update_issue_title
str
default:"''"
New title for the issue
update_labels
str
default:"''"
New labels for the issue
update_milestone
int
default:"0"
New milestone for the issue
update_base
str
default:"''"
New base branch
update_maintainer_can_modify
bool
default:"True"
Update maintainer modification permission
update_pull_request_body
str
default:"''"
New body for the pull request
update_pull_request_state
str
default:"''"
New state for the pull request
update_pull_request_title
str
default:"''"
New title for the pull request
update_draft
bool
default:"False"
Update draft status
update_prerelease
bool
default:"False"
Update prerelease status
update_release_body
str
default:"''"
New description for the release
update_release_name
str
default:"''"
New name for the release
update_tag_name
str
default:"''"
New tag name for the release
update_target_commitish
str
default:"''"
New commitish value for the release
update_content_type
str
default:"''"
New content type
update_insecure_ssl
bool
default:"False"
Update insecure SSL setting
update_webhook_active
bool
default:"True"
Update webhook active status
update_webhook_events
str
default:"''"
New events to trigger webhook
update_webhook_secret
str
default:"''"
New secret key for webhook
update_webhook_url
str
default:"''"
New URL for webhook payloads
update_has_issues
bool
default:"True"
Enable/disable issues
update_has_projects
bool
default:"True"
Enable/disable projects
update_has_wiki
bool
default:"True"
Enable/disable wiki
update_homepage
str
default:"''"
New homepage URL
update_is_private
bool
default:"False"
Update privacy setting
update_repository_description
str
default:"''"
New description for the repository
update_repository_name
str
default:"''"
New name for the repository
auto_init
bool
default:"True"
Initialize repository with a README
gitignore_template
str
default:"''"
GitIgnore template to use
homepage
str
default:"''"
Homepage URL for the repository
is_private
bool
default:"False"
Whether the repository should be private
license_template
str
default:"''"
License template to use
repository_description
str
default:"''"
Description of the repository
username
str
required
Username to read information for

integration_gitlab — Gitlab

Gitlab
pipeline.add(name="node").integration_gitlab(commit_message="...", file=..., file_path="...", integration=...)
Parameters
action
str
default:"''"
Select the action to perform
return_all
bool
default:"False"
Whether to return all files (ignores limit)
author_email
str
default:"''"
Email of the author
author_name
str
default:"''"
Name of the author
branch
str
default:"'main'"
Branch to create the file on
commit_message
str
required
Commit message for the file creation
encoding
str
default:"'text'"
Upload as text format or base64 One of: base64, text
file
AcceptsFile
required
Please upload file
file_path
str
required
Path where the file will be created
integration
AcceptsIntegration
required
Connect to your account
project_name
str
required
Name of the project
project_owner
str
required
Project owner username
start_branch
str
default:"''"
The base branch to start the commit from, useful for creating a new branch
committer_email
str
default:"''"
Email of the committer
committer_name
str
default:"''"
Name of the committer
body
str
required
The comment body text
issue_number
str
required
The issue number (IID) to comment on
assignee_ids
str
default:"''"
Comma-separated list of assignee ids
due_date
AcceptsTimestamp
default:"''"
Due date in YYYY-MM-DD format
issue_body
str
default:"''"
New body/description for the issue (supports Markdown)
labels
str
default:"''"
Comma-separated list of labels
state
str
default:"''"
Filter issues by state One of: all, close, closed, opened, reopen
title
str
required
Title of the issue
project_id
str
required
The project ID (optional, can be used instead of project_owner and project_name)
tag_name
str
required
The name of the Git tag this release will be created for (e.g., v1.2.3). This tag must exist in the repository or be created beforehand.
description
str
default:"''"
A short project description (max 500 characters)
milestones
str
default:"''"
Comma-separated list of milestone titles assigned to the release
name
str
default:"''"
The release title. If omitted, it defaults to the Tag name.
release_project_id
str
required
The project ID (optional, can be used instead of project_owner and project_name)
released_at
AcceptsTimestamp
default:"''"
Date and time the release was made, in ISO 8601 format (e.g., 2025-11-19T10:00:00Z)
ref
str
default:"'main'"
Branch, tag, or commit SHA to read from, default is main
limit
int
default:"10"
Maximum number of files to return (used only if Return All is OFF)
list_file_path
str
required
The path to list files in the repository (required)
page
int
default:"1"
Page of results to display
order_by
str
default:"''"
Field to sort results by One of: created_at, due_date, name, released_at, title, updated_at
sort
str
default:"''"
Order of sorting (asc for ascending, desc for descending) One of: asc, desc
lock_reason
str
default:"''"
Optional message recorded before locking the issue One of: Duplicate, Off-topic, Other, Resolved, Spam, Too heated
creator_username
str
default:"''"
Filter issues by creator username
issue_assignee_username
str
default:"''"
Filter issues by assignee username
Filter issues by title or description matching the search term
updated_after
AcceptsTimestamp
default:"''"
Filter issues updated after a specific date/time (ISO 8601 format)
namespace_id
str
default:"''"
The ID of the group or user namespace where the project should be created. If not specified, it defaults to the authenticated user’s personal namespace
path
str
default:"''"
Project slug (the URL path). If not provided, it’s generated from the name
repository_name
str
required
Project name
visibility
str
default:"'private'"
Visibility level of the project. Can be public, internal, or private. Default is private One of: internal, private, public

integration_gmail — Gmail

Gmail
pipeline.add(name="node").integration_gmail(integration=..., num_messages=0, format="full", recipients="...")
Parameters
action
str
default:"''"
Select the action to perform
use_date
bool
default:"False"
Toggle to use dates
use_exact_date
bool
default:"False"
Switch between exact date range and relative dates
query
str
default:"''"
Raw query string to use directly. If provided, overrides all other query parameters.
bcc
str
default:"''"
Blind carbon copy recipients. These addresses are hidden from other recipients (comma-separated)
body
str
default:"''"
The body of the email
category
str
default:"''"
Filter by tab (e.g. Primary, Social)
cc
str
default:"''"
Carbon copy recipients who will receive a visible copy of the email (comma-separated)
detailed_view
bool
default:"False"
Include full draft details in the response
filename
str
default:"''"
Find attachments by name or type
from_
str
default:"''"
has
str
default:"''"
Filter by feature (e.g. attachment, drive)
has_attachment
str
default:"'Ignore'"
Only emails with attachments One of: Ignore, false, true
has_images
str
default:"'Ignore'"
Emails containing images One of: Ignore, false, true
Emails containing links One of: Ignore, false, true
has_starred
str
default:"'Ignore'"
Only starred emails One of: Ignore, false, true
has_unread
str
default:"'Ignore'"
Only unread emails One of: Ignore, false, true
has_user_labels
str
default:"'Ignore'"
Emails with custom labels One of: Ignore, false, true
in_
str
default:"''"
include_spam_trash
str
default:"False"
Include spam and trash emails One of: Ignore, false, true
integration
AcceptsIntegration
required
Connect to your account
is_
str
default:"''"
label
str
default:"''"
Search emails with this label
label_ids
str
default:"''"
Emails with all listed label IDs
larger
str
default:"''"
Emails larger than this size (e.g. 5M)
list
str
default:"''"
Emails from this mailing list
newer_than
str
default:"''"
Emails newer than a time (e.g. 7d, 2m)
num_messages
int
required
Specify the last n number of emails
older_than
str
default:"''"
Emails older than a time (e.g. 7d, 2m)
page_token
str
default:"''"
Use to fetch next page of results
smaller
str
default:"''"
Emails smaller than this size (e.g. 5M)
subject
str
default:"''"
The subject of the email
to
str
default:"''"
Emails sent to this address
has_chat
str
default:"'Ignore'"
Only chat threads One of: Ignore, false, true
has_important
str
default:"'Ignore'"
Only important threads One of: Ignore, false, true
read_status
str
default:"'all'"
Filter by read status One of: all, read, unread
received_after
AcceptsTimestamp
default:"''"
RFC3339 timestamp (e.g. 2023-01-01T00:00:00Z)
received_before
AcceptsTimestamp
default:"''"
RFC3339 timestamp (e.g. 2023-12-31T23:59:59Z)
custom_params
str
default:"''"
Extra filters as raw query
msg_id
str
default:"''"
Search by message ID (ignores other filters)
projection
str
default:"''"
Select which fields to return
attachments
AcceptsFileList
default:"[]"
Attachments to be appended.
format
str
required
Either html (to allow html content) or text (for plaintext content - default) One of: full, html, metadata, minimal, raw, text
recipients
str
required
A single email or a comma-separated list of the recipients’ emails, example: john@company.com, alex@company.com
reply_to
str
default:"''"
Alternative email address where replies should be sent instead of the sender’s address
reply_to_sender_only
bool
default:"False"
When enabled, ensures that replies go only to the sender, excluding CC or group recipients
sender_name
str
default:"''"
Custom name to display as the sender in the recipient’s inbox
email_id
str
required
The ID of the email (often used in conjunction with a trigger where the email ID is received from the trigger)
thread_id
str
required
The ID of the thread to read
label_list_visibility
str
required
The visibility of the label in the label list One of: labelHide, labelShow, labelShowIfUnread
message_list_visibility
str
required
The visibility of messages with this label One of: hide, show
name
str
required
The name of the label to create
message_id
str
required
The ID of the message to read
draft_id
str
required
The ID of the draft to read
label_id
str
required
The ID of the label to read, example: Label_1, Label_2
draft_message_id
str
required
The ID of the draft message to trash
date_range
dict
default:"{}"
exact_date
dict
default:"{}"

integration_gohighlevel — GoHighLevel

GoHighLevel
pipeline.add(name="node").integration_gohighlevel(integration=...)
Parameters
action
str
default:"''"
Select the action to perform One of: create_contact, create_opportunity
email
str
default:"''"
Email address of the contact
first_name
str
default:"''"
First name of the contact
integration
AcceptsIntegration
required
Connect to your account
last_name
str
default:"''"
Last name of the contact
phone
str
default:"''"
Phone number of the contact
contact_name
str
default:"''"
Name of the existing contact to link to the opportunity. One contact can only be linked to one opportunity.
name
str
default:"''"
Name of the opportunity
pipeline_name
str
default:"''"
Name of the existing pipeline to link to the opportunity
status
str
default:"''"
Status of the opportunity (must be one of: ‘open’, ‘won’, ‘lost’, ‘abandoned’)
value
str
default:"''"
Money value of the opportunity

integration_google_ads — Google Ads

Google Ads
pipeline.add(name="node").integration_google_ads(customer_id="...", integration=..., num_messages=0, campaign_id="...")
Parameters
action
str
default:"''"
Select the action to perform One of: get_campaigns, read_campaign
use_date
bool
default:"False"
Toggle to use dates
use_exact_date
bool
default:"False"
Switch between exact date range and relative dates
campaign_status
str
default:"''"
Filter by campaign status (ENABLED, PAUSED, REMOVED)
campaign_type
str
default:"''"
Filter by campaign type (SEARCH, DISPLAY, VIDEO, etc.)
customer_id
str
required
The Google Ads customer account
integration
AcceptsIntegration
required
Connect to your account
num_messages
int
required
Specify the number of campaigns to fetch
campaign_id
str
required
The campaign to retrieve details for
date_range
dict
default:"{}"
pick the relative date range
exact_date
dict
default:"{}"
Pick the start and end dates

integration_google_analytics — Google Analytics

Google Analytics
pipeline.add(name="node").integration_google_analytics(integration=..., num_messages=0, property_id="...")
Parameters
action
str
default:"''"
Select the action to perform One of: read_ga4_report
use_date
bool
default:"False"
Toggle to use dates
use_exact_date
bool
default:"False"
Switch between exact date range and relative dates
currency_code
str
default:"'USD'"
Currency code for monetary metrics
dimensions
str
default:"''"
Comma-separated list of dimensions (e.g., date,country)
integration
AcceptsIntegration
required
Connect to your Google Analytics account
keep_empty_rows
bool
default:"False"
Include rows with all zero metrics
metric_aggregations
str
default:"''"
List of metric aggregations to apply One of: MAXIMUM, MINIMUM, TOTAL
metrics
str
default:"''"
Comma-separated list of metrics (e.g., totalUsers,sessions)
num_messages
int
required
Specify the number of results to fetch
order_by
str
default:"''"
Order by configuration for results
property_id
str
required
Enter the GA4 property
return_all
bool
default:"False"
Return all results instead of limiting
return_property_quota
bool
default:"False"
Return property quota usage
simple
bool
default:"True"
Return simplified output format
date_range
dict
default:"{}"
pick the relative date range
exact_date
dict
default:"{}"
Pick the start and end dates

integration_google_big_query — Google BigQuery

Google BigQuery
pipeline.add(name="node").integration_google_big_query(bigquery_table_id="...", dataset_id="...", integration=..., project_id="...")
Parameters
action
str
default:"''"
Select the action to perform One of: execute_query, insert_rows
endpoint_0
str
One of: [endpoint_0.&lt;A&gt;]
bigquery_table_id
str
required
The ID of the table to insert data into
dataset_id
str
required
The ID of the dataset containing the table
ignore_unknown_values
bool
default:"False"
Ignore values that do not match the table schema
integration
AcceptsIntegration
required
Connect to your account
project_id
str
required
The Google Cloud project ID
skip_invalid_rows
bool
default:"False"
Skip rows that contain invalid data
query
str
required
SQL query to execute
dry_run
bool
default:"False"
Validate query without executing
timeout_ms
int
default:"30000"
Query timeout in milliseconds
use_legacy_sql
bool
default:"False"
Use Legacy SQL syntax

integration_google_calendar — Google Calendar

Google Calendar
pipeline.add(name="node").integration_google_calendar(integration=..., num_messages=0, end_date_and_time=..., start_date_and_time=...)
Parameters
action
str
default:"''"
Select the action to perform One of: check_availability, delete_event, get_events, new_event, read_event, update_event
use_date
bool
default:"False"
Toggle to use dates
use_exact_date
bool
default:"False"
Switch between exact date range and relative dates
query
str
default:"''"
Return only events that contain these keywords
calendar
str
Select the calendar to add the new event to
integration
AcceptsIntegration
required
Connect to your account
num_messages
int
required
Specify the last n numbers of events
end_date_and_time
AcceptsTimestamp
required
The last date and end time for everyday to look for availability
slot_duration
int
default:"30"
The duration of an individual slot to look for (in minutes). Default: 30 (in minutes)
start_date_and_time
AcceptsTimestamp
required
The first date and start time for everyday to look for availability
timezone
str
required
IANA Time Zone (e.g., US/Eastern). The available time slots in the output will be returned in this timezone.
all_day_event
bool
default:"False"
Toggle to set the event as an all-day event
attendees
str
default:"''"
Email IDs of attendees (comma separated)
description
str
default:"''"
The description of the event
duration
int
default:"30"
The duration of the event (positive integer). Default: 30 (in minutes)
event_name
str
required
The name of the calendar event
location
str
default:"''"
Physical location or the meeting location (like Zoom)
repeat_frequency
str
default:"''"
How often the event repeats (leave empty for non-recurring events) One of: daily, monthly, weekly, yearly
repeat_how_many_times
int
default:"0"
Number of times the event should repeat (use either this or Repeat Until, not both)
repeat_until
AcceptsTimestamp
default:"-1"
End date for the recurring event (use either this or Repeat How Many Times, not both)
rrule
str
default:"''"
Advanced: Custom recurrence rule (overrides Repeat Frequency, Repeat How Many Times, and Repeat Until if set). Format: RFC 5545
start_datetime
AcceptsTimestamp
required
The start time of the calendar event (format: YYYY-MM-DD for full day event or YYYY-MM-DDTHH:MM:SS for specific time)
event_id
str
required
The ID of the event to read
send_updates
str
default:"'none'"
Whether to send notifications about the update to attendees One of: all, externalOnly, none
end_time
AcceptsTimestamp
default:"-1"
New end time for the event (RFC3339 format)
send_notifications
bool
default:"False"
Whether to send notifications about the changes
start_time
AcceptsTimestamp
default:"-1"
New start time for the event (RFC3339 format)
update_attendees
str
default:"''"
New attendee list (comma-separated emails)
update_color_id
str
default:"''"
New color ID for the event (1-11)
update_description
str
default:"''"
New description for the event
update_guests_can_invite_others
bool
default:"False"
Whether guests can invite other attendees
update_guests_can_modify
bool
default:"False"
Whether guests can modify the event
update_guests_can_see_other_guests
bool
default:"False"
Whether guests can see other attendees
update_location
str
default:"''"
New location for the event
update_max_attendees
int
default:"0"
Maximum number of attendees
update_show_me_as
str
default:"''"
How to show the time slot (opaque=busy, transparent=free) One of: opaque, transparent
update_summary
str
default:"''"
New title/summary for the event
update_visibility
str
default:"''"
New visibility setting for the event One of: default, private, public
date_range
dict
default:"{}"
exact_date
dict
default:"{}"

integration_google_chat — Integration Google Chat

Integrate with Google Chat to send messages, manage spaces, and handle memberships
pipeline.add(name="node").integration_google_chat(integration=..., message_id="...", message_text="...", space_id="...")
Parameters
action
str
default:"''"
Select the action to perform One of: delete_message, get_memberships, get_spaces, read_membership, read_message, read_space, send_message, update_message
integration
AcceptsIntegration
required
Connect to your account
message_id
str
required
The ID of the message to delete
message_text
str
required
The text of the message
space_id
str
required
The ID of the space
update_mask
str
default:"''"
Update mask for the message
membership_id
str
required
The ID of the membership
thread_key
str
default:"''"
Thread key for threaded messages
page_size
str
default:"''"
The number of memberships to return
filter
str
default:"''"
Filter for spaces

integration_google_cloud_firestore — Google Cloud Firestore

Google Cloud Firestore
pipeline.add(name="node").integration_google_cloud_firestore(collection="...", database="...", fields="...", integration=...)
Parameters
action
str
default:"''"
Select the action to perform One of: create_document, delete_document, get_collections, get_documents, query_documents, read_document, upsert_document
collection
str
required
The collection name where the document will be created
database
str
required
The Firestore database name. Leave as (default) for the default database
fields
str
required
JSON object containing the document fields
integration
AcceptsIntegration
required
Connect to your account
project_id
str
required
The Google Cloud project ID
update_key
str
required
The field name in the document that contains the document ID
document_id
str
default:"''"
Optional document ID. If not provided, Firestore will generate one automatically
limit
int
required
Maximum number of documents to retrieve
query
str
required
Firestore query in JSON format

integration_google_cloud_storage — Google Cloud Storage

Google Cloud Storage
pipeline.add(name="node").integration_google_cloud_storage(bucket_name="...", file=..., integration=..., object_name="...")
Parameters
action
str
default:"''"
Select the action to perform
bucket_name
str
required
Enter the name of the bucket to create
cache_control
str
default:"''"
Cache control directives
content_disposition
str
default:"''"
How the object should be displayed
content_encoding
str
default:"''"
Content encoding of the object
content_language
str
default:"''"
Language of the content
file
AcceptsFile
required
Select a file to upload
integration
AcceptsIntegration
required
Connect to your account
metadata
str
default:"''"
Custom metadata for the object (JSON format)
object_name
str
required
Enter the name for the object
project_id
str
Select your Google Cloud Project
cors
str
default:"''"
Cross-Origin Resource Sharing configuration (JSON format)
lifecycle
str
default:"''"
Object lifecycle management rules (JSON format)
location
str
default:"''"
Enter the location for the bucket (e.g., US, EU, ASIA)
storage_class
str
default:"'STANDARD'"
Select the storage class for the bucket One of: ARCHIVE, COLDLINE, NEARLINE, STANDARD
uniform_bucket_level_access
bool
default:"False"
Enable uniform bucket-level access
versioning
bool
default:"False"
Enable object versioning for this bucket
generation
int
default:"0"
Specify object generation for versioned buckets
delimiter
str
default:"''"
Delimiter for directory-like listing
include_versions
bool
default:"False"
Include all versions of objects
limit
int
required
Maximum number of buckets to return
prefix
str
default:"''"
Filter results to buckets whose names begin with this prefix
projection
str
default:"'noAcl'"
Select the level of detail to return One of: full, noAcl
alt
str
default:"''"
Alternative representation (json for metadata, media for content)
download_content
bool
default:"False"
Download file content instead of metadata
encryption_key
str
default:"''"
Customer-supplied encryption key (base64 encoded)
encryption_key_sha
str
default:"''"
SHA256 hash of the encryption key (base64 encoded)
content_type
str
default:"''"
MIME type of the object
encryption
str
default:"''"
Default encryption configuration (JSON format)
labels
str
default:"''"
Labels to apply to the bucket (JSON format)
logging
str
default:"''"
Access logging configuration (JSON format)
website
str
default:"''"
Static website hosting configuration (JSON format)

integration_google_contacts — Google Contacts

Google Contacts
pipeline.add(name="node").integration_google_contacts(integration=..., contact_id="...")
Parameters
action
str
default:"''"
Select the action to perform One of: create_contact, delete_contact, get_contacts, read_contact, update_contact
email
str
default:"''"
Email address of the contact
family_name
str
default:"''"
Last name of the contact
given_name
str
default:"''"
First name of the contact
integration
AcceptsIntegration
required
Connect to your account
organization
str
default:"''"
Organization name of the contact
phone
str
default:"''"
Phone number of the contact
contact_id
str
required
Google Contacts resource ID to delete
query
str
default:"''"
Search query to filter contacts
limit
str
default:"''"
Maximum number of contacts to retrieve

integration_google_docs — Google Docs

Google Docs
pipeline.add(name="node").integration_google_docs(integration=..., limit=0, text="...", file_id="...")
Parameters
action
str
default:"''"
Select the action to perform
use_date
bool
default:"False"
Toggle to use dates
use_exact_date
bool
default:"False"
Switch between exact date range and relative dates
query
str
default:"''"
Search query to filter documents by name
folder_id
str
default:"''"
ID of the folder to search in (optional)
integration
AcceptsIntegration
required
Connect to your Google Docs account
limit
int
required
Specify the number of documents to fetch
order_by
str
default:"'modifiedTime desc'"
How to order the results
shared_with_me
bool
default:"False"
Include documents shared with me
text
str
required
The text that will be added to the File
file_id
str
required
Select a File to read
content
str
default:"''"
Initial content for the document (optional)
title
str
default:"''"
Title of the document
doc_url
str
required
Enter the public URL of the Google Doc
operation
str
default:"'replace'"
How to handle the content (replace, append, prepend) One of: prepend, replace
date_range
dict
default:"{}"
pick the relative date range
exact_date
dict
default:"{}"
Pick the start and end dates

integration_google_drive — Google Drive

Google Drive
pipeline.add(name="node").integration_google_drive(integration=..., num_messages=0, file_id="...", role="commenter")
Parameters
action
str
default:"''"
Select the action to perform
use_date
bool
default:"False"
Toggle to use dates
use_exact_date
bool
default:"False"
Switch between exact date range and relative dates
query
str
default:"''"
Search query for filtering files (see Drive API documentation for syntax)
corpora
str
default:"''"
Scope to search in: ‘user’ (files owned/shared to user) or ‘domain’ (files shared to user’s domain)
drive_id
str
default:"''"
ID of the shared drive to search
fields
str
default:"''"
Comma-separated list of fields to include in the response
include_items_from_all_drives
bool
default:"True"
Whether to include items from all drives, including shared drives
include_labels
str
default:"''"
Comma-separated list of label IDs to include in the response
include_permissions_for_view
str
default:"''"
Additional view’s permissions to include (only ‘published’ supported)
integration
AcceptsIntegration
required
Connect to your account
num_messages
int
required
Specify the number of files to fetch
order_by
str
default:"''"
Sort order for files (e.g., ‘folder,name,modifiedTime desc’)
recursive
bool
default:"False"
When enabled, fetches all files from nested folders recursively. Folders will be traversed and only files will be returned.
spaces
str
default:"''"
Comma-separated list of spaces to search (‘drive’, ‘appDataFolder’)
supports_all_drives
bool
default:"True"
Whether the application supports both My Drives and shared drives
domain
str
default:"''"
Domain for domain permissions
email_address
str
default:"''"
Email address for user/group permissions
email_message
str
default:"''"
Custom message for the notification email
file_id
str
required
Select the file to read
role
str
required
Role for the permission (reader, writer, commenter, owner) One of: commenter, owner, reader, writer
send_notification_email
bool
default:"False"
Whether to send notification email
type
str
required
Type of permission (user, group, domain, anyone) One of: anyone, domain, group, user
folder_id
str
default:"''"
Select the folder within your Google Drive to save the file
content
str
required
Text content for the file
description
str
default:"''"
Description for the file
name
str
default:"''"
Name of the file to create
parent_folder_id
str
default:"''"
Select the folder to create the file in
copy_requires_writer_permission
bool
default:"False"
Whether the copy requires writer permission
same_folder
bool
default:"False"
Keep the copy in the same folder as the original
folder_color
str
default:"''"
Color for the folder (hex code)
color_rgb
str
default:"''"
Color for the shared drive (hex code)
hidden
bool
default:"False"
Whether the shared drive is hidden
delete_permanently
bool
default:"False"
Whether to delete the file permanently or move to trash
limit
int
required
Maximum number of shared drives to return (when not returning all)
return_all
bool
default:"False"
Whether to return all shared drives or limit the results
use_domain_admin_access
bool
default:"False"
Whether to use domain admin access
drive_file_url
str
required
The URL of the drive file to read.
file
AcceptsFile
required
Select or Upload a file
change_file_content
bool
default:"False"
Whether to update the file content
content_type
str
default:"''"
MIME type of the file content One of: text/html, text/plain
file_data
str
default:"''"
New file content (when changing content)
file_name
str
default:"''"
New name for the file
starred
bool
default:"False"
Whether to star the file
trashed
bool
default:"False"
Whether to trash the file
date_range
dict
default:"{}"
exact_date
dict
default:"{}"

integration_google_firebase_realtime_db — Google Firebase Realtime DB

Google Firebase Realtime DB
pipeline.add(name="node").integration_google_firebase_realtime_db(data="...", database_url="...", integration=..., path="...")
Parameters
action
str
default:"''"
Select the action to perform One of: create_record, delete_record, push_to_list, read_record, update_record
data
str
required
The data to write (JSON format)
database_url
str
required
Your Firebase Realtime Database URL (e.g., https://your-project-id-default-rtdb.firebaseio.com)
integration
AcceptsIntegration
required
Connect to your account
path
str
required
The path where you want to create/write data
update_data
str
required
The fields to update (JSON format)

integration_google_perspective — Google Perspective

Google Perspective
pipeline.add(name="node").integration_google_perspective(comment="...", integration=..., requested_attributes="FLIRTATION")
Parameters
action
str
default:"''"
Select the action to perform One of: analyze_comment
comment
str
required
The text content to analyze for various attributes
integration
AcceptsIntegration
required
Connect to your account
language
str
default:"''"
Language code (e.g., en, es, fr). Leave empty for auto-detection
requested_attributes
str
required
Select which attribute to analyze One of: FLIRTATION, IDENTITY_ATTACK, INSULT, PROFANITY, SEVERE_TOXICITY, SEXUALLY_EXPLICIT, THREAT, TOXICITY
score_threshold
float
default:"''"
Optional threshold (0-1) to filter results. Only scores above this value will be flagged

integration_google_sheets — Google Sheets

Google Sheets
pipeline.add(name="node").integration_google_sheets(integration=..., spreadsheet_id="...", title="...", sheet_id="...")
Parameters
action
str
default:"''"
Select the action to perform
add_columns_manually
bool
default:"False"
Add data points for some columns manually instead of having them extracted by the AI model.
endpoint_0
str
One of: [endpoint_0.&lt;A&gt;]
endpoint_1
str
One of: [endpoint_1.&lt;B&gt;]
hidden
bool
default:"False"
Whether the sheet should be hidden
index
int
default:"0"
Position index of the sheet (0 for end)
integration
AcceptsIntegration
required
right_to_left
bool
default:"False"
Whether the sheet is RTL instead of LTR
sheet_id_number
int
default:"0"
Specific sheet ID number (must be unique, 0 for auto-generate)
spreadsheet_id
str
required
Select the Spreadsheet to create sheet in
tab_color
str
default:"''"
Hex color code for sheet tab (e.g., #ff0000)
title
str
required
Title/name of the new sheet
model
str
default:"'gpt-4o'"
The model to use for the Google Sheets integration
additional_context
str
default:"''"
Additional context for the AI model to extract the table.
extract_multiple_rows
bool
default:"True"
If checked, it will extract multiple rows of data. If unchecked, it will extract a single row.
provider
str
default:"'openai'"
The provider to use for the Google Sheets integration
sheet_id
str
required
Select the Sheet to read from
text_for_extraction
str
required
The text to extract the table from
manual_columns
ListType | list[ColumnEntry] | list[List[Dict[str, Any]]]
default:"[]"
Pass in data to column names manually.
sheet_url
str
required
Enter the URL of your Google Spreadsheet
keep_first_row
bool
default:"False"
Whether to preserve the first row (only for whole sheet clearing)
range
str
default:"''"
Optional: Specify a range (e.g., A1:D10). Leave empty to read entire sheet
auto_recalc
str
default:"'ON_CHANGE'"
Frequency at which formulas should automatically recalculate One of: HOUR, MINUTE, ON_CHANGE
locale
str
default:"''"
Locale (e.g., en_US)
sheets
str
default:"''"
Comma (,) separated list of sheet names
num_columns
int
default:"''"
Number of columns to delete (required when deleting columns)
num_rows
int
default:"''"
Number of rows to delete (required when deleting rows)
start_column
str
default:"''"
Starting column letter (required when deleting columns)
start_row
int
default:"''"
Starting row number (required when deleting rows)
spreadsheet_url
str
required
Enter or map the full URL of the Google Spreadsheet to be deleted
combine_filters
str
default:"'OR'"
How to combine filter conditions One of: AND, OR
return_first_match
bool
default:"False"
Whether to return only the first matching row
condition
str
default:"''"
Conditional Operator

integration_google_slides — Google Slides

Google Slides
pipeline.add(name="node").integration_google_slides(integration=..., page_object_id="...", presentation_id="...", title="...")
Parameters
action
str
default:"''"
Select the action to perform One of: create_presentation, get_slides, read_page, read_presentation, read_thumbnail, replace_text
integration
AcceptsIntegration
required
Connect to your account
page_object_id
str
required
The object ID of the page/slide to read
presentation_id
str
required
Select a presentation to read
mime_type
str
default:"'PNG'"
Format of the thumbnail One of: JPG, PNG
thumbnail_size
str
default:"'MEDIUM'"
Size of the thumbnail One of: LARGE, MEDIUM, SMALL
title
str
required
Title for the new presentation (defaults to ‘Untitled Presentation’)
contains_text
str
default:"''"
The text to search for and replace
match_case
bool
default:"False"
Whether to match case when searching
replace_text
str
default:"''"
The text to replace with
revision_id
str
default:"''"
The revision ID of the presentation for version control. If specified, the request will only succeed if the presentation’s current revision ID matches this value. Leave empty to apply changes without revision checking.

integration_google_tasks — Google Tasks

Google Tasks
pipeline.add(name="node").integration_google_tasks(integration=..., task_list_id="...", task_id="...")
Parameters
action
str
default:"''"
Select the action to perform One of: add_task, delete_task, get_tasks, read_task, update_task
due
AcceptsTimestamp
default:"''"
Due date
integration
AcceptsIntegration
required
Connect to your Google Tasks account
notes
str
default:"''"
Task notes
task_list_id
str
required
Select the task list
title
str
default:"''"
Task title
task_id
str
required
Select the task to delete
status
str
default:"'needsAction'"
Task status One of: completed, needsAction
completed_max
AcceptsTimestamp
default:"''"
Maximum completion time
completed_min
AcceptsTimestamp
default:"''"
Minimum completion time
due_max
AcceptsTimestamp
default:"''"
Maximum due date
due_min
AcceptsTimestamp
default:"''"
Minimum due date
max_results
int
default:"100"
Maximum number of tasks to return
show_completed
bool
default:"False"
Include completed tasks
show_deleted
bool
default:"False"
Include deleted tasks
show_hidden
bool
default:"False"
Include hidden tasks
updated_min
AcceptsTimestamp
default:"''"
Minimum update time

integration_google_workspace_admin — Google Workspace Admin

Google Workspace Admin
pipeline.add(name="node").integration_google_workspace_admin(integration=..., group_id="...", user_id="...", device_action="deprovision")
Parameters
action
str
default:"''"
Select the action to perform
change_password_at_next_login
bool
default:"False"
Force user to change password on next login
first_name
str
default:"''"
The first name of the user
integration
AcceptsIntegration
required
Connect to your account
last_name
str
default:"''"
The last name of the user
org_unit_path
str
default:"''"
Filter by organizational unit path
password
str
default:"''"
The password for the user
primary_email
str
default:"''"
The primary email address of the user
group_id
str
required
The unique identifier or email of the group
role
str
default:"'member'"
The role of the user in the group One of: manager, member, owner
user_id
str
required
The unique identifier or email of the user to delete
deprovision_reason
str
default:"''"
Provide a reason for deprovisioning (only required if the Device Action is set to ‘Deprovision’)
device_action
str
required
The action to perform on the device One of: deprovision, disable, reenable
device_id
str
required
The unique identifier of the ChromeOS device
description
str
default:"''"
The description of the group
group_email
str
default:"''"
The email address of the group
group_name
str
default:"''"
The name of the group
query
str
default:"''"
Raw query string for advanced filtering
asset_id
str
default:"''"
Filter by asset ID
ethernet_mac
str
default:"''"
Filter by Ethernet MAC address (no colons)
include_child_orgunits
bool
default:"False"
Include devices from child organizational units
location
str
default:"''"
Filter by annotated location
max_results
int
required
Maximum number of results to return (1-200)
notes
str
default:"''"
Filter by device notes
order_by
str
default:"''"
Field to order results by
projection
str
default:"'basic'"
What subset of fields to fetch One of: basic, full
register_date
str
default:"''"
Filter by registration date (YYYY-MM-DD)
serial_number
str
default:"''"
Filter by serial number (partial search, min 3 chars)
sort_order
str
default:"''"
Sort order for results One of: ascending, descending
status
str
default:"''"
Filter by device status One of: deprovisioned, disabled, provisioned
sync_date
str
default:"''"
Filter by last sync date (YYYY-MM-DD)
user
str
default:"''"
Filter by annotated user
wifi_mac
str
default:"''"
Filter by WiFi MAC address (no colons)
domain
str
default:"''"
The domain name to filter users
search_group_email
str
default:"''"
Search by group email
search_group_name
str
default:"''"
Search by group name
user_key
str
default:"''"
Filter groups by user membership
email
str
default:"''"
Search by email address
email_prefix
str
default:"''"
Search by email prefix (e.g., admin*)
family_name
str
default:"''"
Search by last name
given_name
str
default:"''"
Search by first name
is_admin
bool
default:"False"
Filter by admin status
is_archived
bool
default:"False"
Filter by archived status
is_delegated_admin
bool
default:"False"
Filter by delegated admin status
is_suspended
bool
default:"False"
Filter by suspension status
name
str
default:"''"
Search by name (given name, family name, or email)
show_deleted
bool
default:"False"
Include deleted users in results
view_type
str
default:"''"
View type for results One of: admin_view, domain_public
annotated_asset_id
str
default:"''"
The new annotated asset ID
annotated_location
str
default:"''"
The new annotated location
annotated_user
str
default:"''"
The new annotated user
suspended
bool
default:"False"
Whether to suspend the user

integration_hubspot — Hubspot

Hubspot
pipeline.add(name="node").integration_hubspot(integration=..., num_messages=0, create_ticket_name="...", create_ticket_pipeline_id="...")
Parameters
action
str
default:"''"
Select the action to perform
use_date
bool
default:"False"
Toggle to use dates
use_exact_date
bool
default:"False"
Switch between exact date range and relative dates
query
str
default:"''"
General search query
annual_revenue
int | str
default:"''"
Annual revenue
city
str
default:"''"
City of residence
country
str
default:"''"
Country name
created_date
str
default:"''"
Filter by creation date (ISO 8601 format)
domain
str
default:"''"
Search by domain
founded_year
str
default:"''"
Filter by founded year
hs_analytics_source
str
default:"''"
Filter by original source
hs_analytics_source_data_1
str
default:"''"
Filter by source data 1
hs_analytics_source_data_2
str
default:"''"
Filter by source data 2
hubspot_owner_id
str
default:"''"
Filter by contact owner ID
industry
str
default:"''"
Type of industry
integration
AcceptsIntegration
required
Connect to your account
is_public
bool
default:"False"
Filter by public company status
last_modified_date
str
default:"''"
Filter by last modified date (ISO 8601 format)
lead_status
str
default:"''"
Filter by lead status One of: ATTEMPTED_TO_CONTACT, BAD_TIMING, CONNECTED, IN_PROGRESS, NEW, OPEN, OPEN_DEAL, UNQUALIFIED
lifecycle_stage
str
default:"''"
Filter by lifecycle stage
name
str
default:"''"
Search by company name
num_messages
int
required
Specify the number of contacts to fetch
number_of_employees
int | str
default:"''"
Employee count
phone
str
default:"''"
Search by phone number
properties
str
default:"''"
Comma-separated properties to fetch
sort_by
str
default:"''"
Field to sort by
sort_order
str
default:"''"
Sort order (asc/desc)
state
str
default:"''"
Search by state
type
str
default:"''"
Filter by company type
web_technologies
str
default:"''"
Filter by web technologies
zip
str
default:"''"
Search by zip code
company_name
str
default:"''"
Search by company name
email
str
default:"''"
Search by email address
first_name
str
default:"''"
Contact’s first name
hs_latest_source
str
default:"''"
Filter by latest source
hs_lead_status
str
default:"''"
Filter by HubSpot lead status
job_title
str
default:"''"
Job title of the contact
last_name
str
default:"''"
Contact’s last name
website
str
default:"''"
Search by website
amount
int | str
default:"''"
Deal amount
close_date
str
default:"''"
Deal close date (ISO 8601 format)
deal_currency_code
str
default:"''"
Filter by currency code
deal_name
str
default:"''"
Deal name
deal_stage
str
default:"''"
Filter by deal stage
deal_type
str
default:"''"
Deal type
hs_date_entered_closed_lost
str
default:"''"
Filter by date entered closed lost (ISO 8601 format)
hs_date_entered_closed_won
str
default:"''"
Filter by date entered closed won (ISO 8601 format)
hs_deal_stage_probability
str
default:"''"
Filter by deal probability
hs_forecast_amount
str
default:"''"
Filter by forecast amount
hs_is_closed
bool
default:"False"
Filter by closed status
hs_is_deal_split
bool
default:"False"
Filter by deal split status
num_associated_contacts
str
default:"''"
Filter by number of associated contacts
num_contacted_notes
str
default:"''"
Filter by number of contact notes
pipeline
str
default:"''"
Pipeline ID
company_id
str
default:"''"
Filter by associated company ID
contact_id
str
default:"''"
Filter by associated contact ID
deal_id
str
default:"''"
Filter by associated deal ID
engagement_type
str
default:"''"
Filter by engagement type (CALL, EMAIL, MEETING, TASK) One of: CALL, EMAIL, MEETING, TASK
hs_activity_type
str
default:"''"
Filter by activity type
hs_communication_channel_type
str
default:"''"
Filter by communication channel type
hs_communication_logged_from
str
default:"''"
Filter by where engagement was logged from
timestamp
str
default:"''"
Engagement timestamp (ISO 8601 format)
closed_date
str
default:"''"
Filter by closed date (ISO 8601 format)
first_agent_reply_date
str
default:"''"
Filter by first agent reply date (ISO 8601 format)
hs_num_times_contacted
str
default:"''"
Filter by number of times contacted
hs_pipeline
str
default:"''"
Filter by pipeline
hs_pipeline_stage
str
default:"''"
Filter by pipeline stage
hs_resolution
str
default:"''"
Filter by ticket resolution
hs_ticket_category
str
default:"''"
Filter by ticket category
hs_ticket_priority
str
default:"''"
Filter by ticket priority
hs_time_to_close
str
default:"''"
Filter by time to close (milliseconds)
hs_time_to_first_agent_reply
str
default:"''"
Filter by time to first agent reply
source_type
str
default:"''"
Filter by source type
subject
str
default:"''"
Search by ticket subject
tags
str
default:"''"
Filter by tags (comma-separated)
associated_company_ids
str
default:"''"
Associated companies
associated_contact_ids
str
default:"''"
Associated contacts
category
str
default:"''"
Ticket category
create_ticket_name
str
required
Ticket subject (required)
create_ticket_pipeline_id
str
required
Pipeline ID (required)
create_ticket_stage_id
str
required
Stage ID (required)
description
str
default:"''"
Company description
priority
str
default:"''"
Priority level
ticket_owner_id
str
default:"''"
Ticket owner ID
contact_ids
str
default:"''"
Comma-separated contact IDs
list_id
str
required
HubSpot list ID (required)
by
str
default:"'email'"
Method to identify contacts: email or Contact ID One of: email, id
emails
str
default:"''"
Comma-separated email addresses (e.g., email1@example.com,email2@example.com)
about_us
str
default:"''"
About the company
company_domain_name
str
default:"''"
Company’s domain name
company_owner
str
default:"''"
Owner’s user ID
country_region
str
default:"''"
Country or region
create_company_name
str
required
Required company name
lifecycle
str
default:"'subscriber'"
Lifecycle stage
phone_number
str
default:"''"
Main phone number
website_url
str
default:"''"
Contact’s website
associated_company_id
str
default:"''"
ID of associated company
company
str
default:"''"
Name of the company
create_email
str
required
Required contact email
custom_properties
str
default:"''"
Custom properties to add to the contact
mobile_phone_number
str
default:"''"
Mobile number
postal_code
str
default:"''"
Postal or ZIP code
state_region
str
default:"''"
State or region
street_address
str
default:"''"
Street address
associated_company
str
default:"''"
Associated company IDs
associated_vids
str
default:"''"
Associated contact IDs
create_deal_stage
str
required
Required deal stage ID
deal_owner
str
default:"''"
Deal owner ID
company_ids
str
default:"''"
Comma-separated company IDs
create_engagement_type
str
required
Select Engagement type (required)
deal_ids
str
default:"''"
Comma-separated deal IDs
metadata
str
default:"''"
Type-specific metadata (JSON)
owner_id
str
default:"''"
Engagement owner ID
delete_company_id
str
required
HubSpot company ID to delete (required)
delete_contact_id
str
required
HubSpot contact ID to delete (required)
delete_deal_id
str
required
HubSpot deal ID to delete (required)
delete_engagement_id
str
required
HubSpot engagement ID to delete (required)
delete_ticket_id
str
required
HubSpot ticket ID to delete (required)
include_merge_audits
bool
default:"False"
Include merge history if true
read_company_id
str
required
HubSpot company ID to read (required)
read_contact_id
str
required
HubSpot contact ID to read (required)
show_list_memberships
bool
default:"False"
Include list memberships
include_property_versions
bool
default:"False"
Include property history if true
read_deal_id
str
required
HubSpot deal ID to read (required)
read_engagement_id
str
required
HubSpot engagement ID to read (required)
read_ticket_id
str
required
HubSpot ticket ID to read (required)
update_about_us
str
default:"''"
About the company
update_annual_revenue
int
default:"0"
Annual revenue
update_city
str
default:"''"
City of residence
update_company_domain_name
str
default:"''"
Company domain
update_company_id
str
required
HubSpot company ID to update (required)
update_company_name
str
default:"''"
Company name
update_company_owner
str
default:"''"
Owner’s user ID
update_country_region
str
default:"''"
Country or region
update_description
str
default:"''"
Company description
update_industry
str
default:"'ACCOUNTING'"
Type of industry
update_lead_status
str
default:"'NEW'"
Lead status
update_lifecycle
str
default:"'subscriber'"
Lifecycle stage
update_number_of_employees
int
default:"0"
Employee count
update_phone_number
str
default:"''"
Main phone number
update_website_url
str
default:"''"
Contact’s website
update_company
str
default:"''"
Name of the company
update_contact_id
str
required
HubSpot contact ID to update (required)
update_country
str
default:"''"
Country name
update_custom_properties
str
default:"''"
Custom properties to add to the contact
update_email
str
default:"''"
Contact email
update_first_name
str
default:"''"
Contact’s first name
update_job_title
str
default:"''"
Job title of the contact
update_last_name
str
default:"''"
Contact’s last name
update_mobile_phone_number
str
default:"''"
Mobile number
update_postal_code
str
default:"''"
Postal or ZIP code
update_state_region
str
default:"''"
State or region
update_street_address
str
default:"''"
Street address
update_amount
int
default:"0"
Deal amount
update_close_date
str
default:"''"
Deal close date (ISO 8601 format)
update_deal_id
str
required
HubSpot deal ID to update (required)
update_deal_name
str
default:"''"
Deal name
update_deal_owner
str
default:"''"
Deal owner ID
update_deal_stage
str
default:"''"
Deal stage ID
update_deal_type
str
default:"''"
Deal type
update_pipeline
str
default:"''"
Pipeline ID
update_category
str
default:"''"
Ticket category
update_priority
str
default:"''"
Priority level
update_stage_id
str
default:"''"
Stage ID
update_ticket_id
str
required
HubSpot ticket ID to update (required)
update_ticket_name
str
default:"''"
Ticket subject
update_ticket_owner_id
str
default:"''"
Ticket owner ID
date_range
dict
default:"{}"
pick the relative date range
exact_date
dict
default:"{}"
Pick the start and end dates

integration_intercom — Intercom

Intercom
pipeline.add(name="node").integration_intercom(id_value="...", identifier_type="email", integration=..., value="...")
Parameters
action
str
default:"''"
Select the action to perform
avatar
str
default:"''"
URL of the lead’s avatar image
companies
str
default:"''"
Select companies from dropdown, or enter company IDs comma-separated (e.g., company-1,company-2)
custom_attributes
str
default:"''"
Custom attributes as key:value pairs, comma-separated (e.g., plan:premium,tier:gold)
id_value
str
required
The email or user ID for the user
identifier_type
str
required
How to identify the user One of: email, user_id
integration
AcceptsIntegration
required
Connect to your Intercom account
name
str
default:"''"
The name of the company
phone
str
default:"''"
The phone number of the lead
session_count
int
default:"0"
Number of sessions the user has had
unsubscribed_from_emails
bool
default:"False"
Whether the lead has unsubscribed from emails
update_last_request_at
bool
default:"False"
Whether to update the last request timestamp
utm_campaign
str
default:"''"
UTM campaign parameter
utm_content
str
default:"''"
UTM content parameter
utm_medium
str
default:"''"
UTM medium parameter
utm_source
str
default:"''"
UTM source parameter
utm_term
str
default:"''"
UTM term parameter
company_id
str
default:"''"
The unique identifier for the company in your system
industry
str
default:"''"
The industry the company operates in
monthly_spend
int
default:"0"
The monthly revenue from this company
plan
str
default:"''"
The name of the plan the company is on
size
int
default:"0"
The number of employees
website
str
default:"''"
The company’s website URL
email
str
default:"''"
The email address of the lead
delete_by
str
default:"'id'"
How to identify the lead to delete
value
str
required
The value to search for based on the selected field
select_by
str
default:"'id'"
How to identify the company One of: company_id, email, id, name, phone, user_id
limit
int
default:"10"
Maximum number of companies to retrieve
list_by
str
default:"'id'"
How to identify the company One of: company_id, id
update_by
str
default:"'id'"
How to identify the lead to update One of: email, id, user_id
segment_id
str
default:"''"
Filter by segment ID (optional)
tag_id
str
default:"''"
Filter by tag ID (optional)

integration_jira — Jira

Jira
pipeline.add(name="node").integration_jira(comment_id="...", integration=..., issue_key="...", site="...")
Parameters
action
str
default:"''"
Select the action to perform
use_date
bool
default:"False"
Toggle to use dates
use_exact_date
bool
default:"False"
Switch between exact date range and relative dates
comment
str
default:"''"
Search in issue comments
comment_id
str
required
The ID of the comment to remove
expand
str
default:"''"
Additional information to include
integration
AcceptsIntegration
required
issue_key
str
required
The key of the issue to get changelog for
project
str
default:"''"
The name of the project
site
str
required
The name of the Jira site
use_wiki_markup
bool
default:"False"
Enable wiki markup parsing
file
AcceptsFile
required
File to attach to the issue
visibility_role
str
default:"''"
Restrict comment visibility to a project role (leave empty for public comment)
limit
int
required
Maximum number of changelog entries to return
assignee_name
str
default:"''"
Account Name of the user to assign the issue to
description
str
default:"''"
Detailed description of the issue
issue_type
str
default:"''"
Type of issue (e.g. Task, Bug, Story)
parent_issue_key
str
default:"''"
Parent Issue Key (for subtasks)
summary
str
required
A brief title or summary of the issue
download
bool
default:"False"
Whether to download the attachment content
delete_subtasks
bool
default:"False"
Whether to delete subtasks along with the issue
group_names
str
default:"''"
Comma-separated list of group names to notify
html_body
str
default:"''"
HTML body of the notification
notify_assignee
bool
default:"False"
Send notification to the issue assignee (note: Jira prevents self-notification, so this will fail if you are the assignee)
notify_reporter
bool
default:"False"
Send notification to the issue reporter (note: Jira prevents self-notification, so this will fail if you are the reporter)
notify_voters
bool
default:"False"
Send notification to issue voters (note: Jira prevents self-notification, so this will fail if you are the only voter)
notify_watchers
bool
default:"False"
Send notification to issue watchers (note: Jira prevents self-notification, so this will fail if you are the only watcher)
subject
str
default:"''"
Subject of the email notification
text_body
str
default:"''"
Plain text body of the notification
user_account_ids
str
default:"''"
Comma-separated list of user account IDs to notify
skip_remote_only_condition
bool
default:"False"
Include transitions with remote-only conditions
transition_id
str
default:"''"
ID of specific transition to get
update_assignee_name
str
default:"''"
Account Name of the user to assign the issue to
update_description
str
default:"''"
The new description for the issue
update_issue_type
str
default:"''"
Type of issue (e.g. Task, Bug, Story)
update_summary
str
default:"''"
The new summary for the issue
email_address
str
required
Email address of the user
notification
bool
default:"True"
If enabled, sends an invitation email to the user
text
str
default:"''"
Search in all text fields
query
str
default:"''"
The query to filter issues
affected_version
str
default:"''"
Filter by affected version
comment_exact
str
default:"''"
Match comment exactly
component
str
default:"''"
Filter by issue component
created
str
default:"''"
Issue creation (YYYY-MM-DD)
description_exact
str
default:"''"
Match description exactly
due
str
default:"''"
Due (YYYY-MM-DD)
fix_version
str
default:"''"
Filter by fix version
issue_summary
str
default:"''"
Search by issue summary
labels
str
default:"''"
Filter by issue labels
num_messages
int
default:"10"
Specify the number of issues to fetch
reporter_name
str
default:"''"
Account Name of the user who reported the issue
resolution
str
default:"''"
Filter by resolution status
resolved
str
default:"''"
Resolution (YYYY-MM-DD)
status
str
default:"''"
The status of the issue (e.g. Open, Closed, In Progress)
summary_exact
str
default:"''"
Match summary exactly
text_exact
str
default:"''"
Match text exactly across fields
updated
str
default:"''"
Last update (YYYY-MM-DD)
date_range
dict
default:"{}"
exact_date
dict
default:"{}"
attachment_id
str
required
The ID of the attachment to retrieve
account_id
str
required
The account ID of the user to retrieve

integration_linear — Linear

Linear
pipeline.add(name="node").integration_linear(integration=..., num_messages=0, issue_id="...", link="...")
Parameters
action
str
default:"''"
Select the action to perform One of: add_link, create_comment, create_new_issue, delete_issue, get_issue, list_issues, update_issue
use_date
bool
default:"False"
Toggle to use dates
use_exact_date
bool
default:"False"
Switch between exact date range and relative dates
assignee_id
str
default:"''"
Assign the issue to a user
integration
AcceptsIntegration
required
Connect to your account
num_messages
int
required
Specify the number of issues to fetch
priority
str
default:"''"
Issue priority One of: 0, 1, 2, 3, 4
return_all
bool
default:"False"
Return all matching issues regardless of count
state_id
str
default:"''"
Set the workflow state
team_id
str
default:"''"
The team within Linear
issue_id
str
required
The ID of the issue to update
The URL to attach to the issue
comment
str
required
The comment text
parent_id
str
default:"''"
ID of parent comment for replies (optional)
description
str
default:"''"
The description of the ticket
title
str
default:"''"
The title of the issue
update_team_id
str
default:"''"
Move to a different team
date_range
dict
default:"{}"
pick the relative date range
exact_date
dict
default:"{}"
Pick the start and end dates

integration_linkedin — Linkedin

Linkedin
pipeline.add(name="node").integration_linkedin(integration=...)
Parameters
action
str
default:"''"
Select the action to perform One of: create_text_share
integration
AcceptsIntegration
required
Connect to your account
post_text
str
default:"''"
Content you wanted to post on your LinkedIn

integration_mailchimp — Mailchimp

Mailchimp
pipeline.add(name="node").integration_mailchimp(integration=..., list_id="...", member_id="...", tags=...)
Parameters
action
str
default:"''"
Select the action to perform
integration
AcceptsIntegration
required
Connect to your Mailchimp account
list_id
str
required
Choose the list to get groups from
member_id
str
required
Choose the member to retrieve
tags
list[str]
required
List of tags to add to the member
email_address
str
default:"''"
Email address of the new member
first_name
str
default:"''"
First name of the member (optional)
last_name
str
default:"''"
Last name of the member (optional)
status
str
default:"''"
Filter campaigns by status
limit
int
required
Maximum number of campaigns to return
campaign_id
str
required
Choose the campaign to retrieve
type
str
default:"''"
Filter campaigns by type One of: “, absplit, plaintext, regular, rss, variate

integration_mailgun — Mailgun

Mailgun
pipeline.add(name="node").integration_mailgun(integration=...)
Parameters
action
str
default:"''"
Select the action to perform One of: add_contact_to_mailing_list, send_mail
email
str
default:"''"
The email of the contact to be added to the list
integration
AcceptsIntegration
required
Connect to your account
list_name
str
default:"''"
The list the contact will be added to
name
str
default:"''"
The name of contact to be added to the list
bcc_recipients
str
default:"''"
The email(s) of the recipient(s) you want to BCC the email to
body
str
default:"''"
The body (message) of the email
cc_recipients
str
default:"''"
The email(s) of the recipient(s) you want to CC the email to
domain
str
Your Mailgun domain
from_email
str
default:"''"
The email of the sender of the email
from_name
str
default:"''"
The name of the sender of the email
recipients
str
default:"''"
The email of the recipient you want to send the email to, example: john@company.com, alex@company.com
subject
str
default:"''"
The subject of the email

integration_microsoft — OneDrive

OneDrive
pipeline.add(name="node").integration_microsoft(file_content="...", file_name="...", folder_id="...", integration=...)
Parameters
action
str
default:"''"
Select the action to perform
content_type
str
default:"'text/plain'"
MIME type of the file
file_content
str
required
Content of the file
file_name
str
required
Name of the file to create
folder_id
str
required
ID of the folder where the file will be created
integration
AcceptsIntegration
required
Connect to your account
expiration_date
AcceptsTimestamp
default:"''"
Expiration date for the link (ISO 8601)
item_id
str
required
Select the folder within your OneDrive to add the file
Scope of link One of: anonymous, organization
Type of link One of: edit, embed, view
password
str
default:"''"
Password for the link (optional)
destination_folder_id
str
required
Select the destination folder
file_id
str
required
Select the file to read from OneDrive
new_name
str
default:"''"
New name for the copied file (optional)
folder_name
str
required
Name of the folder to create
parent_folder_id
str
required
Select the parent folder
item_type
str
default:"'all'"
Filter results by type (business accounts only)
limit
int
default:"10"
Maximum number of files to return
search_query
str
default:"''"
Search query to filter files (searches within folder if selected, or across all files)
skip_token
str
default:"''"
Pagination token from next_link output
file
AcceptsFile
default:"''"
Select or Upload a file
order_by
str
default:"'name'"
Sort order
search_folder_id
str
default:"''"
Select folder to search within (optional, leave empty to search all files)

integration_microsoft_calendar — Outlook Calendar

Outlook Calendar
pipeline.add(name="node").integration_microsoft_calendar(integration=..., num_messages=0, calendar="...", duration=0)
Parameters
action
str
default:"''"
Select the action to perform
use_date
bool
default:"False"
Toggle to use dates
use_exact_date
bool
default:"False"
Switch between exact date range and relative dates
calendar_id
str
default:"''"
The ID of the calendar to retrieve
calendar_owner_email
str
default:"''"
Leave empty to use your own calendar. Enter someone else’s email if you want to access their calendar and they have given you access.
from_all_calendars
bool
default:"True"
Whether to list events from all calendars
has_attachments
bool
default:"False"
Filter for events with attachments
importance
str
default:"''"
Importance level of the event One of: “, high, low, normal
integration
AcceptsIntegration
required
Connect to your account
is_all_day
bool
default:"False"
Filter for all-day events only
location_contains
str
default:"''"
Filter events by location
num_messages
int
required
Specify the number of events to fetch
order_by
str
default:"'start/dateTime'"
Field to order results by
sensitivity
str
default:"''"
Sensitivity level of the event One of: “, confidential, normal, personal, private
show_as
str
default:"''"
How to show the time slot One of: “, busy, free, out_of_office, tentative, working_elsewhere
subject_contains
str
default:"''"
Filter events by subject containing this text
all_day_event
bool
default:"False"
Whether this is an all-day event
allow_new_time_proposals
bool
default:"False"
Whether attendees can propose new times
attachments
AcceptsFileList
default:"[]"
Files to attach to the event. Files larger than 3 MB will be uploaded to OneDrive and a sharing link will be included in the event description.
attendees
str
default:"''"
Comma-separated list of attendee email addresses
body
str
default:"''"
Description/body of the event
calendar
str
required
The ID of the calendar to create event in
categories
str
default:"''"
Comma-separated list of categories
duration
int
required
The duration of the event in minutes. Default: 30 (in minutes)
hide_attendees
bool
default:"False"
Whether to hide attendees from each other
is_online_meeting
bool
default:"False"
Whether to create an online meeting
is_reminder_on
bool
default:"True"
Whether to enable reminder
location
str
default:"''"
Location of the event
online_meeting_provider
str
default:"'teamsForBusiness'"
Provider for online meeting One of: skypeForBusiness, skypeForConsumer, teamsForBusiness
reminder_minutes
int
default:"15"
Minutes before event to send reminder (default 15)
response_requested
bool
default:"True"
Whether responses are requested from attendees
start_datetime
AcceptsTimestamp
default:"-1"
The start time of the event (RFC3339 format)
subject
str
required
The subject/title of the event
activity_domain
str
default:"'work'"
Controls which hours to consider for scheduling. ‘Work’ restricts suggestions to each attendee’s individual work hours and timezone. ‘Personal’ extends to weekends. ‘Unrestricted’ allows any time of day. One of: personal, unrestricted, work
attendee_emails
list[str]
required
List of attendee email addresses to find common available times.
attendee_types
list[str]
default:"[]"
Type for each attendee (maps 1:1 with attendee emails). Values: ‘required’ (must attend), ‘optional’ (nice to have), ‘resource’ (room/equipment). Defaults to ‘required’ if not provided.
end_date_and_time
AcceptsTimestamp
default:"''"
The last date and end time for everyday to look for availability
is_location_required
bool
default:"False"
Whether a meeting location is required for the suggestions.
is_organizer_optional
bool
default:"False"
Whether the organizer (you) is optional for the meeting
location_names
list[str]
default:"[]"
Optional list of preferred meeting location names. Must be registered room resources in your organization (Exchange/Microsoft 365 room mailboxes). Graph API will attempt to resolve and verify room availability for each provided location.
max_suggestions
int
default:"20"
Maximum number of meeting time suggestions to return. Typical values: 5-20.
meeting_duration
str
required
Duration of the meeting (e.g., 30, 60m, 1h, 90). Defaults to minutes if no suffix provided.
minimum_attendee_percentage
int
default:"100"
Minimum percentage of attendees that must be available for a slot to be suggested (0-100). Use 100 to require all attendees, or lower values (e.g., 50) for flexible scheduling where not everyone needs to attend.
start_date_and_time
AcceptsTimestamp
default:"''"
The first date and start time for everyday to look for availability
suggest_location
bool
default:"False"
Whether the API should suggest available meeting rooms.
timezone
str
default:"'US/Eastern'"
IANA Time Zone code (e.g., US/Eastern)
slot_duration
int
default:"''"
The duration of an individual slot to look for (in minutes). Default: 30 (in minutes)
event_id
str
required
The ID of the event to retrieve
description
str
default:"''"
New description/body of the event
end_datetime
AcceptsTimestamp
default:"-1"
New end time of the event (RFC3339 format)
event_subject
str
default:"''"
New subject/title of the event
calendar_name
str
default:"''"
The name of the calendar to create
color
str
default:"''"
Color for the calendar
user_identifier
str
required
The user’s ID or organizational email (work/school accounts only, not personal @outlook.com/@hotmail.com)
filter_query
str
default:"''"
Filter query to filter calendars. Examples: ‘canShare eq true’, ‘canEdit eq true’, ‘isDefaultCalendar eq false’
limit
int
required
Maximum number of calendars to retrieve
search
str
default:"''"
Search users by display name or email
date_range
dict
default:"{}"
pick the relative date range
exact_date
dict
default:"{}"
Pick the start and end dates

integration_microsoft_dynamics_crm — Microsoft Dynamics CRM

Microsoft Dynamics CRM
pipeline.add(name="node").integration_microsoft_dynamics_crm(integration=..., num_messages=0, create_account_name="...", account_id="...")
Parameters
action
str
default:"''"
Select the action to perform One of: create_account, delete_account, get_account, list_accounts, update_account
use_date
bool
default:"False"
Toggle to filter accounts by date
use_exact_date
bool
default:"False"
Switch between exact date range and relative dates
expand
str
default:"''"
Related entities to expand (optional, e.g., primarycontactid)
filter
str
default:"''"
OData filter expression (e.g., statecode eq 0)
integration
AcceptsIntegration
required
Connect to your Microsoft Dynamics CRM account
num_messages
int
required
Specify the number of accounts to fetch (max 5000)
order_by
str
default:"''"
Field to sort by (e.g., name asc, createdon desc)
select_fields
str
default:"''"
Comma-separated list of fields to return (optional, e.g., name,accountnumber,telephone1)
account_number
str
default:"''"
Account number
additional_fields
str
default:"''"
Additional fields as JSON object
address_line1
str
default:"''"
Street address
city
str
default:"''"
City
country
str
default:"''"
Country
create_account_name
str
required
Name of the account (required)
description
str
default:"''"
Description of the account
email
str
default:"''"
Primary email address
industry
str
default:"''"
Industry type
number_of_employees
int
default:"0"
Number of employees
phone
str
default:"''"
Primary phone number
postal_code
str
default:"''"
Postal or ZIP code
revenue
str
default:"''"
Annual revenue
state
str
default:"''"
State or Province
website
str
default:"''"
Website URL
account_id
str
required
Select the account to delete
name
str
default:"''"
Updated account name
date_range
dict
default:"{}"
Pick the relative date range
exact_date
dict
default:"{}"
Pick the start and end dates

integration_microsoft_excel — Microsoft Excel 365

Microsoft Excel 365
pipeline.add(name="node").integration_microsoft_excel(integration=..., lookup_column="...", lookup_value="...", return_all=True)
Parameters
action
str
default:"''"
Select the action to perform
endpoint_0
str
One of: [endpoint_0.&lt;A&gt;]
endpoint_1
str
One of: [endpoint_1.&lt;A&gt;]
integration
AcceptsIntegration
required
Connect to your Microsoft Excel 365 account
limit
int
default:"1"
Maximum number of columns to return (default: 10)
lookup_column
str
required
Column name to search in
lookup_value
str
required
Value to search for
return_all
bool
required
When enabled, returns all columns (ignores limit)
table_id
str
required
Select the table from your workbook
workbook_id
str
required
Select the workbook
worksheet_name
str
required
Name for the new sheet
has_headers
bool
default:"True"
Whether the range has header row
range_address
str
default:"''"
The range address for the table (e.g., A1:D10)
worksheet_id
str
required
Select the sheet from your workbook
fields
str
default:"''"
Comma-separated list of fields to include in response (e.g., id,name,position)
mode
str
default:"'append'"
Choose append or update mode One of: append, update
row_data
str
required
JSON object or array of objects with column-value pairs (e.g., {“Name”: “John”, “Age”: 30} or [{“Name”: “John”}, {“Name”: “Jane”}])
search_column
str
default:"''"
Column name to search for matching rows (used only in Update mode)
search_value
str
default:"''"
Value to search for in the search column (used only in Update mode)

integration_microsoft_one_note — Microsoft OneNote

Microsoft OneNote
pipeline.add(name="node").integration_microsoft_one_note(destination_section_id="...", integration=..., page_id="...", display_name="...")
Parameters
action
str
default:"''"
Select the action to perform
destination_section_id
str
required
Select the section to copy the page to
group_id
str
default:"''"
Optional group ID if copying to a group notebook
integration
AcceptsIntegration
required
Connect to your Microsoft OneNote account
page_id
str
required
Select a page
display_name
str
required
The name of the notebook to create
notebook_id
str
required
Select a notebook
limit
int
required
Maximum number of notebooks to retrieve
content
str
default:"''"
Text content for the page body
patch_action
str
required
The type of update to perform One of: append, insert, replace
position
str
default:"''"
For Insert: where to place content relative to target line One of: after, before
target_text
str
default:"''"
Find a line on the page to target. Leave empty to target the whole page body
file
AcceptsFile
default:"''"
Attach an image or file to the page (optional)
file_name
str
default:"''"
Name for the attached file (required if file is provided)
section_id
str
default:"''"
Select a section
title
str
default:"''"
Title of the page
section_group_id
str
required
Select a section group
query
str
default:"''"
Filter notebooks by name (leave empty to list all)
order_by_field
str
default:"''"
Field to order results by One of: createdDateTime, displayName, lastModifiedDateTime, title
order_direction
str
default:"''"
The order to sort the data One of: asc, desc

integration_microsoft_sql_server — Microsoft SQL Server

Microsoft SQL Server
pipeline.add(name="node").integration_microsoft_sql_server(confirm_delete=True, integration=..., limit=0, table_name="...")
Parameters
action
str
default:"''"
Select the database operation to perform One of: create_rows, delete_rows, execute_query, get_tables, update_rows
confirm_delete
bool
required
Confirm that you want to delete the specified records
integration
AcceptsIntegration
required
Connect to your SQL Server database
limit
int
required
Maximum number of rows to return
table_name
str
required
Name of the table to insert data into
where_clause
str
required
WHERE condition to identify records to update
data
str
required
JSON array of objects or single object to insert into the table
batch_size
int
default:"1000"
Number of rows to insert per batch
columns
list[str]
default:"[]"
Specific columns to insert (optional - uses all if empty)
parameters
list[str]
default:"[]"
Query parameters for prepared statements
sql_query
str
required
SQL query to execute

integration_monday — Monday

Monday
pipeline.add(name="node").integration_monday(column_id="...", column_item_id="...", integration=..., value="...")
Parameters
action
str
default:"''"
Select the action to perform
endpoint_0
str
One of: [endpoint_0.&lt;A&gt;]
board_id
str
default:"''"
The board to retrieve
column_id
str
required
The column to update
column_item_id
str
required
ID of the item to retrieve
integration
AcceptsIntegration
required
Connect to your account
value
str
required
New value for the column
workspace_id
str
default:"''"
The workspace to retrieve boards from
column_value
str
required
Value to search for in the column
limit
int
required
Maximum number of boards to return
column_type
str
required
Type of column to create
defaults
str
Default values for the column. For Status/Dropdown: comma-separated labels (e.g. ‘Working on it, Done, Stuck’). For Text: default text value. For Number: default number.
description
str
default:"''"
Optional description for the board
title
str
required
Title of the column to create
group_id
str
default:"''"
The group to delete
item_name
str
required
Name of the item to create
update_text
str
required
Content of the update
color
str
default:"''"
Select a color from the dropdown or provide a HEX code directly (e.g. #579bfc). Must include #.
group_name
str
required
Name of the group to create
position
str
default:"'1'"
Position of the group
filter_column_id
str
default:"''"
Column to filter by. Select a single column from the dropdown, or type comma-separated column names for multi-column filtering (e.g. ‘Status,Priority’).
filter_value
str
default:"''"
Value to match in the filter column. For multi-column filtering, use comma-separated values matching the order of columns (e.g. ‘Done,High’).
return_all
bool
default:"False"
When enabled, fetches all items from the board (ignores limit). Use with caution on large boards.
search_by_name
str
default:"''"
Search for items by item name. When provided, returns only items whose name matches the search term.
sort_by
str
default:"''"
Column to order results by. Use column name, column ID, or special values: creation_log (created date), last_updated (last modified).
sort_direction
str
default:"'asc'"
Order of sorted results One of: asc, desc
target_group_id
str
required
ID of the group to move the item to
board_kind
str
default:"'public'"
Type of board to create One of: private, public, share
name
str
required
Name of the board to create
template_id
str
default:"''"
Board ID of a saved template in your account.Only account-level templates are supported, not marketplace templates.
include_archived
bool
default:"False"
Whether to include archived groups
state
str
default:"'active'"
Filter boards by state One of: active, all, archived, deleted

integration_mongodb — MongoDB

MongoDB
pipeline.add(name="node").integration_mongodb(filter="...", integration=..., replacement="...", update="...")
Parameters
action
str
default:"''"
Select the action to perform
collection
str
default:"''"
The collection on which to perform the query
filter
str
required
The filter to select documents to update (JSON format)
integration
AcceptsIntegration
required
Connect to your account
replacement
str
required
The replacement document (JSON format)
update
str
required
The update operation (JSON format)
document
str
required
The document to insert (JSON format)
query
str
default:"''"
The MongoDB query to find all matching records

integration_mysql — MySQL

MySQL
pipeline.add(name="node").integration_mysql(column_to_match_on="...", data="...", integration=..., table_name="...")
Parameters
action
str
default:"''"
Select the action to perform
column_to_match_on
str
required
Column used to find the row to update
connection_limit
int
default:"10"
Maximum number of connections (default: 10)
connection_timeout
int
default:"30"
Connection timeout in seconds (default: 30)
data
str
required
JSON object with column-value pairs to insert
integration
AcceptsIntegration
required
Connect to your account
table_name
str
required
Choose the table to insert into
value
str
required
Value in the match column to identify the row
delete_command
str
required
Delete command to execute (truncate, delete, or drop) One of: delete, drop, truncate
where_clause
str
default:"''"
Optional WHERE condition (without WHERE keyword)
columns
str
default:"''"
Choose specific columns (comma-separated or select multiple)
limit
int
required
Maximum number of rows to return
order_by
str
default:"''"
Optional ORDER BY clause
parameters
str
default:"''"
Comma-separated parameters for parameterized queries (optional)
sql_query
str
required
SQL query to execute
query
str
default:"''"
Natural language query to be converted to SQL
query_agent_model
str
default:"'gpt-4-turbo-preview'"
query_type
str
default:"'Raw SQL'"
sql_generation_model
str
default:"'gpt-4-turbo-preview'"

integration_notion — Notion

Notion
pipeline.add(name="node").integration_notion(database_id="...", integration=..., text="...", page_id="...")
Parameters
action
str
default:"''"
Select the action to perform
endpoint_0
str
One of: [endpoint_0.&lt;A&gt;]
database_id
str
required
Select Notion Database
integration
AcceptsIntegration
required
Connect to your account
limit
int
default:"10"
Maximum number of databases to return
return_all
bool
default:"False"
If true, returns all databases regardless of limit
text
str
required
Text to search for in database names and content
get_page_content
bool
default:"False"
If true, fetches the text content of each matching page
archived
bool
default:"False"
Whether to archive the page
page_id
str
required
Select the page to archive
properties
str
required
JSON object containing properties to update
blocks
list[str]
default:"[]"
Array of block objects. Each block should be a JSON string with ‘type’ (paragraph, heading_1, heading_2, heading_3, toggle, to_do, bulleted_list_item, numbered_list_item, image) and ‘content’ fields. Use checked for to_do blocks to indicate if the task is completed. Content will not be used if blocks are provided. Example: {“type”:“paragraph”,“content”:“Hello”}
item_id
str
required
Select Notion Database
icon
str
default:"''"
Icon emoji (e.g., 😀) or external file URL if type is ‘file’
icon_type
str
default:"''"
Type of icon: emoji or external file URL One of: emoji, file
block_id
str
required
The ID of the parent block to get children from
user_id
str
required
The ID of the user to read
condition
str
default:"''"
Conditional Operator

integration_openweathermap — Open Weather Map

Open Weather Map
pipeline.add(name="node").integration_openweathermap(integration=..., units="imperial")
Parameters
action
str
default:"''"
Select the action to perform One of: get_5_day_forecast, get_current_weather
location_type
str
default:"'city_name'"
How to specify the location One of: city_id, city_name, coordinates, zip_code
city_id
str
default:"''"
OpenWeatherMap city ID
count
int
default:"10"
Number of forecast entries to return (max 40, each represents 3 hours)
integration
AcceptsIntegration
required
Connect to your OpenWeatherMap account
language
str
default:"'en'"
Language code for weather descriptions (e.g., ‘en’, ‘es’, ‘fr’)
units
str
required
Temperature units One of: imperial, metric, standard
city_name
str
default:"''"
City name, optionally with country code (e.g., ‘London,UK’)
latitude
str
default:"''"
Latitude coordinate
longitude
str
default:"''"
Longitude coordinate
zip_code
str
default:"''"
ZIP code with country code (e.g., ‘10001,US’)

integration_oracle_database — Oracle Database

Oracle Database
pipeline.add(name="node").integration_oracle_database(delete_command="delete", integration=..., schema="...", table_name="...")
Parameters
action
str
default:"''"
Select the action to perform One of: delete_table, execute_query, insert, select, update, upsert
endpoint_0
str
One of: [endpoint_0.&lt;A&gt;]
return_all
bool
default:"False"
Return all rows (ignores limit)
delete_command
str
required
Delete command to execute (truncate, delete, or drop) One of: delete, drop, truncate
integration
AcceptsIntegration
required
Connect to your Oracle Database account
schema
str
required
Choose the schema
table_name
str
required
Choose the table to insert into
where_clause
str
default:"''"
Optional WHERE condition (without WHERE keyword)
auto_commit
bool
default:"True"
Automatically commit after each insert. If false, all inserts are wrapped in a transaction.
data
list[str]
required
JSON objects with column-value pairs to insert (one per row)
match_columns
str
required
Column(s) to match on for update (comma-separated). Rows matching these column values will be updated.
limit
int
default:"10"
Maximum number of rows to return
order_by
str
default:"''"
Optional ORDER BY clause
output_numbers_as_string
bool
default:"False"
Convert numeric values to strings in the output
bind_variable_placeholder_values
str
default:"''"
Comma-separated values for bind variables (:1, :2, etc.) in the query
sql_query
str
required
SQL query to execute (use :1, :2, etc. for parameters)

integration_outlook — Outlook

Outlook
pipeline.add(name="node").integration_outlook(email_id="...", integration=..., recipients="...", attachment=...)
Parameters
action
str
default:"''"
Select the action to perform
use_date
bool
default:"False"
Toggle to use dates
use_exact_date
bool
default:"False"
Switch between exact date range and relative dates
attachments
AcceptsFileList
default:"[]"
Attachments to be appended.
bcc_recipients
str
default:"''"
A single email or a comma-separated list of the BCC recipients’ emails
body
str
default:"''"
The body of the email
cc_recipients
str
default:"''"
A single email or a comma-separated list of the CC recipients’ emails
email_id
str
required
The ID of the email to reply to
format
str
default:"'text'"
Either html (to allow html content) or text (for plaintext content - default) One of: html, text
integration
AcceptsIntegration
required
Connect to your account
recipients
str
required
A single email or a comma-separated list of the recipients’ emails
reply_to
str
default:"''"
Alternative email address where replies should be sent instead of the sender’s address
reply_to_sender_only
bool
default:"False"
When enabled, ensures that replies go only to the sender, excluding CC or group recipients
sender_name
str
default:"''"
Custom name to display as the sender in the recipient’s inbox
subject
str
default:"''"
The subject of the email
attachment
AcceptsFile
required
The file to attach to the message
message_id
str
required
Select the message to get
birthday
AcceptsTimestamp
default:"''"
Birthday date
business_address_city
str
default:"''"
Business address city
business_address_country
str
default:"''"
Business address country
business_address_postal_code
str
default:"''"
Business address postal/ZIP code
business_address_state
str
default:"''"
Business address state/province
business_address_street
str
default:"''"
Business street address
business_home_page
str
default:"''"
Company or business website URL
business_phones
str
default:"''"
Comma-separated list of business phone numbers
categories
str
default:"''"
Comma-separated list of categories
children
str
default:"''"
Comma-separated list of children’s names
company_name
str
default:"''"
The company name
department
str
default:"''"
The department
display_name
str
default:"''"
The name of the folder to create
email_addresses
str
default:"''"
Comma-separated list of email addresses
file_as
str
default:"''"
How to file the contact
first_name
str
required
The first name of the contact
home_address_city
str
default:"''"
Home address city
home_address_country
str
default:"''"
Home address country
home_address_postal_code
str
default:"''"
Home address postal/ZIP code
home_address_state
str
default:"''"
Home address state/province
home_address_street
str
default:"''"
Home street address
home_phones
str
default:"''"
Comma-separated list of home phone numbers
im_addresses
str
default:"''"
Comma-separated list of instant messaging addresses
initials
str
default:"''"
Initials of the contact
job_title
str
default:"''"
The job title
last_name
str
required
The last name of the contact
manager
str
default:"''"
Manager’s name
middle_name
str
default:"''"
The middle name of the contact
mobile_phone
str
default:"''"
The mobile phone number
nickname
str
default:"''"
Nickname of the contact
notes
str
default:"''"
Personal notes about the contact
office_location
str
default:"''"
The office location
other_address_city
str
default:"''"
Other address city
other_address_country
str
default:"''"
Other address country
other_address_postal_code
str
default:"''"
Other address postal/ZIP code
other_address_state
str
default:"''"
Other address state/province
other_address_street
str
default:"''"
Other street address
profession
str
default:"''"
The profession
spouse_name
str
default:"''"
Name of the spouse
title
str
default:"''"
Title of the contact (e.g., Mr., Mrs., Dr.)
attachment_id
str
required
The ID of the attachment to retrieve
output
str
default:"'simple'"
Output format for the message data One of: full, simple
fields
str
default:"''"
Comma-separated list of additional fields to return
filter
str
default:"''"
OData filter expression
folder_id
str
required
Select a mailbox to read
limit
int
required
Maximum number of folders to return (0 for no limit)
return_all
bool
default:"False"
Whether to return all folders (ignores limit)
search
str
default:"''"
Search term to filter messages
destination_folder_id
str
default:"''"
ID of the folder to move the message to (leave empty to keep in current folder)
parent_folder_id
str
default:"''"
ID of the parent folder (optional, creates in root if not provided)
contact_id
str
required
Select the contact to retrieve
user_identifier
str
required
The user’s ID or organizational email (work/school accounts only, not personal @outlook.com/@hotmail.com)