Skip to content

Commit

Permalink
Events with graph_func include actual output of graph_func
Browse files Browse the repository at this point in the history
  • Loading branch information
gshank committed Nov 29, 2021
1 parent d8dd753 commit 888a59f
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions core/dbt/events/types.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
)
from dbt.events.format import format_fancy_output_line, pluralize
from dbt.node_types import NodeType
from typing import Any, Callable, cast, Dict, List, Optional, Set, Tuple, TypeVar, Union
from typing import Any, Callable, Dict, List, Optional, Set, Tuple, TypeVar, Union


# The classes in this file represent the data necessary to describe a
Expand Down Expand Up @@ -706,7 +706,7 @@ class DumpBeforeAddGraph(DebugLevel, Cli, File):
def message(self) -> str:
# workaround for https://github.com/python/mypy/issues/6910
# TODO remove when we've upgraded to a mypy version without that bug
func_returns = cast(Callable[[], Dict[str, List[str]]], getattr(self, "graph_func"))
func_returns = self.graph_func() # type: ignore
return f"before adding : {func_returns}"


Expand All @@ -717,7 +717,7 @@ class DumpAfterAddGraph(DebugLevel, Cli, File):

def message(self) -> str:
# workaround for https://github.com/python/mypy/issues/6910
func_returns = cast(Callable[[], Dict[str, List[str]]], getattr(self, "graph_func"))
func_returns = self.graph_func() # type: ignore
return f"after adding: {func_returns}"


Expand All @@ -728,7 +728,7 @@ class DumpBeforeRenameSchema(DebugLevel, Cli, File):

def message(self) -> str:
# workaround for https://github.com/python/mypy/issues/6910
func_returns = cast(Callable[[], Dict[str, List[str]]], getattr(self, "graph_func"))
func_returns = self.graph_func() # type: ignore
return f"before rename: {func_returns}"


Expand All @@ -739,7 +739,7 @@ class DumpAfterRenameSchema(DebugLevel, Cli, File):

def message(self) -> str:
# workaround for https://github.com/python/mypy/issues/6910
func_returns = cast(Callable[[], Dict[str, List[str]]], getattr(self, "graph_func"))
func_returns = self.graph_func() # type: ignore
return f"after rename: {func_returns}"


Expand Down

0 comments on commit 888a59f

Please sign in to comment.