Databricks Continue
CertifiedContinue a Genie conversation
Databricks Continue
Continue a Genie conversation
Sends a follow-up on an existing Genie conversation and waits until Genie answers. Use the conversationId from AskQuestion. Outputs match AskQuestion.
type: io.kestra.plugin.databricks.genie.ContinueExamples
Send a follow-up in the same Genie conversation.
id: databricks_genie_follow_up
namespace: company.team
tasks:
- id: ask_question
type: io.kestra.plugin.databricks.genie.AskQuestion
authentication:
token: "{{ secret('DATABRICKS_TOKEN') }}"
host: https://adb-1234567890123456.7.azuredatabricks.net
spaceId: <your-space>
question: What was total revenue by region last quarter?
- id: follow_up
type: io.kestra.plugin.databricks.genie.Continue
authentication:
token: "{{ secret('DATABRICKS_TOKEN') }}"
host: https://adb-1234567890123456.7.azuredatabricks.net
spaceId: <your-space>
conversationId: "{{ outputs.ask_question.conversationId }}"
question: Now break that down by month.
Properties
conversationId *string
Conversation identifier
conversationId from AskQuestion or a previous Continue
question *string
Question
spaceId *string
Genie space
ID of an existing Genie space
accountId string
Databricks account identifier
assets
Assets this task consumes as inputs or produces as outputs, for lineage tracking and the asset graph (Enterprise Edition). A flow declaring this property on a task is rejected in the open-source edition.
io.kestra.core.models.assets.AssetsDeclaration
IGNOREFAILWARNAsset failure behavior
Behavior applied to the task state when a declared asset fails to render, emit, or be persisted (e.g. a lock conflict): FAIL escalates it to FAILED, WARN (default) warns it if it would otherwise succeed, IGNORE leaves the state untouched.
Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.
The assets consumed as inputs.
io.kestra.core.models.assets.AssetIdentifier
1The assets produced as outputs.
io.kestra.plugin.ee.assets.Dataset
1150{}1150io.kestra.plugin.ee.assets.File
1150{}1150io.kestra.plugin.ee.assets.Table
1150{}1150io.kestra.plugin.ee.assets.VM
1150{}1150io.kestra.core.models.assets.External
1150{}1150io.kestra.core.models.assets.Custom
11501Custom asset type
{}1150authentication
Databricks authentication configuration
This property allows to configure the authentication to Databricks, different properties should be set depending on the type of authentication and the cloud provider. All configuration options can also be set using the standard Databricks environment variables. Check the Databricks authentication guide for more information.
io.kestra.plugin.databricks.AbstractTask-AuthenticationConfig
Authentication type
Azure client ID
Azure client secret
Azure tenant ID
Client ID
Client secret
Google credentials JSON
Google service account email
Password
Databricks personal access token
Username
configFile string
Databricks configuration file, use this if you don't want to configure each Databricks account properties one by one
host string
Databricks host
maxRows integerstring
1000Maximum rows
Maximum number of query rows included on result. Defaults to 1000. The task fails when Genie returns more rows than this; the error names maxRows and the row count.
timeout string
PT20MTimeout
How long to wait for Genie, as an ISO-8601 duration. Defaults to 20 minutes. Must be greater than zero.
Outputs
conversationId string
Conversation identifier
Pass this to Continue for a follow-up
messageId string
Message identifier
query string
Generated SQL
SQL Genie produced. Unset for a text-only answer.
result array
Query result
Rows for the generated SQL, keyed by column name. Unset for a text-only answer. Limited to maxRows; the task fails when Genie returns more.
text string
Text answer
Set when Genie replies with text. Unset when the answer is SQL only.
