Skip to content

Commit d8d6a79

Browse files
committed
fix: remove unnecessary os.sep
1 parent 637c77b commit d8d6a79

File tree

2 files changed

+5
-6
lines changed

2 files changed

+5
-6
lines changed

airflow_dbt_python/hooks/dbt.py

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,6 @@
44

55
import json
66
import logging
7-
import os
87
import sys
98
from abc import ABC
109
from contextlib import contextmanager
@@ -258,7 +257,7 @@ def get_dbt_task_config(self, command: str, **config_kwargs) -> BaseConfig:
258257
@contextmanager
259258
def dbt_directory(
260259
self,
261-
config,
260+
config: BaseConfig,
262261
upload_dbt_project: bool = False,
263262
delete_before_upload: bool = False,
264263
replace_on_upload: bool = False,
@@ -347,8 +346,8 @@ def prepare_directory(
347346
profiles_dir_path = None
348347

349348
return (
350-
str(project_dir_path) + os.sep,
351-
str(profiles_dir_path) + os.sep if profiles_dir_path is not None else None,
349+
str(project_dir_path),
350+
str(profiles_dir_path) if profiles_dir_path is not None else None,
352351
)
353352

354353
def setup_dbt_logging(self, debug: Optional[bool]):

tests/hooks/dbt/test_dbt_hook_base.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -379,8 +379,8 @@ def test_dbt_base_dbt_directory_changed_to_s3(
379379
assert Path(tmp_dir).exists()
380380
assert Path(tmp_dir).is_dir()
381381

382-
assert config.project_dir == f"{tmp_dir}/"
383-
assert config.profiles_dir == f"{tmp_dir}/"
382+
assert config.project_dir == tmp_dir
383+
assert config.profiles_dir == tmp_dir
384384
assert config.state == f"{tmp_dir}/target"
385385

386386
assert Path(f"{tmp_dir}/profiles.yml").exists()

0 commit comments

Comments
 (0)