Close the tar file

db/data.py

@@ -10,6 +10,7 @@
 
 from sqlalchemy import text
 import sqlalchemy.exc
+from brainzutils import musicbrainz_db
 
 _whitelist_file = os.path.join(os.path.dirname(__file__), "tagwhitelist.json")
 _whitelist_tags = set(json.load(open(_whitelist_file)))

manage.py

@@ -202,7 +202,7 @@ def get_entities():
     print('Redirecting mbids to original entities...')
     webserver.external.get_entities.get_original_entity()
 
-
+@cli.command()
 def apply_replication_changes():
     print("\nUpdating musicbrainz schema by applying replication packets...")
     musicbrainz_importer.apply_replication_changes.main()

musicbrainz_importer/apply_replication_changes.py

@@ -36,6 +36,7 @@
 from sqlalchemy import text
 from sqlalchemy.exc import IntegrityError
 import db.import_mb_data
+import db.data
 
 include_tables = ['language', 'artist_credit_name', 'artist', 'artist_gid_redirect', 'area', 'area_type', 'recording_gid_redirect', \
                   'script', 'release_gid_redirect', 'recording', 'track', 'artist_credit', 'release_group_primary_type', 'release_group', \
@@ -298,6 +299,7 @@ def process_tar(fileobj, expected_schema_seq, replication_seq):
         elif member.name in ('mbdump/PendingData', 'mbdump/dbmirror_pendingdata'):
             importer.load_pending_data(tar.extractfile(member))
     importer.process()
+    tar.close()
 
 
 def download_packet(base_url, token, replication_seq):