![\"Kestra](\"https://kestra.io/banner.png\")
\n \n\n \n \n \n
![\"Last](\"https://img.shields.io/github/v/tag/kestra-io/kestra.svg?sort=semver&include_prereleases&color=blueviolet\")
\n ![\"License\"](\"https://img.shields.io/github/license/kestra-io/kestra?color=blueviolet\")
\n ![\"Github](\"https://img.shields.io/github/stars/kestra-io/kestra?color=blueviolet&logo=github\")
![\"Kestra](\"https://img.shields.io/badge/Website-kestra.io-192A4E?color=blueviolet\"){kind=icon}
\n![\"Slack\"](\"https://img.shields.io/badge/Slack-Join%20Community-blueviolet?logo=slack\"){kind=icon}
\n\n \n \n \n
![\"Kestra](\"https://api.producthunt.com/widgets/embed-image/v1/top-post-badge.svg?post_id=612077&theme=light&period=daily&t=1740737506162\"){kind=icon}
\n
\n \n ![\"Get](\"https://kestra.io/startvideo.png\")
\n \n
Click on the image to learn how to get started with Kestra in 3 minutes.
\n\n\n## š What is Kestra?\n\nKestra is an open-source, event-driven orchestration platform for data, AI, and infrastructure workflows. It unifies **scheduled** and **event-driven** automation behind a declarative, language-agnostic interface. By bringing **Infrastructure as Code** best practices to your data, process, and microservice pipelines, you can build reliable [workflows](https://kestra.io/docs/quickstart) directly from the UI in just a few lines of YAML.\n\n## š Table of Contents\n\n- [š Quick Start](#-quick-start)\n- [š§© Plugin Ecosystem](#-plugin-ecosystem)\n- [š Key Concepts](#-key-concepts)\n- [šØ Build Workflows Visually](#-build-workflows-visually)\n- [š§ Extensible and Developer-Friendly](#-extensible-and-developer-friendly)\n- [š Join the Community](#-join-the-community)\n- [š¤ Contributing](#-contributing)\n- [š License](#-license)\n- [āļø Stay Updated](#ļø-stay-updated)\n\n\n\n**Key Features:**\n- **Everything as Code and from the UI:** keep **workflows as code** with a **Git Version Control** integration, even when building them from the UI.\n- **Event-Driven & Scheduled Workflows:** automate both **scheduled** and **real-time** event-driven workflows via a simple `trigger` definition.\n- **Declarative YAML Interface:** define workflows using a simple configuration in the **built-in code editor**.\n- **Rich Plugin Ecosystem:** hundreds of plugins built in to extract data from any database, cloud storage, or API, and **run scripts in any language**.\n- **Intuitive UI & Code Editor:** build and visualize workflows directly from the UI with syntax highlighting, auto-completion and real-time syntax validation.\n- **Scalable:** designed to handle millions of workflows, with high availability and fault tolerance.\n- **Version Control Friendly:** write your workflows from the built-in code Editor and push them to your preferred Git branch directly from Kestra, enabling best practices with CI/CD pipelines and version control systems.\n- **Structure & Resilience**: tame chaos and bring resilience to your workflows with **namespaces**, **labels**, **subflows**, **retries**, **timeout**, **error handling**, **inputs**, **outputs** that generate artifacts in the UI, **variables**, **conditional branching**, **advanced scheduling**, **event triggers**, **backfills**, **dynamic tasks**, **sequential and parallel tasks**, and skip tasks or triggers when needed by setting the flag `disabled` to `true`.\n\n\nš§āš» The YAML definition gets automatically adjusted any time you make changes to a workflow from the UI or via an API call. Therefore, the orchestration logic is **always managed declaratively in code**, even if you modify your workflows in other ways (UI, CI/CD, Terraform, API calls).\n\n---\n\n## š Quick Start\n\n### Launch on AWS (CloudFormation)\n\nDeploy Kestra on AWS using our CloudFormation template:\n\n[](https://console.aws.amazon.com/cloudformation/home#/stacks/create/review?templateURL=https://kestra-deployment-templates.s3.eu-west-3.amazonaws.com/aws/cloudformation/ec2-rds-s3/kestra-oss.yaml&stackName=kestra-oss)\n\n### Launch on Google Cloud (Terraform deployment)\n\nDeploy Kestra on Google Cloud Infrastructure Manager using [our Terraform module](https://github.com/kestra-io/deployment-templates/tree/main/gcp/terraform/infrastructure-manager/vm-sql-gcs).\n\n### Get Started Locally in 5 Minutes\n\n#### Launch Kestra in Docker\n\nMake sure that Docker is running. Then, start Kestra in a single command:\n\n```bash\ndocker run --pull=always -it -p 8080:8080 --user=root \\\n --name kestra --restart=always \\\n -v kestra_data:/app/storage \\\n -v /var/run/docker.sock:/var/run/docker.sock \\\n -v /tmp:/tmp \\\n kestra/kestra:latest server local\n```\n\nIf you're on Windows and use PowerShell:\n```powershell\ndocker run --pull=always -it -p 8080:8080 --user=root `\n --name kestra --restart=always `\n -v \"kestra_data:/app/storage\" `\n -v \"/var/run/docker.sock:/var/run/docker.sock\" `\n -v \"C:/Temp:/tmp\" `\n kestra/kestra:latest server local\n```\n\nIf you're on Windows and use Command Prompt (CMD):\n```cmd\ndocker run --pull=always -it -p 8080:8080 --user=root ^\n --name kestra --restart=always ^\n -v \"kestra_data:/app/storage\" ^\n -v \"/var/run/docker.sock:/var/run/docker.sock\" ^\n -v \"C:/Temp:/tmp\" ^\n kestra/kestra:latest server local\n```\n\nIf you're on Windows and use WSL (Linux-based environment in Windows):\n```bash\ndocker run --pull=always -it -p 8080:8080 --user=root \\\n --name kestra --restart=always \\\n -v kestra_data:/app/storage \\\n -v \"/var/run/docker.sock:/var/run/docker.sock\" \\\n -v \"/mnt/c/Temp:/tmp\" \\\n kestra/kestra:latest server local\n```\n\nCheck our [Installation Guide](https://kestra.io/docs/installation) for other deployment options (Docker Compose, Podman, Kubernetes, AWS, GCP, Azure, and more).\n\nAccess the Kestra UI at [http://localhost:8080](http://localhost:8080) and start building your first flow!\n\n#### Your First Hello World Flow\n\nCreate a new flow with the following content:\n\n```yaml\nid: hello_world\nnamespace: dev\n\ntasks:\n - id: say_hello\n type: io.kestra.plugin.core.log.Log\n message: \"Hello, World!\"\n```\n\n\nRun the flow and see the output in the UI!\n\n---\n\n## š§© Plugin Ecosystem\n\nKestra's functionality is extended through a rich [ecosystem of plugins](https://kestra.io/plugins) that empower you to run tasks anywhere and code in any language, including Python, Node.js, R, Go, Shell, and more. Here's how Kestra plugins enhance your workflows:\n\n- **Run Anywhere:**\n - **Local or Remote Execution:** Execute tasks on your local machine, remote servers via SSH, or scale out to serverless containers using [Task Runners](https://kestra.io/docs/task-runners).\n - **Docker and Kubernetes Support:** Seamlessly run Docker containers within your workflows or launch Kubernetes jobs to handle compute-intensive workloads.\n\n- **Code in Any Language:**\n - **Scripting Support:** Write scripts in your preferred programming language. Kestra supports Python, Node.js, R, Go, Shell, and others, allowing you to integrate existing codebases and deployment patterns.\n - **Flexible Automation:** Execute shell commands, run SQL queries against various databases, and make HTTP requests to interact with APIs.\n\n- **Event-Driven and Real-Time Processing:**\n - **Real-Time Triggers:** React to events from external systems in real-time, such as file arrivals, new messages in message buses (Kafka, Redis, Pulsar, AMQP, MQTT, NATS, AWS SQS, Google Pub/Sub, Azure Event Hubs), and more.\n - **Custom Events:** Define custom events to trigger flows based on specific conditions or external signals, enabling highly responsive workflows.\n\n- **Cloud Integrations:**\n - **AWS, Google Cloud, Azure:** Integrate with a variety of cloud services to interact with storage solutions, messaging systems, compute resources, and more.\n - **Big Data Processing:** Run big data processing tasks using tools like Apache Spark or interact with analytics platforms like Google BigQuery.\n\n- **Monitoring and Notifications:**\n - **Stay Informed:** Send messages to Slack channels, email notifications, or trigger alerts in PagerDuty to keep your team","default_branch":"develop","files":5090,"tree":["\n\n--- Changes ---\n\n",".codespellrc",".devcontainer/Dockerfile",".devcontainer/README.md",".devcontainer/devcontainer.json",".editorconfig",".gitattributes",".github/.hooks/pre-commit",".github/.hooks/setup_hooks.sh",".github/CODE_OF_CONDUCT.md",".github/CONTRIBUTING.md",".github/ISSUE_TEMPLATE/bug.yml",".github/ISSUE_TEMPLATE/config.yml",".github/ISSUE_TEMPLATE/feature.yml",".github/actions/ee-compile-check/action.yml",".github/assets/node_option_env_var.png",".github/assets/run-app.png",".github/dependabot.yml",".github/pull_request_template.md",".github/workflows/auto-translate-ui-keys.yml",".github/workflows/codeql-analysis.yml",".github/workflows/codespell.yml",".github/workflows/dependency-submission.yml",".github/workflows/e2e-scheduling.yml",".github/workflows/ee-compile-check-manual.yml",".github/workflows/ee-openapi-result.yml",".github/workflows/global-create-new-release-branch.yml",".github/workflows/global-push-base-image.yml",".github/workflows/global-start-release.yml",".github/workflows/main-build.yml",".github/workflows/pre-release.yml",".github/workflows/publish-design-system.yml",".github/workflows/publish-hey-api-plugin.yml",".github/workflows/pull-request-cleanup.yml",".github/workflows/pull-request.yml",".github/workflows/release-docker.yml",".github/workflows/sync-slot-contracts.yml",".github/workflows/update-generated-sdk.yml",".github/workflows/update-plugin-count.yml",".github/workflows/vulnerabilities-check.yml",".github/workflows/welcome.yml",".gitignore",".gitpod.yml",".prettierignore","AGENTS.md","CLAUDE.md","Dockerfile","Dockerfile.base","Dockerfile.pr","LICENSE","Makefile","README.md","SECURITY.md","build-and-start-e2e-tests.sh","build.gradle","charts/kestra-starter/.helmignore","charts/kestra-starter/Chart.lock","charts/kestra-starter/Chart.yaml","charts/kestra-starter/LICENSE","charts/kestra-starter/README.md","charts/kestra-starter/README.md.gotmpl","charts/kestra-starter/templates/secret.yaml","charts/kestra-starter/templates/service.yaml","charts/kestra-starter/templates/statefulset.yaml","charts/kestra-starter/values.yaml","charts/kestra/.helmignore","charts/kestra/Chart.yaml","charts/kestra/LICENSE","charts/kestra/README.md","charts/kestra/README.md.gotmpl","charts/kestra/templates/_helpers.tpl","charts/kestra/templates/checks.yaml","charts/kestra/templates/configmap.yaml","charts/kestra/templates/deployment.yaml","charts/kestra/templates/extra-manifests.yaml","charts/kestra/templates/ingress.yaml","charts/kestra/templates/service.yaml","charts/kestra/templates/serviceaccount.yaml","charts/kestra/tests/deployment_progress_deadline_test.yaml","charts/kestra/tests/deployment_replicas_test.yaml","charts/kestra/tests/jvm_active_processor_test.yaml","charts/kestra/values-testing.yaml","charts/kestra/values.yaml","cli/build.gradle","cli/src/main/java/io/kestra/cli/AbstractApiCommand.java","cli/src/main/java/io/kestra/cli/AbstractCommand.java","cli/src/main/java/io/kestra/cli/AbstractValidateCommand.java","cli/src/main/java/io/kestra/cli/BaseCommand.java","cli/src/main/java/io/kestra/cli/Kestra.java","cli/src/main/java/io/kestra/cli/StandAloneRunner.java","cli/src/main/java/io/kestra/cli/VersionProvider.java","cli/src/main/java/io/kestra/cli/commands/AbstractServiceNamespaceUpdateCommand.java","cli/src/main/java/io/kestra/cli/commands/configs/sys/ConfigCommand.java","cli/src/main/java/io/kestra/cli/commands/configs/sys/ConfigPropertiesCommand.java","cli/src/main/java/io/kestra/cli/commands/configs/sys/ConfigValidateCommand.java","cli/src/main/java/io/kestra/cli/commands/flows/FlowCommand.java","cli/src/main/java/io/kestra/cli/commands/flows/FlowDeleteCommand.java","cli/src/main/java/io/kestra/cli/commands/flows/FlowDotCommand.java","cli/src/main/java/io/kestra/cli/commands/flows/FlowExportCommand.java","cli/src/main/java/io/kestra/cli/commands/flows/FlowTestCommand.java","cli/src/main/java/io/kestra/cli/commands/flows/FlowsSyncFromSourceCommand.java","cli/src/main/java/io/kestra/cli/commands/migrations/AbstractMigrationCommand.java","cli/src/main/java/io/kestra/cli/commands/migrations/MigrationCommand.java","cli/src/main/java/io/kestra/cli/commands/migrations/PlanMigrationCommand.java","cli/src/main/java/io/kestra/cli/commands/migrations/RepairMigrationCommand.java","cli/src/main/java/io/kestra/cli/commands/migrations/RunMigrationCommand.java","cli/src/main/java/io/kestra/cli/commands/migrations/UnlockMigrationCommand.java","cli/src/main/java/io/kestra/cli/commands/migrations/V2ExecutionResubmitMigrationCommand.java","cli/src/main/java/io/kestra/cli/commands/namespaces/NamespaceCommand.java","cli/src/main/java/io/kestra/cli/commands/namespaces/kv/KvCommand.java","cli/src/main/java/io/kestra/cli/commands/namespaces/kv/KvUpdateCommand.java","cli/src/main/java/io/kestra/cli/commands/plugins/PluginCommand.java","cli/src/main/java/io/kestra/cli/commands/plugins/PluginDocCommand.java","cli/src/main/java/io/kestra/cli/commands/plugins/PluginInstallCommand.java","cli/src/main/java/io/kestra/cli/commands/plugins/PluginListCommand.java","cli/src/main/java/io/kestra/cli/commands/plugins/PluginSearchCommand.java","cli/src/main/java/io/kestra/cli/commands/plugins/PluginUninstallCommand.java","cli/src/main/java/io/kestra/cli/commands/servers/AbstractServerCommand.java","cli/src/main/java/io/kestra/cli/commands/servers/ControllerCommand.java","cli/src/main/java/io/kestra/cli/commands/servers/ExecutorCommand.java","cli/src/main/java/io/kestra/cli/commands/servers/IndexerCommand.java","cli/src/main/java/io/kestra/cli/commands/servers/LocalCommand.java","cli/src/main/java/io/kestra/cli/commands/servers/SchedulerCommand.java","cli/src/main/java/io/kestra/cli/commands/servers/ServerCommand.java","cli/src/main/java/io/kestra/cli/commands/servers/ServerCommandInterface.java","cli/src/main/java/io/kestra/cli/commands/servers/StandAloneCommand.java","cli/src/main/java/io/kestra/cli/commands/servers/WebServerCommand.java","cli/src/main/java/io/kestra/cli/commands/servers/WorkerCommand.java","cli/src/main/java/io/kestra/cli/commands/sys/ReindexCommand.java","cli/src/main/java/io/kestra/cli/commands/sys/SubmitQueuedCommand.java","cli/src/main/java/io/kestra/cli/commands/sys/SysCommand.java","cli/src/main/java/io/kestra/cli/listeners/DeleteConfigurationApplicationListeners.java","cli/src/main/java/io/kestra/cli/listeners/GracefulEmbeddedServiceShutdownListener.java","cli/src/main/java/io/kestra/cli/logger/StackdriverJsonLayout.java","cli/src/main/java/io/kestra/cli/schema/ConfigurationSchemaCommand.java","cli/src/main/java/io/kestra/cli/schema/ConfigurationSchemaGenerator.java","cli/src/main/java/io/kestra/cli/services/DefaultEnvironmentProvider.java","cli/src/main/java/io/kestra/cli/services/DefaultStartupHook.java","cli/src/main/java/io/kestra/cli/services/EnvironmentProvider.java","cli/src/main/java/io/kestra/cli/services/FileChangedEventListener.java","cli/src/main/java/io/kestra/cli/services/FlowFilesManager.java","cli/src/main/java/io/kestra/cli/services/LocalFlowFileWatcher.java","cli/src/main/java/io/kestra/cli/services/StartupHookInterface.java","cli/src/main/java/io/kestra/cli/services/TenantIdSelectorService.java","cli/src/main/resources/META-INF/services/io.kestra.cli.services.EnvironmentProvider","cli/src/main/resources/application.yml","cli/src/main/resources/logback.xml","cli/src/test/java/io/kestra/cli/KestraTest.java","cli/src/test/java/io/kestra/cli/commands/configs/sys/ConfigPropertiesCommandTest.java","cli/src/test/java/io/kestra/cli/commands/configs/sys/ConfigValidateCommandTest.java","cli/src/test/java/io/kestra/cli/commands/configs/sys/NoConfigCommandTest.java","cli/src/test/java/io/kestra/cli/commands/flows/FlowDotCommandTest.java","cli/src/test/java/io/kestra/cli/commands/flows/FlowExportCommandTest.java","cli/src/test/java/io/kestra/cli/commands/flows/FlowTestCommandTest.java","cli/src/test/java/io/kestra/cli/commands/migrations/MigrationApplicationContextTest.java","cli/src/test/java/io/kestra/cli/commands/migrations/PlanMigrationCommandTest.java","cli/src/test/java/io/kestra/cli/commands/migrations/RepairMigrationCommandTest.java","cli/src/test/java/io/kestra/cli/commands/migrations/RunMigrationCommandTest.java","cli/src/test/java/io/kestra/cli/commands/migrations/UnlockMigrationCommandTest.java","cli/src/test/java/io/kestra/cli/commands/migrations/V2ExecutionResubmitMigrationCommandTest.java","cli/src/test/java/io/kestra/cli/commands/namespaces/NamespaceCommandTest.java","cli/src/test/java/io/kestra/cli/commands/namespaces/kv/KvCommandTest.java","cli/src/test/java/io/kestra/cli/commands/namespaces/kv/KvUpdateCommandTest.java","cli/src/test/java/io/kestra/cli/commands/plugins/PluginCommandTest.java","cli/src/test/java/io/kestra/cli/commands/plugins/PluginDocCommandTest.java","cli/src/test/java/io/kestra/cli/commands/plugins/PluginInstallCommandTest.java","cli/src/test/java/io/kestra/cli/commands/plugins/PluginListCommandTest.java","cli/src/test/java/io/kestra/cli/commands/plugins/PluginSearchCommandTest.java","cli/src/test/java/io/kestra/cli/commands/servers/TenantIdSelectorServiceTest.java","cli/src/test/java/io/kestra/cli/commands/servers/WorkerServerContextTest.java","cli/src/test/java/io/kestra/cli/commands/sys/ReindexCommandTest.java","cli/src/test/java/io/kestra/cli/listeners/DeleteConfigurationApplicationListenersTest.java","cli/src/test/java/io/kestra/cli/schema/ConfigurationSchemaGeneratorTest.java","cli/src/test/java/io/kestra/cli/services/FileChangedEventListenerTest.java","cli/src/test/resources/application-file-watch.yml","cli/src/test/resources/application-test.yml","cli/src/test/resources/crudFlow/date.yml","cli/src/test/resources/flows/quattro.yml","cli/src/test/resources/flows/same/first.yaml","cli/src/test/resources/flows/same/flowsSubFolder/third.yaml","cli/src/test/resources/flows/same/second.yaml","cli/src/test/resources/helper/include.yaml","cli/src/test/resources/helper/lorem-multiple.txt","cli/src/test/resources/helper/lorem.txt","cli/src/test/resources/invalids/empty.yaml","cli/src/test/resources/invalidsTemplates/template.yml","cli/src/test/resources/logback.xml","cli/src/test/resources/namespacefiles/ignore/.kestraignore","cli/src/test/resources/namespacefiles/ignore/1","cli/src/test/resources/namespacefiles/ignore/2","cli/src/test/resources/namespacefiles/ignore/flows/flow.yml","cli/src/test/resources/namespacefiles/noignore/1","cli/src/test/resources/namespacefiles/noignore/2","cli/src/test/resources/namespacefiles/noignore/flows/flow.yml","cli/src/test/resources/plugins/plugin-template-test-0.24.0-SNAPSHOT.jar","cli/src/test/resources/templates/template-2.yml","cli/src/test/resources/templates/template.yml","cli/src/test/resources/templates/templatesSubFolder/template-3.yml","cli/src/test/resources/warning/flow-with-warning.yaml","codecov.yml","core/build.gradle","core/src/main/java/io/kestra/core/ai/agent/models/AgentMessage.java","core/src/main/java/io/kestra/core/ai/agent/models/AgentMessageRole.java","core/src/main/java/io/kestra/core/ai/agent/models/AgentMessageType.java","core/src/main/java/io/kestra/core/ai/agent/models/AgentMode.java","core/src/main/java/io/kestra/core/ai/agent/models/AgentPrincipal.java","core/src/main/java/io/kestra/core/ai/agent/models/AgentThinking.java","core/src/main/java/io/kestra/core/ai/agent/models/AgentThread.java","core/src/main/java/io/kestra/core/ai/agent/models/AgentThreadStatus.java","core/src/main/java/io/kestra/core/ai/agent/models/AgentToolCall.java","core/src/main/java/io/kestra/core/ai/agent/models/AgentToolFamily.java","core/src/main/java/io/kestra/core/ai/agent/models/AgentWritePolicy.java","core/src/main/java/io/kestra/core/ai/agent/models/ArtefactDraft.java","core/src/main/java/io/kestra/core/ai/agent/models/ArtefactKind.java","core/src/main/java/io/kestra/core/ai/agent/repositories/AiMessageRepositoryInterface.java","core/src/main/java/io/kestra/core/ai/agent/repositories/AiThreadRepositoryInterface.java","core/src/main/java/io/kestra/core/annotations/Retryable.java","core/src/main/java/io/kestra/core/app/AppBlockInterface.java","core/src/main/java/io/kestra/core/app/AppPluginInterface.java","core/src/main/java/io/kestra/core/assets/AssetManagerFactory.java","core/src/main/java/io/kestra/core/assets/AssetService.java","core/src/main/java/io/kestra/core/async/AsyncEventStreamingService.java","core/src/main/java/io/kestra/core/async/AsyncOperation.java","core/src/main/java/io/kestra/core/async/AsyncOperationProcessedEvent.java","core/src/main/java/io/kestra/core/async/AsyncOperationService.java","core/src/main/java/io/kestra/core/async/AsyncOperationsConfiguration.java","core/src/main/java/io/kestra/core/cache/NoopCache.java","core/src/main/java/io/kestra/core/contexts/KestraBeansFactory.java","core/src/main/java/io/kestra/core/contexts/KestraContext.java","core/src/main/java/io/kestra/core/contexts/MavenPluginRepositoryConfig.java","core/src/main/java/io/kestra/core/contexts/configuration/KestraConfiguration.java","core/src/main/java/io/kestra/core/contexts/configuration/RepositoryConfiguration.java","core/src/main/java/io/kestra/core/contexts/configuration/StorageConfiguration.java","core/src/main/java/io/kestra/core/contexts/configuration/SystemFlowsConfiguration.java","core/src/main/java/io/kestra/core/debug/Breakpoint.java","core/src/main/java/io/kestra/core/docs/AbstractClassDocumentation.java","core/src/main/java/io/kestra/core/docs/ClassInputDocumentation.java","core/src/main/java/io/kestra/core/docs/ClassPluginDocumentation.java","core/src/main/java/io/kestra/core/docs/Document.java","core/src/main/java/io/kestra/core/docs/DocumentationGenerator.java","core/src/main/java/io/kestra/core/docs/DocumentationWithSchema.java","core/src/main/java/io/kestra/core/docs/InputType.java","core/src/main/java/io/kestra/core/docs/JsonSchemaCache.java","core/src/main/java/io/kestra/core/docs/JsonSchemaGenerator.java","core/src/main/java/io/kestra/core/docs/Plugin.java","core/src/main/java/io/kestra/core/docs/PluginIcon.java","core/src/main/java/io/kestra/core/docs/Schema.java","core/src/main/java/io/kestra/core/docs/SchemaType.java","core/src/main/java/io/kestra/core/encryption/EncryptionConfig.java","core/src/main/java/io/kestra/core/encryption/EncryptionService.java","core/src/main/java/io/kestra/core/endpoints/BasicAuthEndpointsFilter.java","core/src/main/java/io/kestra/core/endpoints/EndpointBasicAuthConfiguration.java","core/src/main/java/io/kestra/core/events/CrudEvent.java","core/src/main/java/io/kestra/core/events/CrudEventType.java","core/src/main/java/io/kestra/core/events/EventId.java","core/src/main/java/io/kestra/core/exceptions/ConflictException.java","core/src/main/java/io/kestra/core/exceptions/CyclicGraphException.java","core/src/main/java/io/kestra/core/exceptions/DeserializationException.java","core/src/main/java/io/kestra/core/exceptions/FlowBlockedException.java","core/src/main/java/io/kestra/core/exceptions/FlowNotFoundException.java","core/src/main/java/io/kestra/core/exceptions/FlowProcessingException.java","core/src/main/java/io/kestra/core/exceptions/IllegalConditionEvaluation.java","core/src/main/java/io/kestra/core/exceptions/IllegalVariableEvaluationException.java","core/src/main/java/io/kestra/core/exceptions/InputOutputValidationException.java","core/src/main/java/io/kestra/core/exceptions/InternalException.java","core/src/main/java/io/kestra/core/exceptions/InvalidException.java","core/src/main/java/io/kestra/core/exceptions/InvalidQueryFiltersException.java","core/src/main/java/io/kestra/core/exceptions/InvalidSourceSearchQueryException.java","core/src/main/java/io/kestra/core/exceptions/InvalidTriggerConfigurationException.java","core/src/main/java/io/kestra/core/exceptions/KestraException.java","core/src/main/java/io/kestra/core/exceptions/KestraRuntimeException.java","core/src/main/java/io/kestra/core/exceptions/KilledException.java","core/src/main/java/io/kestra/core/exceptions/MigrationRequiredException.java","core/src/main/java/io/kestra/core/exceptions/NoMatchingWorkerQueueException.java","core/src/main/java/io/kestra/core/exceptions/NotFoundException.java","core/src/main/java/io/kestra/core/exceptions/ResourceAccessDeniedException.java","core/src/main/java/io/kestra/core/exceptions/ResourceExpiredException.java","core/src/main/java/io/kestra/core/exceptions/TaskNotFoundException.java","core/src/main/java/io/kestra/core/exceptions/TimeoutExceededException.java","core/src/main/java/io/kestra/core/exceptions/TypeConversionException.java","core/src/main/java/io/kestra/core/exceptions/ValidationErrorException.java","core/src/main/java/io/kestra/core/executor/WorkerJobRunningStateStore.java","core/src/main/java/io/kestra/core/executor/command/ChangeTaskRunState.java","core/src/main/java/io/kestra/core/executor/command/Create.java","core/src/main/java/io/kestra/core/executor/command/ExecutionCommand.java","core/src/main/java/io/kestra/core/executor/command/ExecutionCommandType.java","core/src/main/java/io/kestra/core/executor/command/ForceRun.java","core/src/main/java/io/kestra/core/executor/command/Pause.java","core/src/main/java/io/kestra/core/executor/command/Replay.java","core/src/main/java/io/kestra/core/executor/command/Restart.java","core/src/main/java/io/kestra/core/executor/command/Resume.java","core/src/main/java/io/kestra/core/executor/command/ResumeFromBreakpoint.java","core/src/main/java/io/kestra/core/executor/command/Unqueue.java","core/src/main/java/io/kestra/core/executor/command/UpdateLabels.java","core/src/main/java/io/kestra/core/executor/command/UpdateStatus.java","core/src/main/java/io/kestra/core/http/HttpRequest.java","core/src/main/java/io/kestra/core/http/HttpResponse.java","core/src/main/java/io/kestra/core/http/HttpService.java","core/src/main/java/io/kestra/core/http/HttpSseEvent.java","core/src/main/java/io/kestra/core/http/client/HttpClient.java","core/src/main/java/io/kestra/core/http/client/HttpClientException.java","core/src/main/java/io/kestra/core/http/client/HttpClientRequestException.java","core/src/main/java/io/kestra/core/http/client/HttpClientResponseException.java","core/src/main/java/io/kestra/core/http/client/apache/AbstractLoggingInterceptor.java","core/src/main/java/io/kestra/core/http/client/apache/FailedResponseInterceptor.java","core/src/main/java/io/kestra/core/http/client/apache/HttpResponseFailure.java","core/src/main/java/io/kestra/core/http/client/apache/LoggingRequestInterceptor.java","core/src/main/java/io/kestra/core/http/client/apache/LoggingResponseInterceptor.java","core/src/main/java/io/kestra/core/http/client/apache/RunContextResponseInterceptor.java","core/src/main/java/io/kestra/core/http/client/configurations/AbstractAuthConfiguration.java","core/src/main/java/io/kestra/core/http/client/configurations/BasicAuthConfiguration.java","core/src/main/java/io/kestra/core/http/client/configurations/BearerAuthConfiguration.java","core/src/main/java/io/kestra/core/http/client/configurations/DigestAuthConfiguration.java","core/src/main/java/io/kestra/core/http/client/configurations/HttpConfiguration.java","core/src/main/java/io/kestra/core/http/client/configurations/ProxyConfiguration.java","core/src/main/java/io/kestra/core/http/client/configurations/SslOptions.java","core/src/main/java/io/kestra/core/http/client/configurations/TimeoutConfiguration.java","core/src/main/java/io/kestra/core/killswitch/EvaluationType.java","core/src/main/java/io/kestra/core/killswitch/KillSwitchService.java","core/src/main/java/io/kestra/core/listeners/RetryEvents.java","core/src/main/java/io/kestra/core/lock/Lock.java","core/src/main/java/io/kestra/core/lock/LockException.java","core/src/main/java/io/kestra/core/lock/LockService.java","core/src/main/java/io/kestra/core/lock/LockServiceResourceReleaser.java","core/src/main/java/io/kestra/core/log/KestraLogFilter.java","core/src/main/java/io/kestra/core/mcp/models/McpServer.java","core/src/main/java/io/kestra/core/mcp/models/McpServerClusterEventPayload.java","core/src/main/java/io/kestra/core/mcp/models/McpSession.java","core/src/main/java/io/kestra/core/mcp/models/McpSessionEvent.java","core/src/main/java/io/kestra/core/mcp/repositories/McpServerRepositoryInterface.java","core/src/main/java/io/kestra/core/mcp/repositories/McpSessionRepositoryInterface.java","core/src/main/java/io/kestra/core/mcp/services/McpServerService.java","core/src/main/java/io/kestra/core/metrics/GlobalTagsConfigurer.java","core/src/main/java/io/kestra/core/metrics/MeterRegistryBinderFactory.java","core/src/main/java/io/kestra/core/metrics/MetricConfig.java","core/src/main/java/io/kestra/core/metrics/MetricRegistry.java","core/src/main/java/io/kestra/core/migration/AbstractV2_0_01UpgradeMigration.java","core/src/main/java/io/kestra/core/migration/MigrationHistoryStore.java","core/src/main/java/io/kestra/core/migration/MigrationLock.java","core/src/main/java/io/kestra/core/migration/MigrationLockedException.java","core/src/main/java/io/kestra/core/migration/MigrationPendingException.java","core/src/main/java/io/kestra/core/migration/MigrationRunner.java","core/src/main/java/io/kestra/core/migration/MigrationRunnerInterface.java","core/src/main/java/io/kestra/core/migration/MigrationScript.java","core/src/main/java/io/kestra/core/migration/MigrationStartupRunner.java","core/src/main/java/io/kestra/core/models/AccessScope.java","core/src/main/java/io/kestra/core/models/FetchVersion.java","core/src/main/java/io/kestra/core/models/HasSource.java","core/src/main/java/io/kestra/core/models/HasUID.java","core/src/main/java/io/kestra/core/models/Label.java","core/src/main/java/io/kestra/core/models/MaintenanceStatusResponse.java","core/src/main/java/io/kestra/core/models/Pauseable.java","core/src/main/java/io/kestra/core/models/PluginVersioning.java","core/src/main/java/io/kestra/core/models/QueryFilter.java","core/src/main/java/io/kestra/core/models/SearchResult.java","core/src/main/java/io/kestra/core/models/ServerType.java","core/src/main/java/io/kestra/core/models/Setting.java","core/src/main/java/io/kestra/core/models/SoftDeletable.java","core/src/main/java/io/kestra/core/models/SourceMatch.java","core/src/main/java/io/kestra/core/models/TenantAndNamespace.java","core/src/main/java/io/kestra/core/models/TenantInterface.java","core/src/main/java/io/kestra/core/models/WorkerJobLifecycle.java","core/src/main/java/io/kestra/core/models/assets/Asset.java","core/src/main/java/io/kestra/core/models/assets/AssetExporter.java","core/src/main/java/io/kestra/core/models/assets/AssetIdentifier.java","core/src/main/java/io/kestra/core/models/assets/AssetLineage.java","core/src/main/java/io/kestra/core/models/assets/AssetUser.java","core/src/main/java/io/kestra/core/models/assets/AssetsDeclaration.java","core/src/main/java/io/kestra/core/models/assets/AssetsInOut.java","core/src/main/java/io/kestra/core/models/assets/Custom.java","core/src/main/java/io/kestra/core/models/assets/External.java","core/src/main/java/io/kestra/core/models/collectors/ConfigurationUsage.java","core/src/main/java/io/kestra/core/models/collectors/ExecutionUsage.java","core/src/main/java/io/kestra/core/models/collectors/FlowUsage.java","core/src/main/java/io/kestra/core/models/collectors/HostUsage.java","core/src/main/java/io/kestra/core/models/collectors/MetricUsage.java","core/src/main/java/io/kestra/core/models/collectors/PluginMetric.java","core/src/main/java/io/kestra/core/models/collectors/PluginUsage.java","core/src/main/java/io/kestra/core/models/collectors/Result.java","core/src/main/java/io/kestra/core/models/collectors/ServiceUsage.java","core/src/main/java/io/kestra/core/models/conditions/ConditionContext.java","core/src/main/java/io/kestra/core/models/dashboards/AggregationType.java","core/src/main/java/io/kestra/core/models/dashboards/ChartOption.java","core/src/main/java/io/kestra/core/models/dashboards/ColumnDescriptor.java","core/src/main/java/io/kestra/core/models/dashboards/Dashboard.java","core/src/main/java/io/kestra/core/models/dashboards/DataFilter.java","core/src/main/java/io/kestra/core/models/dashboards/DataFilterKPI.java","core/src/main/java/io/kestra/core/models/dashboards/ExportFormat.java","core/src/main/java/io/kestra/core/models/dashboards/GraphStyle.java","core/src/main/java/io/kestra/core/models/dashboards/Order.java","core/src/main/java/io/kestra/core/models/dashboards/OrderBy.java","core/src/main/java/io/kestra/core/models/dashboards/TimeWindow.java","core/src/main/java/io/kestra/core/models/dashboards/WithLegend.java","core/src/main/java/io/kestra/core/models/dashboards/WithTooltip.java","core/src/main/java/io/kestra/core/models/dashboards/charts/Chart.java","core/src/main/java/io/kestra/core/models/dashboards/charts/DataChart.java","core/src/main/java/io/kestra/core/models/dashboards/charts/DataChartKPI.java","core/src/main/java/io/kestra/core/models/dashboards/charts/LegendOption.java","core/src/main/java/io/kestra/core/models/dashboards/charts/TooltipBehaviour.java","core/src/main/java/io/kestra/core/models/dashboards/filters/AbstractFilter.java"],"storefront":"/r/kestra-io","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/kestra-io/kestra/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}![\"twitter\"](\"https://kestra.io/twitter.svg\")
![\"linkedin\"](\"https://kestra.io/linkedin.svg\")
![\"youtube\"](\"https://kestra.io/youtube.svg\")