You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
When mara/mara-pipelines#69 is merged and published, a sample should be added in README and docs how to run dbt on a separate container through a Mara pipeline. For example:
frommara_pipelines.commands.sqlimportExecuteSQLfrommara_pipelines.pipelinesimportPipeline, Taskfrommara_dbt.commandsimportDbtRunpipeline=Pipeline(
id='dwh_dbt',
description="Runs additional dbt transformations on the data warehouse")
pipeline.add_initial(
Task(id='initialize_schemas',
description="Create the schema",
max_retries=3,
commands=[ExecuteSQL(sql_statement="""EXEC util.drop_schema_force 'dbt_next'GOCREATE SCHEMA dbt_nextGO""")]))
pipeline.add(
Task(id='run',
description='Run dbt run',
commands=[DbtRun()],
context='dbt-project-dwh'))
pipeline.add_final(
Task(id='replace_schema',
description="",
commands=[ExecuteSQL("EXEC util.replace_schema 'dbt_next', 'dbt'")]))
A readthedocs.io. documentation is needed with samples how to use the package.
The text was updated successfully, but these errors were encountered: