flytekitplugins.dbt.DBTRunInput

class flytekitplugins.dbt.DBTRunInput(project_dir, profiles_dir, profile, target=None, output_path='target', ignore_handled_error=False, flags=None, select=None, exclude=None)

Input to DBT Run task.

Parameters:

• project_dir (str)

• profiles_dir (str)

• profile (str)

• target (str)

• output_path (str)

• ignore_handled_error (bool)

• flags (dict)

• select (List[str] | None)

• exclude (List[str] | None)

select

List of model to be executed (default=None).

Type:

List[str]

exclude

List of model to be excluded (default=None).

Type:

List[str]

Methods

classmethod from_dict(kvs, *, infer_missing=False)

Parameters:

kvs (dict | list | str | int | float | bool | None)

Return type:

A

classmethod from_json(s, *, parse_float=None, parse_int=None, parse_constant=None, infer_missing=False, **kw)

Parameters:

s (str | bytes | bytearray)

Return type:

A

classmethod schema(*, infer_missing=False, only=None, exclude=(), many=False, context=None, load_only=(), dump_only=(), partial=False, unknown=None)

Parameters:

• infer_missing (bool)

• many (bool)

• partial (bool)

Return type:

SchemaF[A]

to_args()

Convert the instance of BaseDBTInput into list of arguments.

Returns:

List of arguments.

Return type:

List[str]

to_dict(encode_json=False)

Return type:

Dict[str, dict | list | str | int | float | bool | None]

to_json(*, skipkeys=False, ensure_ascii=True, check_circular=True, allow_nan=True, indent=None, separators=None, default=None, sort_keys=False, **kw)

Parameters:

• skipkeys (bool)

• ensure_ascii (bool)

• check_circular (bool)

• allow_nan (bool)

• indent (int | str | None)

• separators (Tuple[str, str] | None)

• default (Callable | None)

• sort_keys (bool)

Return type:

str

Attributes

dataclass_json_config = None

exclude: List[str] | None = None

flags: dict = None

ignore_handled_error: bool = False

output_path: str = 'target'

select: List[str] | None = None

target: str = None

project_dir: str

profiles_dir: str

profile: str