[GitHub] [airflow] mik-laj commented on issue #7510: [AIRFLOW-6887][WIP] Do not check the state of fresh DAGRun

[GitBox]

mik-laj commented on issue #7510: [AIRFLOW-6887][WIP] Do not check the state of 
fresh DAGRun
URL: https://github.com/apache/airflow/pull/7510#issuecomment-590472486
 
 
   These part of code is most important:
   ```
       @timing(RETRY)
       @retry(RETRY)
       @timing()
       @count_queries
       def slow_case():
           from airflow.models import DagRun
           session.query(DagRun).delete()
           from airflow.models import TaskInstance
           session.query(TaskInstance).delete()
           session.commit()
           processor.process_file(DAG_FILE, None, pickle_dags=False)
   
       slow_case()
   ```
   and I ran this code in 90% of cases.
   
   @count_queries - count queries in block and displays on the screen
   @timing - display executon time
   @retry(10) - runs functions in loop 10 times
   @timing(10) -   display executon time but divides the result by 10.
   

----------------------------------------------------------------
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.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


With regards,
Apache Git Services