the tiger is not called _tiger

closeio · Jul 19, 2016 · 5debfca · 5debfca
1 parent 6d6e04c
commit 5debfca
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/tasktiger/task.py b/tasktiger/task.py
@@ -329,8 +329,8 @@ def from_id(self, tiger, queue, state, task_id, load_executions=0):
             serialized_executions = []
         # XXX: No timestamp for now
         if serialized_data:
-            data = self._tiger.deserialize_data(serialized_data)
-            executions = [self._tiger.deserialize_data(e) for e in serialized_executions if e]
+            data = self.tiger.deserialize_data(serialized_data)
+            executions = [self.tiger.deserialize_data(e) for e in serialized_executions if e]
             return Task(tiger, queue=queue, _data=data, _state=state,
                         _executions=executions)
         else:
@@ -368,8 +368,8 @@ def tasks_from_queue(self, tiger, queue, state, skip=0, limit=1000,
                 results = pipeline.execute()
 
                 for serialized_data, serialized_executions, ts in zip(results[0], results[1:], tss):
-                    data = self._tiger.deserialize_data(serialized_data)
-                    executions = [self._tiger.deserialize_data.loads(e) for e in serialized_executions if e]
+                    data = self.tiger.deserialize_data(serialized_data)
+                    executions = [self.tiger.deserialize_data.loads(e) for e in serialized_executions if e]
 
                     task = Task(tiger, queue=queue, _data=data, _state=state,
                                 _ts=ts, _executions=executions)
@@ -378,7 +378,7 @@ def tasks_from_queue(self, tiger, queue, state, skip=0, limit=1000,
             else:
                 data = tiger.connection.mget([tiger._key('task', item[0]) for item in items])
                 for serialized_data, ts in zip(data, tss):
-                    data = self._tiger.deserialize_data(serialized_data)
+                    data = self.tiger.deserialize_data(serialized_data)
                     task = Task(tiger, queue=queue, _data=data, _state=state,
                                 _ts=ts)
                     tasks.append(task)