Another question: I can't seem to get cache to work when I run a task via map. So for instance, my_task.map([1,2,3]) called again with my_task.map([2,3,4]) I'd assume that for 2 and 3 my_task would be cached if cache_for=timedelta(hours=1) and cache_validator=cache_validators.all_inputs -- am I missing something obvious? thanks!