Skip to content

Commit

Permalink
PR feedback, Changelog
Browse files Browse the repository at this point in the history
  • Loading branch information
iknox-fa committed Jul 14, 2021
1 parent 8a1e643 commit 51b5175
Show file tree
Hide file tree
Showing 5 changed files with 5 additions and 5 deletions.
1 change: 1 addition & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
## dbt 0.21.0

### Features
- Add `dbt build` command to run models, tests, seeds, and snapshots in DAG order. ([#2743] (https://github.com/dbt-labs/dbt/issues/2743), , [#3490] (https://github.com/dbt-labs/dbt/issues/3490))

### Fixes
- Fix docs generation for cross-db sources in REDSHIFT RA3 node ([#3236](https://github.com/fishtown-analytics/dbt/issues/3236), [#3408](https://github.com/fishtown-analytics/dbt/pull/3408))
Expand Down
1 change: 0 additions & 1 deletion core/dbt/graph/queue.py
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,6 @@ def __init__(self, graph: nx.DiGraph, manifest: Manifest, selected: Set[UniqueId
# this lock controls most things
self.lock = threading.Lock()
# store the 'score' of each node as a number. Lower is higher priority.
# TODO: incorporate _include_in_cost (or remove dead code, still needed?)
self._scores = self._get_scores(self.graph)
# populate the initial queue
self._find_new_additions()
Expand Down
2 changes: 1 addition & 1 deletion core/dbt/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -383,7 +383,7 @@ def _build_build_subparser(subparsers, base_subparser):
'build',
parents=[base_subparser],
help='''
Runs the whole shebang! @TODO: better description
Run all Seeds, Models, Snapshots, and tests in DAG order
'''
)
sub.set_defaults(
Expand Down
1 change: 0 additions & 1 deletion core/dbt/task/build.py
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,6 @@ class BuildTask(CompileTask):
as run_model_runner.
"""

# TODO: is this list complete?
RUNNER_MAP = {
NodeType.Model: run_model_runner,
NodeType.Snapshot: snapshot_model_runner,
Expand Down
5 changes: 3 additions & 2 deletions core/dbt/task/runnable.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,7 @@
print_run_end_messages,
print_cancel_line,
)

from dbt import ui
from dbt.task.base import ConfiguredTask
from dbt.adapters.base import BaseRelation
Expand Down Expand Up @@ -39,7 +40,7 @@
RuntimeException,
FailFastException,
)
from dbt.node_types import NodeType

from dbt.graph import GraphQueue, NodeSelector, SelectionSpec, Graph
from dbt.parser.manifest import ManifestLoader

Expand Down Expand Up @@ -166,7 +167,7 @@ def get_runner(self, node):
run_count = self.run_count
num_nodes = self.num_nodes

cls = self.get_runner_type(node) # TODO: reduce this to just node.resource_type?
cls = self.get_runner_type(node)
return cls(self.config, adapter, node, run_count, num_nodes)

def call_runner(self, runner):
Expand Down

0 comments on commit 51b5175

Please sign in to comment.