jasono
04/20/2022, 5:38 PMjasono
04/20/2022, 5:38 PM@op(config_schema{'yymm': str})
def first_op(context):
yymm = context.op_config["yymm"]
... do something here...
return yymm
notebook_op = dm.define_dagstermill_op(
"my_notebook",
script_relative_path('....'),
output_notebook_name="xxxx",
config_schema{
yymm: yymm <<<<< trying to achieve something like this.
}
)
@job( ..)
def run_job():
notebook_op(
first_op()
)
johann
04/20/2022, 6:25 PMdefine_dagstermill_op
takes input_defs
johann
04/20/2022, 6:26 PMjasono
04/20/2022, 8:30 PMjohann
04/20/2022, 8:53 PMpath
via input_defsjasono
04/20/2022, 8:54 PM