def METHOD_NAME(task_id, task, **kw):
    timer = TaskTimer()
    log.info(
        'starting task timer; id={id}; name={name}; '
        'current_dt={current_dt}'.format(
            id=task_id, name=task.name, current_dt=timer.current_datetime
        )
    )
    # Cache start time for one hour. This will allow us to catch crazy long
    # tasks. Currently, stats indexing tasks run around 20-30 min.
    expiration = 60 * 60
    cache_key = timer.cache_key(task_id)
    cache.set(cache_key, timer.current_epoch_ms, expiration)