@@ -306,8 +306,8 @@ class TestCeleryTasks(unittest.TestCase):
# With eta.
presult2 = t1.apply_async(kwargs=dict(name="George Costanza"),
- eta=datetime.utcnow() + timedelta(days=1),
- expires=datetime.utcnow() + timedelta(days=2))
+ eta=datetime.utcnow() + timedelta(days=1),
+ expires=datetime.utcnow() + timedelta(days=2))
self.assertNextTaskDataEqual(consumer, presult2, t1.name,
name="George Costanza", test_eta=True, test_expires=True)
@@ -34,6 +34,7 @@ class TSR(chords.TaskSetResult):
def join_native(self, **kwargs):
return self.value
+
class test_unlock_chord_task(AppCase):
@patch("celery.task.chords._unlock_chord.retry")
@@ -22,7 +22,7 @@ from dateutil.parser import parse as parse_iso8601
try:
import pytz
except ImportError:
- pytz = None
+ pytz = None # noqa
DAYNAMES = "sun", "mon", "tue", "wed", "thu", "fri", "sat"