ESC
All(0)
emoticon icon

No results found for the current search

  1. ⚡️ Kestra 0.23 adds Unit Tests for Flows, Multi-Panel Editor and new UI filters Learn More

Item 1 of 1
Kestra, Open source declarative data orchestration
  • Product

    • Open Source
      Explore Kestra's Core Capabilities

    • Enterprise Edition
      Security and Governance for Enterprise Needs

    • Cloud EditionEarly Adopter
      Register for the Cloud Edition

    • Platform Overview
      Powerful capabilities from the UI

    • Start orchestrating your first workflows.

      Quickstart Guide

      • Workflow components
        Get to know the main orchestration components of a Kestra workflow

      • Videos tutorials
        Get started with our video tutorials

  • Solutions

      Features

    • Declarative Orchestration
      Infrastructure as Code for All Your Workflows

    • Automation Platform
      Scheduling and Automation Made Easy

    • Language Agnostic
      Separate your Business Logic from Orchestration Logic

    • Kestra's Terraform Provider
      Deploy and manage all Kestra resources with Terraform

    • API-First
      Learn more about Kestra’s API features

      Use Cases

    • For Data Engineers
      Orchestrate your Data Pipelines, Automate Processes, and Harness the Power of Your Data

    • For Software Engineers
      Boost Productivity, Simplify Processes, and Accelerate Microservice Deployment

    • For Platform Engineers
      Automate, Scale, Provision and Optimize Your Infrastructure

      Industries

    • For Retail
      Empower retail businesses with an event-driven, language-agnostic orchestration platform that scales

    • For Healthcare
      Streamline data processing, accelerate research, and enhance collaboration in healthcare

    • For Automotive
      Ensure seamless operations and optimized performance across all processes.

    • Explore blueprints

      Explore blueprints
      to kick-start
      your next flow.

      Explore
  • Resources

      RESOURCES

    • Blog
      Company news, product updates, and engineering deep dives

    • Video Tutorials
      Get started with our video tutorials

    • FAQ
      FAQ about the product and the company

      DISCOVER

    • Community Overview
      Ask any questions and share your feedback

    • Partners
      Use our partner ecosystem to accelerate your Kestra adoption

    • About Us
      Discover the team and values behind Kestra

    • Platform Overview

      Gorgias, Using Declarative
      Data Engineering
      Orchestration With Kestra

      Explore

      • Customer Stories
        Learn how Enterprises orchestrate their business-critical workflows

  • Docs
  • Plugins
  • Blueprints
  • Pricing
  • Star
    Talk to us Get Started Talk to Us

Product

  • Open Source
    Explore Kestra's Core Capabilities

  • Enterprise Edition
    Security and Governance for Enterprise Needs

  • Cloud EditionEarly Adopter
    Register for the Cloud Edition

  • Platform Overview
    Powerful capabilities from the UI

Start
orchestrating your
first workflows.

Quickstart Guide

  • Workflow components
    Get to know the main orchestration components of a Kestra workflow

  • Videos tutorials
    Get started with our video tutorials

Features

  • Declarative Orchestration
    Infrastructure as Code for All Your Workflows

  • Automation Platform
    Scheduling and Automation Made Easy

  • Language Agnostic
    Separate your Business Logic from Orchestration Logic

  • Kestra's Terraform Provider
    Deploy and manage all Kestra resources with Terraform

  • API-First
    Learn more about Kestra’s API features

Use Cases

  • For Data Engineers
    Orchestrate your Data Pipelines, Automate Processes, and Harness the Power of Your Data

  • For Software Engineers
    Boost Productivity, Simplify Processes, and Accelerate Microservice Deployment

  • For Platform Engineers
    Automate, Scale, Provision and Optimize Your Infrastructure

Industries

  • For Retail
    Empower retail businesses with an event-driven, language-agnostic orchestration platform that scales

  • For Healthcare
    Streamline data processing, accelerate research, and enhance collaboration in healthcare

  • For Automotive
    Ensure seamless operations and optimized performance across all processes.

Explore blueprints

Explore blueprints to kick-start
your next flow.

Explore

