def marathon_log_line_passes_filter(line, levels, service, components, clusters):
    try:
        parsed_line = json.loads(line)
    except ValueError:
        log.debug('Trouble parsing line as json. Skipping. Line: %r' % line)
        return False
    return format_job_id(service, '') in parsed_line.get('message', '')
Given a (JSON-formatted) log line where the message is a Marathon log line,
dataset/ETHPy150Open Yelp/paasta/paasta_tools/cli/cmds/logs.py/marathon_log_line_passes_filter