Daniel Mosesson
03/13/2023, 4:11 PMyuhan
03/13/2023, 4:32 PMDaniel Mosesson
03/15/2023, 2:36 AMfrom dagster import HourlyPartitionsDefinition, op, asset, graph_asset, DynamicOut, DynamicOutput, Definitions, OpExecutionContext
@op(out=DynamicOut(int, is_required=False))
def splay(context: OpExecutionContext):
if not '22' in context.partition_key:
yield DynamicOutput(1, mapping_key='1')
@op
def op2(o1):
return o1+1
@graph_asset(
partitions_def=HourlyPartitionsDefinition(start_date='2023-03-14-20:00')
)
def g1():
s = splay()
a = s.map(op2)
return a
defs = Definitions(
assets=[g1]
)
Picture in dagit overall and for the 2200 run below