Browse Source

Bubfixes for #1129

Ask Solem 11 years ago
parent
commit
f1dac6976c
1 changed files with 2 additions and 1 deletions
  1. 2 1
      celery/worker/__init__.py

+ 2 - 1
celery/worker/__init__.py

@@ -153,7 +153,8 @@ class Pool(bootsteps.StartStopComponent):
             if hard:
                 trefs[job] = apply_at(
                     now() + (hard - soft),
-                    _on_hard_timeout, (job, soft, hard, hub))
+                    _on_hard_timeout, (job, ),
+                )
             try:
                 result = cache[job]
             except KeyError: