Repair a job run. — repair_job

Re-run one or more tasks. Tasks are re-run as part of the original job run. They use the current job and task settings, and can be viewed in the history for the original job run.

Usage

repair_job_run(
  client,
  run_id,
  dbt_commands = NULL,
  jar_params = NULL,
  job_parameters = NULL,
  latest_repair_id = NULL,
  notebook_params = NULL,
  pipeline_params = NULL,
  python_named_params = NULL,
  python_params = NULL,
  rerun_all_failed_tasks = NULL,
  rerun_dependent_tasks = NULL,
  rerun_tasks = NULL,
  spark_submit_params = NULL,
  sql_params = NULL
)

jobsRepairRun(
  client,
  run_id,
  dbt_commands = NULL,
  jar_params = NULL,
  job_parameters = NULL,
  latest_repair_id = NULL,
  notebook_params = NULL,
  pipeline_params = NULL,
  python_named_params = NULL,
  python_params = NULL,
  rerun_all_failed_tasks = NULL,
  rerun_dependent_tasks = NULL,
  rerun_tasks = NULL,
  spark_submit_params = NULL,
  sql_params = NULL
)

Arguments

client: Required. Instance of DatabricksClient()
run_id: Required. The job run ID of the run to repair.
dbt_commands: An array of commands to execute for jobs with the dbt task, for example 'dbt_commands': ['dbt deps', 'dbt seed', 'dbt run'].
jar_params: A list of parameters for jobs with Spark JAR tasks, for example 'jar_params': ['john doe', '35'].
job_parameters: Job-level parameters used in the run.
latest_repair_id: The ID of the latest repair.
notebook_params: A map from keys to values for jobs with notebook task, for example 'notebook_params': {'name': 'john doe', 'age': '35'}.
pipeline_params: This field has no description yet.
python_named_params: A map from keys to values for jobs with Python wheel task, for example 'python_named_params': {'name': 'task', 'data': 'dbfs:/path/to/data.json'}.
python_params: A list of parameters for jobs with Python tasks, for example 'python_params': ['john doe', '35'].
rerun_all_failed_tasks: If true, repair all failed tasks.
rerun_dependent_tasks: If true, repair all tasks that depend on the tasks in rerun_tasks, even if they were previously successful.
rerun_tasks: The task keys of the task runs to repair.
spark_submit_params: A list of parameters for jobs with spark submit task, for example 'spark_submit_params': ['--class', 'org.apache.spark.examples.SparkPi'].
sql_params: A map from keys to values for jobs with SQL task, for example 'sql_params': {'name': 'john doe', 'age': '35'}.