Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
03-23-2023 04:32 AM
@Rahul Samant :
Based on the JSON payload you provided, it looks like you are using the DatabricksSubmitRunOperator in Airflow to submit a Databricks job run. To pass the run_as_user_name parameter, you can add it as a top-level parameter in the json dictionary like this:
"json": {
"existing_cluster_id": "{{ env.existing_cluster_id }}",
"dbt_task": {
"project_directory": "",
"commands": [
"dbt deps",
"dbt run --select models/ZZZZ"
],
"schema": "kpi",
"warehouse_id": "XXXXXX"
},
"git_source": {
"git_url": "https://axxxx-dbt",
"git_provider": "azureDevOpsServices",
"git_branch": "master"
},
"run_as_user_name": "user@test.com"
}Make sure that the value of run_as_user_name is a valid Databricks user name or email address with the appropriate permissions to access the necessary resources.