Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| d944fdd0c0 | |||
| e345631e27 |
@ -1,6 +1,6 @@
|
||||
[tool.poetry]
|
||||
name = "vrobbler"
|
||||
version = "0.9.2"
|
||||
version = "0.9.3"
|
||||
description = ""
|
||||
authors = ["Colin Powell <colin@unbl.ink>"]
|
||||
|
||||
|
||||
@ -37,12 +37,6 @@ class AudioScrobblerTSVImport(TimeStampedModel):
|
||||
return f"Audioscrobbler TSV upload: {self.tsv_file.path}"
|
||||
return f"Audioscrobbler TSV upload {self.id}"
|
||||
|
||||
def save(self, **kwargs):
|
||||
"""On save, attempt to import the TSV file"""
|
||||
super().save(**kwargs)
|
||||
self.process()
|
||||
return
|
||||
|
||||
def process(self, force=False):
|
||||
from scrobbles.tsv import process_audioscrobbler_tsv_file
|
||||
|
||||
|
||||
@ -1,7 +1,7 @@
|
||||
import logging
|
||||
from celery import shared_task
|
||||
|
||||
from scrobbles.models import LastFmImport
|
||||
from scrobbles.models import AudioScrobblerTSVImport, LastFmImport
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
@ -13,3 +13,12 @@ def process_lastfm_import(import_id):
|
||||
logger.warn(f"LastFmImport not found with id {import_id}")
|
||||
|
||||
lastfm_import.process()
|
||||
|
||||
|
||||
@shared_task
|
||||
def process_tsv_import(import_id):
|
||||
tsv_import = AudioScrobblerTSVImport.objects.filter(id=import_id).first()
|
||||
if not tsv_import:
|
||||
logger.warn(f"AudioScrobblerTSVImport not found with id {import_id}")
|
||||
|
||||
tsv_import.process()
|
||||
|
||||
@ -48,7 +48,7 @@ from scrobbles.serializers import (
|
||||
AudioScrobblerTSVImportSerializer,
|
||||
ScrobbleSerializer,
|
||||
)
|
||||
from scrobbles.tasks import process_lastfm_import
|
||||
from scrobbles.tasks import process_lastfm_import, process_tsv_import
|
||||
from scrobbles.thesportsdb import lookup_event_from_thesportsdb
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
@ -173,6 +173,7 @@ class AudioScrobblerImportCreateView(
|
||||
self.object = form.save(commit=False)
|
||||
self.object.user = self.request.user
|
||||
self.object.save()
|
||||
process_tsv_import.delay(self.object.id)
|
||||
return HttpResponseRedirect(self.get_success_url())
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user