Kevin Otte
02/08/2023, 1:59 AM@asset
def asset1():
write to tableA
@asset(wait_for_asset1_finish)
def asset2():
write to tableB
@asset(wait_for_asset2_finish)
def asset3():
write to tableC
test_job = define_asset_job(name="testing")
defs = Definitions(
assets=[asset1, asset2, asset3],
jobs=[test_job],
)
daniel
02/08/2023, 3:54 AM@asset
def asset1():
write to tableA
@asset
def asset2(asset1):
write to tableB
@asset
def asset3(asset2):
write to tableC
test_job = define_asset_job(name="testing")
defs = Definitions(
assets=[asset1, asset2, asset3],
jobs=[test_job],
)
Kevin Otte
02/08/2023, 4:10 AM