parisni commented on issue #19822:
URL: https://github.com/apache/airflow/issues/19822#issuecomment-979077641


   still apply with 2.2.2. This does not lead to scheduler crash, still they 
likely to try to insert sames dags same time resulting in pg PK errors
   
   ```
   │ 2021-11-25 10:34:42.496 GMT [152] ERROR:  duplicate key value violates 
unique constraint "dag_pkey"                                                    
     │
   
   │ 2021-11-25 10:34:42.496 GMT [152] DETAIL:  Key (dag_id)=(test_dag_386) 
already exists.                                                                 
     │
   │ 2021-11-25 10:34:42.496 GMT [152] STATEMENT:  INSERT INTO dag (dag_id, 
root_dag_id, is_paused, is_subdag, is_active, last_parsed_time, last_pickled, 
last_e │
   │ 2021-11-25 10:34:47.649 GMT [152] ERROR:  duplicate key value violates 
unique constraint "serialized_dag_pkey"                                         
     │
   │ 2021-11-25 10:34:47.649 GMT [152] DETAIL:  Key (dag_id)=(test_dag_356) 
already exists.                                                                 
     │
   │ 2021-11-25 10:34:47.649 GMT [152] STATEMENT:  INSERT INTO serialized_dag 
(dag_id, fileloc, fileloc_hash, data, last_updated, dag_hash) VALUES 
('test_dag_35 │
   │ 2021-11-25 10:34:48.731 GMT [444] ERROR:  duplicate key value violates 
unique constraint "serialized_dag_pkey"                                         
     │
   │ 2021-11-25 10:34:48.731 GMT [444] DETAIL:  Key (dag_id)=(test_dag_379) 
already exists.                                                                 
     │
   │ 2021-11-25 10:34:48.731 GMT [444] STATEMENT:  INSERT INTO serialized_dag 
(dag_id, fileloc, fileloc_hash, data, last_updated, dag_hash) VALUES 
('test_dag_37 │
   │ 2021-11-25 10:34:50.349 GMT [347] ERROR:  duplicate key value violates 
unique constraint "serialized_dag_pkey"                                         
     │
   │ 2021-11-25 10:34:50.349 GMT [347] DETAIL:  Key (dag_id)=(test_dag_379) 
already exists.                                                                 
     │
   │ 2021-11-25 10:34:50.349 GMT [347] STATEMENT:  INSERT INTO serialized_dag 
(dag_id, fileloc, fileloc_hash, data, last_updated, dag_hash) VALUES 
('test_dag_37 │
   ```


-- 
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]


Reply via email to