[CT-920][CT-1900] Create Click CLI runner and use it to fix dbt docs …

.changes/unreleased/Under the Hood-20230125-041136.yaml

@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: '[CT-920][CT-1900] Create Click CLI runner and use it to fix dbt docs commands'
+time: 2023-01-25T04:11:36.57506-08:00
+custom:
+ Author: aranke
+ Issue: 5544 6722

core/dbt/cli/main.py

@@ -12,6 +12,7 @@
 from dbt.task.compile import CompileTask
 from dbt.task.deps import DepsTask
 from dbt.task.run import RunTask
+from dbt.task.serve import ServeTask
 from dbt.task.test import TestTask
 from dbt.task.snapshot import SnapshotTask
 from dbt.task.seed import SeedTask
@@ -170,6 +171,7 @@ def docs(ctx, **kwargs):
 @p.models
 @p.profile
 @p.profiles_dir
+@p.project_dir
 @p.select
 @p.selector
 @p.state
@@ -185,7 +187,11 @@ def docs(ctx, **kwargs):
 @requires.manifest
 def docs_generate(ctx, **kwargs):
  """Generate the documentation website for your project"""
- task = GenerateTask(ctx.obj["flags"], ctx.obj["runtime_config"])
+ task = GenerateTask(
+ ctx.obj["flags"],
+ ctx.obj["runtime_config"],
+ ctx.obj["manifest"],
+ )
 
  results = task.run()
  success = task.interpret_results(results)
@@ -203,10 +209,21 @@ def docs_generate(ctx, **kwargs):
 @p.target
 @p.vars
 @requires.preflight
+@requires.profile
+@requires.project
+@requires.runtime_config
+@requires.manifest
 def docs_serve(ctx, **kwargs):
  """Serve the documentation website for your project"""
- click.echo(f"`{inspect.stack()[0][3]}` called\n flags: {ctx.obj['flags']}")
- return None, True
+ task = ServeTask(
+ ctx.obj["flags"],
+ ctx.obj["runtime_config"],
+ ctx.obj["manifest"],
+ )
+
+ results = task.run()
+ success = task.interpret_results(results)
+ return results, success
 
 
 # dbt compile

core/dbt/events/types.py

@@ -2463,33 +2463,6 @@ def message(self) -> str:
  return ""
 
 
-@dataclass
-class ServingDocsPort(InfoLevel, pt.ServingDocsPort):
- def code(self):
- return "Z018"
-
- def message(self) -> str:
- return f"Serving docs at {self.address}:{self.port}"
-
-
-@dataclass
-class ServingDocsAccessInfo(InfoLevel, pt.ServingDocsAccessInfo):
- def code(self):
- return "Z019"
-
- def message(self) -> str:
- return f"To access from your browser, navigate to: http://localhost:{self.port}"
-
-
-@dataclass
-class ServingDocsExitInfo(InfoLevel, pt.ServingDocsExitInfo):
- def code(self):
- return "Z020"
-
- def message(self) -> str:
- return "Press Ctrl+C to exit."
-
-
 @dataclass
 class RunResultWarning(WarnLevel, pt.RunResultWarning):
  def code(self):

core/dbt/task/serve.py

@@ -1,46 +1,28 @@
-import shutil
 import os
+import shutil
+import socketserver
 import webbrowser
-
-from dbt.include.global_project import DOCS_INDEX_FILE_PATH
 from http.server import SimpleHTTPRequestHandler
-from socketserver import TCPServer
-from dbt.events.functions import fire_event
-from dbt.events.types import ServingDocsPort, ServingDocsAccessInfo, ServingDocsExitInfo, EmptyLine
 
+import click
+
+from dbt.include.global_project import DOCS_INDEX_FILE_PATH
 from dbt.task.base import ConfiguredTask
 
 
 class ServeTask(ConfiguredTask):
  def run(self):
  os.chdir(self.config.target_path)
-
- port = self.args.port
- address = "0.0.0.0"
-
  shutil.copyfile(DOCS_INDEX_FILE_PATH, "index.html")
 
- fire_event(ServingDocsPort(address=address, port=port))
- fire_event(ServingDocsAccessInfo(port=port))
- fire_event(EmptyLine())
- fire_event(EmptyLine())
- fire_event(ServingDocsExitInfo())
-
- # mypy doesn't think SimpleHTTPRequestHandler is ok here, but it is
- httpd = TCPServer( # type: ignore
- (address, port), SimpleHTTPRequestHandler # type: ignore
- ) # type: ignore
-
- if self.args.open_browser:
- try:
- webbrowser.open_new_tab(f"http://127.0.0.1:{port}")
- except webbrowser.Error:
- pass
+ port = self.args.port
 
- try:
- httpd.serve_forever() # blocks
- finally:
- httpd.shutdown()
- httpd.server_close()
+ if self.args.browser:
+ webbrowser.open_new_tab(f"http://localhost:{port}")
 
