API for Restarting Individual Failed Tasks within a Job?
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
04-15-2025 09:13 PM
Hi everyone,
I'm exploring ways to streamline my workflow in Databricks and could really use some expert advice. In my current setup, I have a job (named job_silver) with multiple tasks (e.g., task 1, task 2, task 3). When one of these tasks fails—say task 2—I want the ability to restart just that specific task without rerunning the entire job.
I did some research and came across the “Repair and Rerun” feature (Databricks Blog). While that's a great tool for saving time and money in data and ML workflows, my use case requires more flexibility. Specifically, I'm looking for an API-based solution that I can integrate into my code, allowing dynamic control over which task to restart based on custom logic.
Some points I’m particularly interested in:
Is there an existing API (or a combination of APIs) that allows for restarting individual tasks within a job?
Could this be done via the REST API, and if so, what endpoints or methods should I look at?
Are there any workarounds or best practices for implementing this functionality if a dedicated API is not available?
How might this approach scale in environments with a large number of jobs and complex dependency graphs?
I’d love to hear about your experiences and any code snippets or documentation pointers that could help me get started. Thanks in advance for your insights!
Hung Nguyen
- Labels:
-
Workflows