'Schedules a kill notification for this flow.'

def ScheduleKillNotification(self):

    kill_timestamp = (rdfvalue.RDFDatetime().Now() + self.stuck_flows_timeout)
    with queue_manager.QueueManager(token=self.token) as manager:
        manager.QueueNotification(session_id=self.session_id, in_progress=True, timestamp=kill_timestamp)
    self.context.kill_timestamp = kill_timestamp
