Add locking clause

Co-authored-by: Staci Mullins <[email protected]>
WordPress · Jun 5, 2023 · c47cc87 · c47cc87
1 parent 62aa408
commit c47cc87
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/catalog/dags/flickr_thumbs_removal.py b/catalog/dags/flickr_thumbs_removal.py
@@ -50,7 +50,7 @@ def delete(num_thumbs):
             query = dedent(
                 f"""
                 UPDATE image SET thumbnail = NULL WHERE identifier IN
-                (SELECT identifier {select_conditions} FETCH FIRST 10000 ROWS ONLY)
+                (SELECT identifier {select_conditions} FETCH FIRST 10000 ROWS ONLY FOR UPDATE SKIP LOCKED)
                 """
             )
             pg.run(query)