- return None
+ with socketserver.TCPServer(("", port), SimpleHTTPRequestHandler) as httpd:
+ click.echo(f"Serving docs at {port}")
+ click.echo(f"To access from your browser, navigate to: http://localhost:{port}")
+ click.echo("\n\n")
+ click.echo("Press Ctrl+C to exit.")
+ httpd.serve_forever()

tests/functional/minimal_cli/fixtures.py

@@ -0,0 +1,120 @@
+import pytest
+
+models__schema_yml = """
+version: 2
+models:
+ - name: sample_model
+ columns:
+ - name: sample_num
+ tests:
+ - accepted_values:
+ values: [1, 2]
+ - not_null
+ - name: sample_bool
+ tests:
+ - not_null
+ - unique
+"""
+
+models__sample_model = """
+select * from {{ ref('sample_seed') }}
+"""
+
+snapshots__sample_snapshot = """
+{% snapshot orders_snapshot %}
+
+{{
+ config(
+ target_database='postgres',
+ target_schema='snapshots',
+ unique_key='sample_num',
+ strategy='timestamp',
+ updated_at='updated_at',
+ )
+}}
+
+select * from {{ ref('sample_model') }}
+
+{% endsnapshot %}
+"""
+
+seeds__sample_seed = """sample_num,sample_bool
+1,true
+2,false
+,true
+"""
+
+tests__failing_sql = """
+{{ config(severity = 'warn') }}
+select 1
+"""
+
+
+class BaseConfigProject:
+
+ @pytest.fixture(scope="class")
+ def project_config_update(self):
+ return {
+ "name": "jaffle_shop",
+ "profile": "jaffle_shop",
+ "version": "0.1.0",
+ "config-version": 2,
+ "clean-targets": [
+ "target",
+ "dbt_packages",
+ "logs"
+ ]
+ }
+
+ @pytest.fixture(scope="class")
+ def profiles_config_update(self):
+ return {
+ "jaffle_shop": {
+ "outputs": {
+ "dev": {
+ "type": "postgres",
+ "database": "postgres",
+ "schema": "jaffle_shop",
+ "host": "localhost",
+ "user": "root",
+ "port": 5432,
+ "password": "password"
+ }
+ },
+ "target": "dev"
+ }
+ }
+
+ @pytest.fixture(scope="class")
+ def packages(self):
+ return {
+ "packages": [
+ {
+ "package": "dbt-labs/dbt_utils",
+ "version": "1.0.0"
+ }
+ ]
+ }
+
+ @pytest.fixture(scope="class")
+ def models(self):
+ return {
+ "schema.yml": models__schema_yml,
+ "sample_model.sql": models__sample_model,
+ }
+
+ @pytest.fixture(scope="class")
+ def snapshots(self):
+ return {
+ "sample_snapshot.sql": snapshots__sample_snapshot
+ }
+
+ @pytest.fixture(scope="class")
+ def seeds(self):
+ return {"sample_seed.csv": seeds__sample_seed}
+
+ @pytest.fixture(scope="class")
+ def tests(self):
+ return {
+ "failing.sql": tests__failing_sql,
+ }

tests/functional/minimal_cli/test_minimal_cli.py

@@ -0,0 +1,49 @@
+import pytest
+from click.testing import CliRunner
+
+from dbt.cli.main import cli
+from tests.functional.minimal_cli.fixtures import BaseConfigProject
+
+
+class TestMinimalCli(BaseConfigProject):
+ """Test the minimal/happy-path for the CLI using the Click CliRunner"""
+ @pytest.fixture(scope="class")
+ def runner(self):
+ return CliRunner()
+
+ def test_clean(self, runner, project):
+ result = runner.invoke(cli, ['clean'])
+ assert 'target' in result.output
+ assert 'dbt_packages' in result.output
+ assert 'logs' in result.output
+
+ def test_deps(self, runner, project):
+ result = runner.invoke(cli, ['deps'])
+ assert 'dbt-labs/dbt_utils' in result.output
+ assert '1.0.0' in result.output
+
+ def test_ls(self, runner, project):
+ runner.invoke(cli, ['deps'])
+ ls_result = runner.invoke(cli, ['ls'])
+ assert '1 seed' in ls_result.output
+ assert '1 model' in ls_result.output
+ assert '5 tests' in ls_result.output
+ assert '1 snapshot' in ls_result.output
+
+ def test_build(self, runner, project):
+ runner.invoke(cli, ['deps'])
+ result = runner.invoke(cli, ['build'])
+ # 1 seed, 1 model, 2 tests
+ assert 'PASS=4' in result.output
+ # 2 tests
+ assert 'ERROR=2' in result.output
+ # Singular test
+ assert 'WARN=1' in result.output
+ # 1 snapshot
+ assert 'SKIP=1' in result.output
+
+ def test_docs_generate(self, runner, project):
+ runner.invoke(cli, ['deps'])
+ result = runner.invoke(cli, ['docs', 'generate'])
+ assert 'Building catalog' in result.output
+ assert 'Catalog written' in result.output