fix(taskqueue): fix FailFast deletion command

talkiq · Jan 25, 2018 · 6d9760d · 6d9760d
1 parent c638e7c
commit 6d9760d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/taskqueue/gcloud/aio/taskqueue/taskmanager.py b/taskqueue/gcloud/aio/taskqueue/taskmanager.py
@@ -194,7 +194,7 @@ async def process(self, task):
 
                     if autorenew is not None:
                         task = await autorenew.stop()
-                    await self.tq.delete(task)
+                    await self.tq.delete(name)
                     await self.fail(task, payload, e)
                     return
                 except Exception as e:  # pylint: disable=broad-except