RESOURCES

  • Blog
    Company news, product updates, and engineering deep dives

  • Video Tutorials
    Get started with our video tutorials

  • FAQ
    FAQ about the product and the company

DISCOVER

  • Community Overview
    Ask any questions and share your feedback

  • Partner
    Use our partner ecosystem to accelerate your Kestra adoption

  • About Us
    Discover the team and values behind Kestra

Platform Overview

Gorgias,
Using Declarative Data Engineering Orchestration
With Kestra

20 000+

executions per month

  • Customer Stories
    Learn how Enterprises orchestrate their business-critical workflows

Search

Ctrl + K
  • Core
    • Debug
      • Tasks
        • Echo
        • Return
    • Kv
      • Tasks
        • Delete
        • Get
        • GetKeys
        • Set
    • Output
      • Tasks
        • OutputValues
    • Chart
      • Charts
        • Bar
        • KPI
        • Markdown
        • Pie
        • Table
        • TimeSeries
    • Execution App Block
      • App Blocks
        • CancelExecutionButton
        • CreateExecutionButton
        • CreateExecutionForm
        • DownloadLogsButton
        • Inputs
        • Logs
        • Outputs
        • ResumeExecutionButton
        • ResumeExecutionForm
        • TaskOutputs
    • Log
      • Tasks
        • Fetch
        • Log
        • PurgeLogs
    • Runner
      • Task Runners
        • Process
    • Condition
      • Conditions
        • DateTimeBetween
        • DayWeek
        • DayWeekInMonth
        • ExecutionFlow
        • ExecutionLabels
        • ExecutionNamespace
        • ExecutionOutputs
        • ExecutionStatus
        • Expression
        • FlowCondition
        • FlowNamespaceCondition
        • HasRetryAttempt
        • MultipleCondition
        • Not
        • Or
        • PublicHoliday
        • TimeBetween
        • Weekend
    • Trigger
      • Tasks
        • Toggle
      • Triggers
        • Flow
        • Schedule
        • ScheduleOnDates
        • Webhook
    • Core App Block
      • App Blocks
        • Alert
        • AutoRefresh
        • Button
        • Divider
        • Image
        • Loading
        • Markdown
        • RedirectTo
        • Stacktrace
        • Table
    • Flow
      • Tasks
        • AllowFailure
        • Dag
        • EachParallel
        • EachSequential
        • ForEach
        • ForEachItem
        • If
        • LoopUntil
        • Parallel
        • Pause
        • Sequential
        • Sleep
        • Subflow
        • Switch
        • Template
        • WorkingDirectory
    • App
      • Apps
        • Execution
    • Data Filter
      • Data Filters
        • Executions
        • Logs
        • Metrics
        • Triggers
    • Namespace
      • Tasks
        • DeleteFiles
        • DownloadFiles
        • UploadFiles
    • Http
      • Tasks
        • Download
        • Request
      • Triggers
        • Trigger
    • Templating
      • Tasks
        • TemplatedTask
    • State
      • Tasks
        • Delete
        • Get
        • Set
    • Log (EE)
      • Tasks
        • AuditLogShipper
        • LogShipper
        • PurgeAuditLogs
      • Log Exporters
        • FileLogExporter
    • Docker
      • Task Runners
        • Docker
    • Execution
      • Tasks
        • Assert
        • Count
        • Exit
        • Fail
        • Labels
        • PurgeExecutions
        • Resume
    • Storage
      • Tasks
        • Concat
        • DeduplicateItems
        • Delete
        • FilterItems
        • LocalFiles
        • PurgeCurrentExecutionFiles
        • Reverse
        • Size
        • Split
        • Write
  • Actian Vector
    • Tasks
      • Batch
      • Queries
      • Query
    • Triggers
      • Trigger
  • Airbyte
    • Jobs
      • Tasks
        • Reset
        • Sync
    • Connections
      • Tasks
        • CheckStatus
        • Sync
  • Airflow
    • Tasks
      • TriggerDagRun
  • Amazon Redshift
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • AMQP
    • Tasks
      • Consume
      • CreateQueue
      • DeclareExchange
      • Publish
      • QueueBind
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Ansible
    • Tasks
      • AnsibleCLI
  • Apache Cassandra
    • Astradb
      • Tasks
        • Query
      • Triggers
        • Trigger
    • Standard
      • Tasks
        • Query
      • Triggers
        • Trigger
  • Apache Druid
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Apache Kafka
    • Tasks
      • Consume
      • Produce
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Apache Pinot
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Apache Pulsar
    • Tasks
      • Consume
      • Produce
      • Reader
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Apache Spark
    • Tasks
      • JarSubmit
      • PythonSubmit
      • RSubmit
      • SparkCLI
  • Apache Tika
    • Tasks
      • Parse
  • Arrow Flight SQL
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • AS400
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Atlassian Jira
    • Issues
      • Tasks
        • Create
        • CreateComment
        • UpdateFields
  • AWS
    • S3
      • Tasks
        • Copy
        • CreateBucket
        • Delete
        • DeleteList
        • Download
        • Downloads
        • List
        • Upload
      • Triggers
        • Trigger
    • Sns
      • Tasks
        • Publish
    • Authentication
      • Tasks
        • EksToken
    • Eventbridge
      • Tasks
        • PutEvents
    • Sqs
      • Tasks
        • Consume
        • Publish
      • Triggers
        • RealtimeTrigger
        • Trigger
    • Ecr
      • Tasks
        • GetAuthToken
    • Glue
      • Tasks
        • GetJobRun
        • StartJobRun
    • Emr
      • Tasks
        • CreateClusterAndSubmitSteps
        • DeleteCluster
        • SubmitSteps
    • Athena
      • Tasks
        • Query
    • Dynamodb
      • Tasks
        • DeleteItem
        • GetItem
        • PutItem
        • Query
        • Scan
    • Kinesis
      • Tasks
        • PutRecords
    • Lambda
      • Tasks
        • Invoke
    • Cli
      • Tasks
        • AwsCLI
  • AWS (EE)
    • Task Runners
      • Batch
    • Log Exporters
      • LogExporter
      • LogExporter
  • Azure
    • Cli
      • Tasks
        • AzCLI
    • Function
      • Tasks
        • HttpFunction
    • Table
      • Tasks
        • Bulk
        • Delete
        • Get
        • List
    • Authentication
      • Tasks
        • OauthAccessToken
    • Eventhubs
      • Tasks
        • Consume
        • Produce
      • Triggers
        • RealtimeTrigger
        • Trigger
    • Datafactory
      • Tasks
        • CreateRun
    • Adls
      • Tasks
        • Delete
        • DeleteFiles
        • List
        • Read
        • Reads
        • SharedAccess
        • Upload
      • Triggers
        • Trigger
    • Job
      • Tasks
        • Create
    • Pool
      • Tasks
        • Resize
    • Blob
      • Tasks
        • Copy
        • Delete
        • DeleteList
        • Download
        • Downloads
        • List
        • SharedAccess
        • Upload
      • Triggers
        • Trigger
  • Azure (EE)
    • Tasks
      • Create
      • List
      • SharedAccess
    • Task Runners
      • Batch
    • Log Exporters
      • LogExporter
      • LogExporter
  • ClickHouse
    • Tasks
      • BulkInsert
      • ClickHouseLocalCLI
      • Queries
      • Query
    • Triggers
      • Trigger
  • CloudQuery
    • Tasks
      • CloudQueryCLI
      • Sync
  • Compression
    • Tasks
      • ArchiveCompress
      • ArchiveDecompress
      • FileCompress
      • FileDecompress
  • Couchbase
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Cryptography
    • Openpgp
      • Tasks
        • Decrypt
        • Encrypt
  • Databricks
    • SQL
      • Tasks
        • Query
    • DBFS
      • Tasks
        • Download
        • Upload
    • Job
      • Tasks
        • CreateJob
        • SubmitRun
    • CLI
      • Tasks
        • DatabricksSQLCLI
    • Cluster
      • Tasks
        • CreateCluster
        • DeleteCluster
  • Datadog (EE)
    • Log Exporters
      • LogExporter
  • Dataform
    • Dataform CLI
      • Tasks
        • DataformCLI
  • DataHub
    • Tasks
      • Ingestion
  • DB2
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Dbt
    • Dbt CLI
      • Tasks
        • Build
        • Compile
        • DbtCLI
        • Deps
        • Freshness
        • List
        • Run
        • Seed
        • Setup
        • Snapshot
        • Test
    • Dbt Cloud
      • Tasks
        • CheckStatus
        • TriggerRun
  • Debezium DB2
    • Tasks
      • Capture
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Debezium Microsoft SQL Server
    • Tasks
      • Capture
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Debezium MongoDB
    • Tasks
      • Capture
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Debezium MySQL
    • Tasks
      • Capture
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Debezium Oracle
    • Tasks
      • Capture
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Debezium PostgreSQL
    • Tasks
      • Capture
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Docker
    • Tasks
      • Build
      • Prune
      • Pull
      • Rm
      • Run
      • Stop
  • Dremio
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • DuckDB
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Elasticsearch
    • Tasks
      • Bulk
      • Esql
      • Get
      • Load
      • Put
      • Request
      • Scroll
      • Search
  • Elasticsearch (EE)
    • Log Exporters
      • LogExporter
  • File system
    • Ftps
      • Tasks
        • Delete
        • Download
        • Downloads
        • List
        • Move
        • Upload
        • Uploads
      • Triggers
        • Trigger
    • Ftp
      • Tasks
        • Delete
        • Download
        • Downloads
        • List
        • Move
        • Upload
        • Uploads
      • Triggers
        • Trigger
    • Smb
      • Tasks
        • Delete
        • Download
        • Downloads
        • List
        • Move
        • Upload
        • Uploads
      • Triggers
        • Trigger
    • Ssh
      • Tasks
        • Command
    • Sftp
      • Tasks
        • Delete
        • Download
        • Downloads
        • List
        • Move
        • Upload
        • Uploads
      • Triggers
        • Trigger
    • Local
      • Tasks
        • Copy
        • Delete
        • Download
        • Downloads
        • List
        • Move
        • Upload
      • Triggers
        • Trigger
  • Fivetran
    • Connectors
      • Tasks
        • Sync
  • Git
    • Tasks
      • Clone
      • Push
      • PushDashboards
      • PushFlows
      • PushNamespaceFiles
      • Sync
      • SyncDashboards
      • SyncFlow
      • SyncFlows
      • SyncNamespaceFiles
  • Git (EE)
    • Git
      • Tasks
        • Clone
        • Push
        • PushDashboards
        • PushFlows
        • PushNamespaceFiles
        • Sync
        • SyncDashboards
        • SyncFlow
        • SyncFlows
        • SyncNamespaceFiles
  • GitHub
    • Tasks
      • RunWorkflow
      • Search
      • Search
      • Comment
      • Create
      • Search
      • Create
      • Search
      • Search
      • Search
      • Search
  • Go
    • Tasks
      • Commands
      • Script
  • Google Cloud
    • Cli
      • Tasks
        • GCloudCLI
    • Vertex AI
      • Tasks
        • ChatCompletion
        • CustomJob
        • MultimodalCompletion
        • TextCompletion
    • Dataproc Batches
      • Tasks
        • PySparkSubmit
        • RSparkSubmit
        • SparkSqlSubmit
        • SparkSubmit
    • Google Cloud Function
      • Tasks
        • HttpFunction
    • Firestore
      • Tasks
        • Delete
        • Get
        • Query
        • Set
    • Dataproc Clusters
      • Tasks
        • Create
        • Delete
    • Pub/Sub
      • Tasks
        • Consume
        • Publish
      • Triggers
        • RealtimeTrigger
        • Trigger
    • BigQuery
      • Tasks
        • Copy
        • CopyPartitions
        • CreateDataset
        • CreateTable
        • DeleteDataset
        • DeletePartitions
        • DeleteTable
        • ExtractToGcs
        • Load
        • LoadFromGcs
        • Query
        • StorageWrite
        • TableMetadata
        • UpdateDataset
        • UpdateTable
      • Triggers
        • Trigger
    • Kubernetes Engine (GKE)
      • Tasks
        • ClusterMetadata
    • Cloud Storage (GCS)
      • Tasks
        • Compose
        • Copy
        • CreateBucket
        • CreateBucketIamPolicy
        • Delete
        • DeleteBucket
        • DeleteList
        • Download
        • Downloads
        • List
        • UpdateBucket
        • Upload
      • Triggers
        • Trigger
    • Authentication
      • Tasks
        • OauthAccessToken
  • Google Cloud (EE)
    • Task Runners
      • Batch
      • CloudRun
    • Log Exporters
      • LogExporter
      • LogExporter
  • Google Workspace
    • Drive
      • Tasks
        • Create
        • Delete
        • Download
        • Export
        • List
        • Upload
    • Sheets
      • Tasks
        • CreateSpreadsheet
        • DeleteSpreadsheet
        • Load
        • Read
        • ReadRange
    • Calendar
      • Tasks
        • InsertEvent
  • GraalVM
    • Ruby
      • Tasks
        • Eval
        • FileTransform
    • Js
      • Tasks
        • Eval
        • FileTransform
    • Python
      • Tasks
        • Eval
        • FileTransform
  • GraphQL
    • Tasks
      • Request
  • Grok
    • Tasks
      • TransformItems
      • TransformValue
  • Groovy
    • Tasks
      • Eval
      • FileTransform
  • Hightouch
    • Tasks
      • Sync
  • Hubspot
    • Tasks
      • Create
      • Delete
      • Get
      • Search
      • Update
      • Create
      • Delete
      • Get
      • Search
      • Update
      • Create
      • Delete
      • Get
      • Search
      • Update
      • Create
  • Huggingface
    • Tasks
      • Inference
  • InfluxDB
    • Tasks
      • FluxQuery
      • InfluxQLQuery
      • Load
      • Write
    • Triggers
      • FluxTrigger
  • JBang
    • Tasks
      • Commands
      • Script
  • Jenkins
    • Tasks
      • JobBuild
      • JobInfo
  • JSONata
    • Tasks
      • TransformItems
      • TransformValue
  • Julia
    • Tasks
      • Commands
      • Script
  • Jython
    • Tasks
      • Eval
      • FileTransform
  • Kestra Plugin
    • Kestra Namespaces
      • Tasks
        • List
    • Kestra Flows
      • Tasks
        • DistinctNamespaces
        • Export
        • List
  • Kubernetes
    • Tasks
      • PodCreate
      • Apply
      • Delete
      • Get
  • Kubernetes (EE)
    • Task Runners
      • Kubernetes
  • Langchain4j
    • Tool
      • Additional Plugins
        • GoogleCustomWebSearch
        • HttpMcpClient
        • StdioMcpClient
        • TavilyWebSearch
    • Rag
      • Tasks
        • ChatCompletion
        • IngestDocument
        • Search
    • Retriever
      • Additional Plugins
        • GoogleCustomWebSearch
        • TavilyWebSearch
    • Embeddings
      • Additional Plugins
        • Elasticsearch
        • KestraKVStore
        • PGVector
    • Provider
      • Additional Plugins
        • AmazonBedrock
        • Anthropic
        • AzureOpenAI
        • DeepSeek
        • GoogleGemini
        • GoogleVertexAI
        • MistralAI
        • Ollama
        • OpenAI
  • LDAP
    • Tasks
      • Add
      • Delete
      • IonToLdif
      • LdifToIon
      • Modify
      • Search
  • Linear
    • Tasks
      • Create
  • Malloy CLI
    • Tasks
      • CLI
  • MariaDB
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Meilisearch
    • Tasks
      • DocumentAdd
      • DocumentGet
      • FacetSearch
      • Search
  • Microsoft SQL Server
    • Tasks
      • Batch
      • Queries
      • Query
    • Triggers
      • Trigger
  • MinIO
    • Tasks
      • Copy
      • CreateBucket
      • Delete
      • DeleteList
      • Download
      • Downloads
      • List
      • Upload
    • Triggers
      • Trigger
  • Modal
    • Modal CLI
      • Tasks
        • ModalCLI
  • MongoDB
    • Tasks
      • Bulk
      • Delete
      • Find
      • InsertOne
      • Load
      • Update
    • Triggers
      • Trigger
  • MQTT
    • Tasks
      • Publish
      • Subscribe
    • Triggers
      • RealtimeTrigger
      • Trigger
  • MySQL
    • Tasks
      • Batch
      • Queries
      • Query
    • Triggers
      • Trigger
  • Nashorn
    • Tasks
      • Eval
      • FileTransform
  • NATS
    • Tasks
      • Consume
      • Produce
      • CreateBucket
      • Delete
      • Get
      • Put
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Neo4j
    • Tasks
      • Batch
      • Query
  • New Relic (EE)
    • Log Exporters
      • LogExporter
  • Node
    • Scripts
      • Tasks
        • Node
  • Notifications
    • Teams
      • Tasks
        • TeamsExecution
        • TeamsIncomingWebhook
    • Mail
      • Tasks
        • MailExecution
        • MailSend
    • Sentry
      • Tasks
        • SentryAlert
        • SentryExecution
    • Telegram
      • Tasks
        • TelegramExecution
        • TelegramSend
    • Squadcast
      • Tasks
        • SquadcastExecution
        • SquadcastIncomingWebhook
    • Twilio
      • Tasks
        • TwilioAlert
        • TwilioExecution
    • Google
      • Tasks
        • GoogleChatExecution
        • GoogleChatIncomingWebhook
    • Sendgrid
      • Tasks
        • SendGridMailExecution
        • SendGridMailSend
    • Pagerduty
      • Tasks
        • PagerDutyAlert
        • PagerDutyExecution
    • Slack
      • Tasks
        • SlackExecution
        • SlackIncomingWebhook
    • Opsgenie
      • Tasks
        • OpsgenieAlert
        • OpsgenieExecution
    • Whatsapp
      • Tasks
        • WhatsAppExecution
        • WhatsAppIncomingWebhook
    • Discord
      • Tasks
        • DiscordExecution
        • DiscordIncomingWebhook
    • Zenduty
      • Tasks
        • ZendutyAlert
        • ZendutyExecution
    • Zulip
      • Tasks
        • ZulipExecution
        • ZulipIncomingWebhook
  • Ollama
    • Cli
      • Tasks
        • OllamaCLI
  • OpenAI
    • Tasks
      • ChatCompletion
      • CreateImage
      • Responses
      • UploadFile
  • OpenSearch
    • Tasks
      • Bulk
      • Get
      • Load
      • Put
      • Request
      • Scroll
      • Search
  • Opensearch (EE)
    • Log Exporters
      • LogExporter
  • Opentelemetry (EE)
    • Log Exporters
      • LogExporter
  • Oracle
    • Tasks
      • Batch
      • Queries
      • Query
    • Triggers
      • Trigger
  • PostgreSQL
    • Tasks
      • Batch
      • CopyIn
      • CopyOut
      • Queries
      • Query
    • Triggers
      • Trigger
  • Power BI
    • Tasks
      • RefreshGroupDataset
  • PowerShell
    • Tasks
      • Commands
      • Script
  • Python
    • Scripts
      • Tasks
        • Python
  • Redis
    • String
      • Tasks
        • Delete
        • Get
        • Increment
        • Set
        • Ttl
    • List
      • Tasks
        • ListPop
        • ListPush
      • Triggers
        • RealtimeTrigger
        • Trigger
    • Json
      • Tasks
        • Delete
        • Get
        • Increment
        • Set
    • Pubsub
      • Tasks
        • Publish
  • Rockset
    • Tasks
      • Query
    • Triggers
      • Trigger
  • RScript
    • Tasks
      • Commands
      • Script
  • Ruby
    • Tasks
      • Commands
      • Script
  • Salesforce (EE)
    • Tasks
      • Create
      • Delete
      • SoqlQuery
      • Update
  • Serialization
    • Xml
      • Tasks
        • IonToXml
        • XmlToIon
    • Csv
      • Tasks
        • CsvToIon
        • IonToCsv
    • Excel
      • Tasks
        • ExcelToIon
        • IonToExcel
    • Avro
      • Tasks
        • AvroToIon
        • InferAvroSchemaFromIon
        • IonToAvro
    • Parquet
      • Tasks
        • IonToParquet
        • ParquetToIon
    • Json
      • Tasks
        • IonToJson
        • JsonToIon
  • ServiceNow
    • Tasks
      • Delete
      • Get
      • Post
      • Update
  • Shell
    • Scripts
      • Tasks
        • Bash
  • Singer
    • Targets
      • Tasks
        • AdswerveBigQuery
        • Csv
        • DatamillCoPostgres
        • GenericTarget
        • Json
        • MeltanoSnowflake
        • Oracle
        • PipelinewisePostgres
        • PipelinewiseRedshift
        • PipelinewiseSnowflake
        • SqlServer
    • Taps
      • Tasks
        • BigQuery
        • BingAds
        • ChargeBee
        • ExchangeRateHost
        • FacebookAds
        • Fastly
        • GenericTap
        • GitHub
        • Gitlab
        • GoogleAdwords
        • GoogleAnalytics
        • GoogleSearchConsole
        • HubSpot
        • Marketo
        • Netsuite
        • PipelinewiseMongoDb
        • PipelinewiseMysql
        • PipelinewiseOracle
        • PipelinewisePostgres
        • PipelinewiseSqlServer
        • Quickbooks
        • Recharge
        • SageIntacct
        • Salesforce
        • Shopify
        • Slack
        • Stripe
        • Zendesk
        • Zoom
  • Snowflake
    • Tasks
      • Download
      • Queries
      • Query
      • SnowflakeCLI
      • Upload
    • Triggers
      • Trigger
  • Soda
    • Tasks
      • Scan
  • Solace
    • Tasks
      • Consume
      • Produce
    • Triggers
      • Trigger
  • Splunk (EE)
    • Log Exporters
      • LogExporter
  • SQLite
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • SQLMesh
    • SQLMesh CLI
      • Tasks
        • SQLMeshCLI
  • SurrealDB
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Sybase
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Terraform
    • Tasks
      • TerraformCLI
  • Trino
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Typesense
    • Tasks
      • BulkIndex
      • DocumentGet
      • DocumentIndex
      • FacetSearch
      • Search
  • Vertica
    • Tasks
      • Batch
      • Queries
      • Query
    • Triggers
      • Trigger
  • Weaviate
    • Tasks
      • BatchCreate
      • Delete
      • Query
      • SchemaCreate
  • Zendesk
    • Tasks
      • Create
