data_pipelines_cli.cli_commands.generate package

Submodules

data_pipelines_cli.cli_commands.generate.generate module

data_pipelines_cli.cli_commands.generate.model_yaml module

class MacroArgName[source]

Bases: TypedDict

arg_name: str
deps_name: str
macro_name: str
generate_model_yamls(env: str, with_meta: bool, overwrite: bool, model_paths: Sequence[Path]) None[source]

data_pipelines_cli.cli_commands.generate.source_sql module

generate_source_sqls(env: str, source_yaml_path: Path, staging_path: Path, overwrite: bool) None[source]

data_pipelines_cli.cli_commands.generate.source_yaml module

generate_source_yamls(env: str, source_path: Path, overwrite: bool, schema_names: Sequence[str]) None[source]

data_pipelines_cli.cli_commands.generate.databricks_job module

generate_source_yamls(env: str, source_path: Path, overwrite: bool, schema_names: Sequence[str]) None[source]

data_pipelines_cli.cli_commands.generate.utils module

generate_models_or_sources_from_single_table(env: str, macro_name: str, macro_args: Dict[str, Any], profiles_path: Path) Dict[str, Any][source]
get_macro_run_output(env: str, macro_name: str, macro_args: Dict[str, str], profiles_path: Path) str[source]
get_output_file_or_warn_if_exists(directory: Path, overwrite: bool, file_extension: str, filename: Optional[str] = None) Optional[Path][source]