The GitHub Actions job "Tests (AMD)" on airflow.git/databricks-repair-from-airflow-3 has failed. Run started by GitHub user PrakshiGoyal10 (triggered by potiuk).
Head commit for run: 5f287abf879060537dff70aedc866ccd13bd4a1d / PrakshiGoyal10 <[email protected]> Enable repair of failed Databricks Workflow tasks from Airflow 3 UI On Airflow 3 the "Repair a single task" and "Repair All Failed Tasks" links on DatabricksWorkflowTaskGroup tasks were gated off, so on-call users had to leave Airflow and repair failed runs in the Databricks UI. This restores repair-from-Airflow on Airflow 3: - Register a FastAPI app on the API server that performs the repair, authorized with Dag-run edit access and authenticated via either the UI's bearer token (XHR) or its _token cookie (plain navigation), so a repair link clicked in the browser is authorized. - Resolve the set of failed tasks from the live Databricks run state rather than Airflow's metadata DB (new hook helper get_run_failed_task_keys), and call repair_run with rerun_dependent_tasks so downstream tasks resume too. - Clear the repaired task instances and their downstream instances, mapping Databricks task keys to Airflow task_ids via the same md5(dag_id__task_id) scheme used by the operators, which works on the serialized Dag. - Remove the Airflow 3 gates on the plugin registration and the per-operator extra links so the repair buttons render again. Verified end-to-end against a real Databricks workflow on serverless and job clusters: a failed task plus its upstream_failed downstream both return to success after clicking repair. Report URL: https://github.com/apache/airflow/actions/runs/29561412239 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
