aboutsummaryrefslogtreecommitdiffstats
path: root/mediagoblin/processing
diff options
context:
space:
mode:
authorRodney Ewing <ewing.rj@gmail.com>2013-08-12 14:28:03 -0700
committerRodney Ewing <ewing.rj@gmail.com>2013-08-16 15:30:18 -0700
commit7584080bf7d7b2d74087d31ca781e1111c2024da (patch)
tree5004ade7e20d18fa1963ba5313c9cb6b1acedffb /mediagoblin/processing
parent455f71d24c7d5e3163b1cc25682161fe1c7f7cc6 (diff)
downloadmediagoblin-7584080bf7d7b2d74087d31ca781e1111c2024da.tar.lz
mediagoblin-7584080bf7d7b2d74087d31ca781e1111c2024da.tar.xz
mediagoblin-7584080bf7d7b2d74087d31ca781e1111c2024da.zip
add bulk_run, thumbs, and initial sub_commands
Diffstat (limited to 'mediagoblin/processing')
-rw-r--r--mediagoblin/processing/__init__.py15
1 files changed, 13 insertions, 2 deletions
diff --git a/mediagoblin/processing/__init__.py b/mediagoblin/processing/__init__.py
index 19e88199..1930a480 100644
--- a/mediagoblin/processing/__init__.py
+++ b/mediagoblin/processing/__init__.py
@@ -137,7 +137,7 @@ class MediaProcessor(object):
raise NotImplementedError
@classmethod
- def media_is_eligible(cls, entry):
+ def media_is_eligible(cls, entry=None, state=None):
raise NotImplementedError
###############################
@@ -204,7 +204,18 @@ class ProcessingManager(object):
return [
processor
for processor in self.processors.values()
- if processor.media_is_eligible(entry)]
+ if processor.media_is_eligible(entry=entry)]
+
+ def list_all_processors_by_state(self, state):
+ """
+ List all processors that this media state is eligible to be processed
+ for.
+ """
+ return [
+ processor
+ for processor in self.processors.values()
+ if processor.media_is_eligible(state=state)]
+
def list_all_processors(self):
return self.processors.values()