Kestra, Open source declarative data orchestrationKestra, Open source declarative data orchestration
  • Product
    • Features
      Discover all the features of Kestra

    • Enterprise Edition
      Security and High Availability for enterprise

    • Declarative Orchestration
      Simplified data workflow creation and execution with YAML

  • Solutions
    • Usages & Use Cases
      Uncover a wide range of use cases

    • CI/CD for your Kestra Workflows
      Treat your workflow as code and embrace CI/CD practices

    • Modern Data Stack Integration
      Integrate leading data tools with Kestra

    • Change Data Capture
      Leverage Kestra's Change Data Capture capabilities

  • Docs
    • Documentation
      Get started with Kestra

    • Plugins documentation
      Extends Kestra with many plugins

  • Community
    • Community Overview
      Connect with peers and exchange ideas

    • Blogs
      Product updates, user stories, and more

  • Company
    • About us
      Discover our story and our team

    • Careers
      Join an open company

    • Contact us
      Extends Kestra with many plugins

  • Star us Book a demo Get Started Search
  • Core
    • Conditions
      • DateTimeBetweenCondition
      • DayWeekCondition
      • DayWeekInMonthCondition
      • ExecutionFlowCondition
      • ExecutionNamespaceCondition
      • ExecutionStatusCondition
      • FlowCondition
      • FlowNamespaceCondition
      • HasRetryAttemptCondition
      • MultipleCondition
      • NotCondition
      • OrCondition
      • VariableCondition
      • WeekendCondition
    • Tasks
      • Debugs
        • Echo
        • Return
      • Executions
        • Counts
        • Fail
      • Flows
        • AllowFailure
        • EachParallel
        • EachSequential
        • Flow
        • If
        • Parallel
        • Pause
        • Sequential
        • Switch
        • Template
        • Worker
      • Log
        • Fetch
        • Log
      • Scripts
        • Bash
        • Node
        • Python
      • States
        • Delete
        • Get
        • Set
      • Storages
        • Concat
        • Delete
        • Purge
        • PurgeExecution
        • Size
        • Split
    • Triggers
      • Flow
      • Schedule
      • Webhook
  • Actian Vector
    • Tasks
      • Batch
      • Query
    • Triggers
      • Trigger
  • Airbyte
    • Tasks
      • CloudJobs
        • Reset
        • Sync
      • Connections
        • Sync
  • Amazon Redshift
    • Tasks
      • Query
    • Triggers
      • Trigger
  • AMQP
    • Tasks
      • Consume
      • CreateQueue
      • DeclareExchange
      • Publish
      • QueueBind
    • Triggers
      • Trigger
  • Apache Cassandra
    • Tasks
      • Query
  • Apache Kafka
    • Tasks
      • Consume
      • Produce
    • Triggers
      • Trigger
  • Apache Pinot
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Apache Pulsar
    • Tasks
      • Consume
      • Produce
      • Reader
    • Triggers
      • Trigger
  • Apache Spark
    • Tasks
      • JarSubmit
      • PythonSubmit
      • RSubmit
  • Apache Tika
    • Tasks
      • Parse
  • AWS
    • Tasks
      • Dynamodb
        • DeleteItem
        • GetItem
        • PutItem
        • Query
        • Scan
      • S3
        • Copy
        • CreateBucket
        • Delete
        • DeleteList
        • Download
        • Downloads
        • List
        • Upload
      • Sns
        • Publish
      • Sqs
        • Consume
        • Publish
    • Triggers
      • S3
        • Trigger
      • Sqs
        • Trigger
  • Azure
    • Tasks
      • BatchJob
        • Create
      • BatchPool
        • Resize
      • StorageBlob
        • Copy
        • Delete
        • DeleteList
        • Download
        • Downloads
        • List
        • SharedAccess
        • Upload
      • StorageTable
        • Bulk
        • Delete
        • Get
        • List
    • Triggers
      • StorageBlob
        • Trigger
  • ClickHouse
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Compression
    • Tasks
      • ArchiveCompress
      • ArchiveDecompress
      • FileCompress
      • FileDecompress
  • Couchbase
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Cryptography
    • Tasks
      • Openpgp
        • Decrypt
        • Encrypt
  • Dbt
    • Tasks
      • Cli
        • Build
        • Compile
        • Deps
        • Freshness
        • List
        • Run
        • Seed
        • Setup
        • Snapshot
        • Test
      • Cloud
        • TriggerRun
  • Debezium Microsoft SQL Server
    • Tasks
      • Capture
    • Triggers
      • Trigger
  • Debezium MySQL
    • Tasks
      • Capture
    • Triggers
      • Trigger
  • Debezium PostgreSQL
    • Tasks
      • Capture
    • Triggers
      • Trigger
  • DuckDB
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Elasticsearch
    • Tasks
      • Bulk
      • Get
      • Load
      • Put
      • Request
      • Scroll
      • Search
  • File system
    • Tasks
      • Ftp
        • Delete
        • Download
        • Downloads
        • List
        • Move
        • Upload
      • Ftps
        • Delete
        • Download
        • Downloads
        • List
        • Move
        • Upload
      • Http
        • Download
        • Request
      • Sftp
        • Delete
        • Download
        • Downloads
        • List
        • Move
        • Upload
      • Ssh
        • Command
    • Triggers
      • Ftp
        • Trigger
      • Ftps
        • Trigger
      • Sftp
        • Trigger
  • Fivetran
    • Tasks
      • Connectors
        • Sync
  • Git
    • Tasks
      • Clone
  • Google Cloud
    • Tasks
      • Auth
        • OauthAccessToken
      • Bigquery
        • Copy
        • CopyPartitions
        • CreateDataset
        • CreateTable
        • DeleteDataset
        • DeletePartitions
        • DeleteTable
        • ExtractToGcs
        • Load
        • LoadFromGcs
        • Query
        • StorageWrite
        • TableMetadata
        • UpdateDataset
        • UpdateTable
      • DataprocBatches
        • PySparkSubmit
        • RSparkSubmit
        • SparkSqlSubmit
        • SparkSubmit
      • Firestore
        • Delete
        • Get
        • Query
        • Set
      • Gcs
        • Compose
        • Copy
        • CreateBucket
        • CreateBucketIamPolicy
        • Delete
        • DeleteBucket
        • DeleteList
        • Download
        • Downloads
        • List
        • UpdateBucket
        • Upload
      • Gke
        • ClusterMetadata
      • Pubsub
        • Consume
        • Publish
      • Vertexai
        • CustomJob
    • Triggers
      • Bigquery
        • Trigger
      • Gcs
        • Trigger
      • Pubsub
        • Trigger
  • Google Workspace
    • Tasks
      • Drive
        • Create
        • Delete
        • Download
        • Export
        • List
        • Upload
      • Sheets
        • Read
        • ReadRange
  • Groovy
    • Tasks
      • Eval
      • FileTransform
  • Jython
    • Tasks
      • Eval
      • FileTransform
  • Kubernetes
    • Tasks
      • PodCreate
  • Microsoft SQL Server
    • Tasks
      • Batch
      • Query
    • Triggers
      • Trigger
  • MongoDB
    • Tasks
      • Bulk
      • Delete
      • Find
      • InsertOne
      • Load
      • Update
  • MQTT
    • Tasks
      • Publish
      • Subscribe
    • Triggers
      • Trigger
  • MySQL
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Nashorn
    • Tasks
      • Eval
      • FileTransform
  • NATS
    • Tasks
      • Consume
      • Produce
    • Triggers
      • Trigger
  • Neo4j
    • Tasks
      • Batch
      • Query
  • Notifications
    • Tasks
      • Mail
        • MailExecution
        • MailSend
      • Slack
        • SlackExecution
        • SlackIncomingWebhook
      • Teams
        • TeamsExecution
        • TeamsIncomingWebhook
  • Oracle
    • Tasks
      • Batch
      • Query
    • Triggers
      • Trigger
  • PostgreSQL
    • Tasks
      • Batch
      • CopyIn
      • CopyOut
      • Query
    • Triggers
      • Trigger
  • Power BI
    • Tasks
      • RefreshGroupDataset
  • Redis
    • Tasks
      • Delete
      • Get
      • ListPop
      • ListPush
      • Publish
      • Set
    • Triggers
      • TriggerList
  • Rockset
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Serialization
    • Tasks
      • Avro
        • AvroConverter
        • AvroReader
        • AvroWriter
      • Csv
        • CsvReader
        • CsvWriter
      • Json
        • JsonReader
        • JsonWriter
      • Parquet
        • ParquetReader
        • ParquetWriter
      • Xml
        • XmlReader
        • XmlWriter
  • ServiceNow
    • Tasks
      • Post
  • Singer
    • Tasks
      • Taps
        • BigQuery
        • BingAds
        • ChargeBee
        • ExchangeRateHost
        • FacebookAds
        • Fastly
        • GitHub
        • Gitlab
        • GoogleAdwords
        • GoogleAnalytics
        • GoogleSearchConsole
        • Marketo
        • Netsuite
        • PipelinewiseMongoDb
        • PipelinewiseMysql
        • PipelinewiseOracle
        • PipelinewisePostgres
        • Quickbooks
        • Recharge
        • SageIntacct
        • Salesforce
        • Shopify
        • Slack
        • Stripe
        • Zendesk
        • Zoom
      • Targets
        • AdswerveBigQuery
        • Csv
        • DatamillCoPostgres
        • Json
        • MeltanoSnowflake
        • PipelinewisePostgres
        • PipelinewiseRedshift
  • Snowflake
    • Tasks
      • Download
      • Query
      • Upload
    • Triggers
      • Trigger
  • Soda
    • Tasks
      • Scan
  • Trino
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Vertica
    • Tasks
      • Batch
      • Query
    • Triggers
      • Trigger
PLUGINSPLUGIN-SODA

​Soda

Table of Contents
  • Tasks
Contribute
  • Join us on Slack
  • GitHub
  • Twitter
  • LinkedIn

Soda

Enhance data quality with Soda integration in Kestra workflows.

This sub-group of plugins contains tasks for using Soda. Soda allows everyone on your data team to find, analyze, and resolve data issues.

Tasks

  • Scan
PluginsCore
Kestra's logo

Open Source Declarative Data Orchestration

Product
  • Features
  • Connectors
  • Enterprise Edition
Solutions
  • Usages
  • For Companies
Community
  • Blogs
  • Slack
  • Github
Docs
  • Documentation
  • Plugins documentation
  • Terraform provider
  • Administrator guide
Company
  • About us
  • Careers
  • Contact us

© 2023 Kestra Technologies. Developed with in the 🌎.

Privacy Policy / Cookie Policy

Slack