PR feedback, annotate hacks

core/dbt/task/base.py

@@ -15,6 +15,7 @@
  InternalException
 )
 from dbt.logger import log_manager
+import logging
 import dbt.events.functions as event_logger
 from dbt.events.functions import fire_event
 from dbt.events.types import (
@@ -63,6 +64,9 @@ def __init__(self, args, config):
  @classmethod
  def pre_init_hook(cls, args):
  """A hook called before the task is initialized."""
+ # the event logger has been initialized, but it has not yet been configured
+ # TODO refactor
+ event_logger.STDOUT_LOG.level = logging.DEBUG if args.debug else logging.INFO
  if args.log_format == 'json':
  log_manager.format_json()
  event_logger.format_json = True
@@ -71,6 +75,9 @@ def pre_init_hook(cls, args):
 
  @classmethod
  def set_log_format(cls):
+ # the event logger has been initialized, but it has not yet been configured
+ # TODO refactor
+ event_logger.STDOUT_LOG.level = logging.DEBUG if flags.DEBUG else logging.INFO
  if flags.LOG_FORMAT == 'json':
  log_manager.format_json()
  event_logger.format_json = True

core/dbt/task/list.py

@@ -57,9 +57,14 @@ def __init__(self, args, config):
  @classmethod
  def pre_init_hook(cls, args):
  """A hook called before the task is initialized."""
- log_manager.stderr_console()
- event_logger.STDOUT_LOG.level = logging.WARN
  super().pre_init_hook(args)
+ log_manager.stderr_console()
+ # filter out all INFO-level logging to allow piping ls output to jq, etc
+ # WARN level will still include all warnings + errors
+ # if user has specified DEBUG level (dbt --debug), don't override
+ # TODO refactor!
+ if event_logger.STDOUT_LOG.level == logging.INFO:
+ event_logger.STDOUT_LOG.level = logging.WARN
 
  def _iterate_selected_nodes(self):
  selector = self.get_node_selector()