Jason Myers
08/09/2023, 8:05 PMJason Myers
08/09/2023, 8:05 PMJason Myers
08/09/2023, 8:05 PMJason Myers
08/09/2023, 8:06 PMJason Myers
08/09/2023, 8:10 PMJason Myers
08/09/2023, 8:16 PM@dbt_assets(
manifest=DBT_MANIFEST,
select="staged__nc_op_asc_patients",
dagster_dbt_translator=CustomDagsterDbtTranslator(),
)
def hca_nc_op_asc_dbt(
context: OpExecutionContext,
config: StateDataProcessingConfig,
dbt_cli: DbtCliResource,
upstream_process,
overlapping_periods,
):
all_periods = set(overlapping_periods["append"]).union(set(overlapping_periods["replace"]))
dbt_vars = {
"replace_reporting_periods": str(overlapping_periods["replace"]),
"all_reporting_periods": str(list(all_periods)),
}
dbt_args = ["run", "--vars", f"'{json.dumps(dbt_vars)}'", "-s", "staged__nc_op_asc_patients"]
dbt_cli_task = dbt_cli.cli(dbt_args, context=context)
yield from dbt_cli_task.stream()
Jason Myers
08/09/2023, 8:17 PMrex
08/09/2023, 8:22 PMJason Myers
08/09/2023, 8:51 PMowen
08/09/2023, 10:12 PM/opt/.../dbt_project/logs/dbt.log
, which is the default path that dbt writes its own logs to.Jason Myers
08/10/2023, 12:37 AMJason Myers
08/10/2023, 3:07 PMowen
08/10/2023, 8:53 PMrex
08/10/2023, 8:55 PMJason Myers
08/13/2023, 7:15 PM