

def expire_task(self, task, task_expiration):
    if task_expiration:
        now = arrow.get()
        task_lifetime = (now.timestamp - task.created.timestamp)
        if (task_lifetime > task_expiration):
            logger.debug('Task %s is older than expiration limit %d. Skipping.', task.id, self)
            return True
        return False
    return False

dataset/ETHPy150Open cloudtools/nymms/nymms/probe/Probe.py Probe.expire_task/VarMisuse@60/97 `task_expiration`->`self`