ENG-2300: Add Databricks workflow (job) trigger and list - #75
Open
kaustav98255 wants to merge 1 commit into
Open
ENG-2300: Add Databricks workflow (job) trigger and list#75kaustav98255 wants to merge 1 commit into
kaustav98255 wants to merge 1 commit into
Conversation
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
bhuvansingla
approved these changes
Mar 26, 2026
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Summary
This PR adds support for triggering Databricks workflow (job) runs and listing available jobs through the Paradime CLI.
Changes
New Files
paradime/core/scripts/databricks_workflow.py— Core implementation for Databricks workflow operations:trigger_databricks_workflows()— Triggers multiple job runs in parallel viaThreadPoolExecutor_trigger_single_workflow()— Triggers a single job run via POST to/api/2.1/jobs/run-now_wait_for_run_completion()— Polls run status every 5 seconds viaGET /api/2.1/jobs/runs/getuntil terminal state_get_run_page_url()— Extracts the run page URL from the run responselist_databricks_jobs()— Lists all jobs viaGET /api/2.1/jobs/listwith ID, name, and creation timeparadime/cli/integrations/databricks_workflow.py— CLI command definitions for Databricks workflow operationsModified Files
paradime/cli/run.py— Registereddatabricks_workflow_triggeranddatabricks_workflow_listcommandsCLI Commands
databricks-workflow-trigger— Trigger Databricks job runsdatabricks-workflow-list— List all Databricks jobsImplementation Details
Authorization: Bearer {token}headerlife_cycle_stateandresult_stateevery 5 seconds viaGET /api/2.1/jobs/runs/getPENDING,RUNNING,TERMINATING,TERMINATED,SKIPPED,INTERNAL_ERRORSUCCESS,FAILED,TIMEDOUT,CANCELED,MAXIMUM_CONCURRENT_RUNS_REACHEDDATABRICKS_HOST,DATABRICKS_TOKENviaenv_click_optionrequestslibrary