Chais commented on issue #57422:
URL: https://github.com/apache/airflow/issues/57422#issuecomment-3456576389
The database appears to be in an inconsistent state, too.
```
airflow_db=> \d task_instance_history
```
### Table "public.task_instance_history"
Column | Type | Collation | Nullable | Default
:---|:---|:---|:---|:---
task_id | character varying(250) | | not null |
dag_id | character varying(250) | | not null |
run_id | character varying(250) | | not null |
map_index | integer | | not null | '-1'::integer
try_number | integer | | not null |
start_date | timestamp with time zone | | |
end_date | timestamp with time zone | | |
duration | double precision | | |
state | character varying(20) | | |
max_tries | integer | | | '-1'::integer
hostname | character varying(1000) | | |
unixname | character varying(1000) | | |
pool | character varying(256) | | not null |
pool_slots | integer | | not null |
queue | character varying(256) | | |
priority_weight | integer | | |
operator | character varying(1000) | | |
custom_operator_name | character varying(1000) | | |
queued_dttm | timestamp with time zone | | |
queued_by_job_id | integer | | |
pid | integer | | |
executor | character varying(1000) | | |
executor_config | bytea | | |
updated_at | timestamp with time zone | | |
rendered_map_index | character varying(250) | | |
external_executor_id | character varying(250) | | |
trigger_id | integer | | |
trigger_timeout | timestamp without time zone | | |
next_method | character varying(1000) | | |
next_kwargs | json | | |
task_display_name | character varying(2000) | | |
dag_version_id | uuid | | |
scheduled_dttm | timestamp with time zone | | |
task_instance_id | uuid | | not null |
context_carrier | jsonb | | |
span_status | character varying(250) | | not null | 'not_started'::character
varying
Indexes:
"task_instance_history_pkey" PRIMARY KEY, btree (task_instance_id)
"idx_tih_dag_run" btree (dag_id, run_id)
"task_instance_history_dtrt_uq" UNIQUE CONSTRAINT, btree (dag_id,
task_id, run_id, map_index, try_number)
Foreign-key constraints:
"task_instance_history_ti_fkey" FOREIGN KEY (dag_id, task_id, run_id,
map_index) REFERENCES task_instance(dag_id, task_id, run_id, map_index) ON
UPDATE CASCADE ON DELETE CASCADE
As you see I have the column `task_instance_id`, which was added in [version
60](https://github.com/apache/airflow/blob/main/airflow-core/src/airflow/migrations/versions/0060_3_0_0_add_try_id_to_ti_and_tih.py),
if I'm reading that correctly. However, I'm lacking the `try_id` column, which
was added in the same version.
I really hope I can salvage this without data loss.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
