From 0a2096893861f0d1a3980a4a992122d1209ced37 Mon Sep 17 00:00:00 2001 From: Guillaume Pellerin Date: Fri, 4 Apr 2014 10:23:32 +0200 Subject: [PATCH] update task status handling in run --- timeside/models.py | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/timeside/models.py b/timeside/models.py index 1e35160..7008fbb 100644 --- a/timeside/models.py +++ b/timeside/models.py @@ -175,6 +175,8 @@ class Task(models.Model): self.save() def run(self): + self.status_setter(2) + for item in self.items: pipe = timeside.decoder.FileDecoder(item.file) proc_dict = {} @@ -193,13 +195,9 @@ class Task(models.Model): item.save() try: - self.status_setter(2) pipe.run() pipe.results.to_hdf5(item.hdf5) - except: - self.status_setter(0) - - if sef.status == 2: + for processor in proc_dict.keys(): proc = proc_dict[processor] results = Result.objects.filter(processor=processor, uuid=proc.UUID) @@ -210,7 +208,11 @@ class Task(models.Model): result.hdf5 = path + item.uuid + '_' + proc.UUID + '.hdf5' proc.results.to_hdf5(result.hdf5) result.save() + except: + self.status_setter(0) + break + self.status_setter(3) del proc del pipe - self.status_setter(3) + -- 2.39.5