Catch invalid notification message

acoustid · Feb 1, 2016 · 03c1fe9 · 03c1fe9
1 parent a2432ec
commit 03c1fe9
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/scripts/import_submissions.py b/scripts/import_submissions.py
@@ -35,7 +35,11 @@ def main_master(script, opts, args):
     channel = script.redis.pubsub()
     channel.subscribe('channel.submissions')
     for message in channel.listen():
-        ids = json.loads(message['data'])
+        try:
+            ids = json.loads(message['data'])
+        except Exception:
+            logger.exception('Invalid notification message: %r', message)
+            ids = []
         logger.debug('Got notified about %s new submissions', len(ids))
         do_import(script)
         logger.debug('Waiting for the next event...')