Skip to content

Commit

Permalink
resolve static check errors
Browse files Browse the repository at this point in the history
  • Loading branch information
michaelmicheal committed Nov 22, 2022
1 parent 2906eae commit c4c7112
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion airflow/models/dagrun.py
Original file line number Diff line number Diff line change
Expand Up @@ -292,7 +292,7 @@ def next_dagruns_to_examine(
# TODO: Bake this query, it is run _A lot_
query = (
session.query(cls)
.with_hint(cls, 'USE INDEX (idx_dag_run_running_dags)', dialect_name='mysql')
.with_hint(cls, "USE INDEX (idx_dag_run_running_dags)", dialect_name="mysql")
.filter(cls.state == state, cls.run_type != DagRunType.BACKFILL_JOB)
.join(DagModel, DagModel.dag_id == cls.dag_id)
.filter(DagModel.is_paused == false(), DagModel.is_active == true())
Expand Down

0 comments on commit c4c7112

Please sign in to comment.