'Injects a WARN message into the current status logging stream.'

def log_warning(self, msg, warning_type):

    timestamp = int(time.time())
    if self.job.warning_manager.is_valid(timestamp, warning_type):
        self.job.record('WARN', None, None, msg)
