Skip to content

Commit

Permalink
fix: nack message if no compiled_release rows in kingfisher_process e…
Browse files Browse the repository at this point in the history
…xtractor
  • Loading branch information
jpmckinney committed Sep 27, 2023
1 parent 8723b19 commit 2c77801
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions workers/extract/kingfisher_process.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@

import click
import psycopg2.extras
from yapw.methods import nack

import dataset.meta_data_aggregator as meta_data_aggregator
from pelican.util import exchange_rates_db, settings
Expand Down Expand Up @@ -81,6 +82,7 @@ def callback(client_state, channel, method, properties, input_message):
)
else:
logger.error("No rows found in `compiled_release` where collection_id = %s", collection_id)
nack(client_state, channel, method.delivery_tag, requeue=False)
finally:
kingfisher_process_cursor.close()
kingfisher_process_connection.close()
Expand Down

0 comments on commit 2c77801

Please sign in to comment.