Steps
Steps are the building blocks of your workflows. Each step performs a specific action like calling an API, transforming data, or sending a notification.
add_timestamp
stepAdd a timestamp to each event as it flows through the workflow.
add_uuid
stepGenerate and add a unique identifier (UUID4) to each event.
anthropic_chat
stepGenerate text completions using Anthropic's Claude AI models via the Messages API.
aws_dynamodb
stepExecute AWS DynamoDB operations.
aws_lambda
stepInvoke AWS Lambda functions from your workflow for serverless processing.
aws_s3
stepPersist event data to Amazon S3 or S3-compatible object storage.
aws_sns
stepExecute AWS SNS notification operations.
aws_sqs
stepExecute AWS SQS queue operations.
chunk_text
stepSplit text into smaller chunks for processing with AI models or vector databases.
discord_webhook
stepPublish formatted event summaries to a Discord Incoming Webhook.
filter
stepFilter events based on field conditions with AND/OR logic.
firebase
stepExecute Firebase operations for Firestore, Realtime Database, Storage, and Auth.
for_each
stepProcess each item in an array with a sequence of steps.
gemini_chat
stepGenerate text using Google's Gemini AI models through the Gemini API.
graphql
stepExecute GraphQL queries and mutations.
http_call
stepMake HTTP requests to external APIs with dynamic templating and error handling.
hubspot
stepIntegrate with HubSpot CRM to manage contacts, companies, deals, and associations.
huggingface_inference
stepRun inference on Hugging Face models via the Inference API.
if_else
stepRoute events through different processing paths based on conditions.
invoke_workflow
stepChain workflows together by invoking another workflow from within your current workflow.
jq
stepTransform JSON data using jq - the powerful JSON processor.
mailchimp
stepExecute Mailchimp email marketing operations.
mongodb
stepExecute MongoDB database operations.
mysql
stepExecute MySQL database operations for queries, inserts, updates, and deletes.
odoo
stepExecute operations on any Odoo model using the XML-RPC API.
openai_completion
stepGenerate text using OpenAI's GPT models or compatible APIs (Azure OpenAI, local models).
openai_embeddings
stepGenerate vector embeddings for text using OpenAI's embedding models.
pinecone
stepExecute Pinecone vector database operations.
postgres
stepExecute PostgreSQL database operations for querying and manipulating data.
Log and display event data for debugging and monitoring workflows.
python_function
stepExecute custom Python code to transform events with full programming flexibility.
redis
stepExecute Redis in-memory database operations.
resend_email
stepSend transactional emails via the Resend API with dynamic content and attachments.
salesforce
stepIntegrate with Salesforce CRM to query, create, update, upsert, and delete records.
segment
stepExecute Segment analytics operations.
sendgrid
stepSend transactional emails via SendGrid with dynamic content and advanced features.
slack_webhook
stepSend formatted notifications to Slack via the Incoming Webhook API.
stripe
stepIntegrate with Stripe payment platform for customer and subscription management.
supabase
stepExecute Supabase operations for database, auth, storage, and realtime.
teams_webhook
stepSend formatted notifications to Microsoft Teams via the Incoming Webhook API.
telegram
stepExecute Telegram Bot API operations.
twilio
stepSend SMS messages, MMS, and perform phone lookups using Twilio's communication platform.
weaviate
stepExecute Weaviate vector search operations.