auto-ingest system vocabs

share/apps.py

@@ -1,7 +1,10 @@
 from django.apps import AppConfig
 from django.core import checks
 from django.db.models.signals import post_migrate
-from share.signals import post_migrate_load_sources
+from share.signals import (
+    post_migrate_load_sources,
+    post_migrate_ingest_vocabs,
+)
 from share.checks import check_all_index_strategies_current
 
 
@@ -10,4 +13,5 @@ class ShareConfig(AppConfig):
 
     def ready(self):
         post_migrate.connect(post_migrate_load_sources, sender=self)
+        post_migrate.connect(post_migrate_ingest_vocabs, sender=self)
         checks.register(check_all_index_strategies_current)

share/signals.py

@@ -9,3 +9,7 @@ def post_migrate_load_sources(sender, **kwargs):
     except ProgrammingError:
         return
     management.call_command('loadsources')
+
+
+def post_migrate_ingest_vocabs(sender, **kwargs):
+    management.call_command('ingest_rdf_vocabs')

trove/management/commands/ingest_rdf_vocabs.py

@@ -3,18 +3,24 @@
 from share.models import ShareUser
 from share.management.commands import BaseShareCommand
 from trove import digestive_tract
+from trove import models as trove_db
 from trove.vocab import VOCAB_SET
 
 
 def ingest_vocabs(system_user: ShareUser):
     for _vocab in VOCAB_SET:
-        digestive_tract.swallow(
-            from_user=system_user,
-            record=_vocab.turtle(),
-            record_identifier=_vocab.turtle_filename,
-            record_mediatype='text/turtle',
-            focus_iri=_vocab.turtle_focus_iri,
-        )
+        if not (  # if any system vocabs are updated, need to change this
+            trove_db.ResourceIdentifier.objects
+            .queryset_for_iri(_vocab.turtle_focus_iri)
+            .exists()
+        ):
+            digestive_tract.swallow(
+                from_user=system_user,
+                record=_vocab.turtle(),
+                record_identifier=_vocab.turtle_filename,
+                record_mediatype='text/turtle',
+                focus_iri=_vocab.turtle_focus_iri,
+            )
 
 
 class Command(BaseShareCommand):