- need self.metadata with BaseProcessingFail
- pass feed_url into ProcessMedia run()
This commit is contained in:
parent
b505952508
commit
d4ae4c9f97
@ -109,7 +109,7 @@ class MediaEntry(Base_v0):
|
|||||||
|
|
||||||
queued_media_file = Column(PathTupleWithSlashes)
|
queued_media_file = Column(PathTupleWithSlashes)
|
||||||
|
|
||||||
queued_task_id = Column(Unicode, default=None)
|
queued_task_id = Column(Unicode)
|
||||||
|
|
||||||
__table_args__ = (
|
__table_args__ = (
|
||||||
UniqueConstraint('uploader', 'slug'),
|
UniqueConstraint('uploader', 'slug'),
|
||||||
|
@ -72,7 +72,7 @@ class ProcessMedia(celery.Task):
|
|||||||
"""
|
"""
|
||||||
track_started=True
|
track_started=True
|
||||||
|
|
||||||
def run(self, media_id):
|
def run(self, media_id, feed_url):
|
||||||
"""
|
"""
|
||||||
Pass the media entry off to the appropriate processing function
|
Pass the media entry off to the appropriate processing function
|
||||||
(for now just process_image...)
|
(for now just process_image...)
|
||||||
@ -86,6 +86,7 @@ class ProcessMedia(celery.Task):
|
|||||||
try:
|
try:
|
||||||
entry.state = u'processing'
|
entry.state = u'processing'
|
||||||
entry.save()
|
entry.save()
|
||||||
|
|
||||||
_log.debug('Processing {0}'.format(entry))
|
_log.debug('Processing {0}'.format(entry))
|
||||||
|
|
||||||
proc_state = ProcessingState(entry)
|
proc_state = ProcessingState(entry)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user