diff --git a/docker/worker/worker.py b/docker/worker/worker.py
index 9b78ab6c717..15cf13e500a 100644
--- a/docker/worker/worker.py
+++ b/docker/worker/worker.py
@@ -333,6 +333,10 @@ def _source_update(self, message):
     deleted = message.attributes['deleted'] == 'true'
 
     source_repo = osv.get_source_repository(source)
+    if source_repo is None:
+      logging.info('Failed to get source repository %s', source)
+      return
+
     if source_repo.type == osv.SourceRepositoryType.GIT:
       repo = osv.ensure_updated_checkout(
           source_repo.repo_url,