plugins

File system​File system

Table of Contents
  • Ftps
  • Ftp
  • Smb
  • Ssh
  • Sftp
  • Local
Contribute
  • Join us on Slack
  • YouTube
  • GitHub
  • Twitter
  • BlueSky
  • LinkedIn

Perform file system tasks in Kestra data orchestration pipelines.

Ftps iconFtps Ftp iconFtp Smb iconSmb Ssh iconSsh Sftp iconSftp Local iconLocal
Kestra's logo

Open Source Declarative Data Orchestration

Get Kestra updates

Stay up to date with the latest features and changes to Kestra

Product
  • Platform Overview
  • Open Source
  • Enterprise Edition
  • Kestra Cloud
  • Pricing
Solutions
  • Use Cases
  • Declarative Orchestration
  • Automation Platform
  • API First
  • Code in Any Language
  • Terraform Provider
  • Airflow vs Kestra
  • Prefect vs Kestra
  • Dagster vs Kestra
  • AWS Step Functions vs Kestra
Community
  • Community Overview
  • Blog
  • Write for Us
  • Slack
  • GitHub
Docs
  • Documentation
  • Plugins
  • Blueprints
  • Getting Started
  • Administrator Guide
  • FAQ
Company
  • About Us
  • Careers Hiring!
  • Contact Us
  • Customer Stories
  • Partners Ecosystem

© 2025 Kestra Technologies. Developed with on 🌎.

Privacy Policy / Cookie Policy

Slack