Skip to content

Commit e50f106

Browse files
committed
fix(deadline): drop redundant empty-rows break in 0080 batch loops
1 parent 844e04a commit e50f106

1 file changed

Lines changed: 0 additions & 6 deletions

File tree

airflow-core/src/airflow/migrations/versions/0080_3_1_0_modify_deadline_callback_schema.py

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -99,9 +99,6 @@ def upgrade():
9999
.limit(batch_size)
100100
).fetchall()
101101

102-
if not rows:
103-
break
104-
105102
batch = []
106103
for row in rows:
107104
path = row[1] or ""
@@ -190,9 +187,6 @@ def downgrade():
190187
.limit(batch_size)
191188
).fetchall()
192189

193-
if not rows:
194-
break
195-
196190
batch = []
197191
for row in rows:
198192
cb = row[1]

0 commit comments

Comments
 (0)