ops_no_data

ops_no_data.py

import dagster as dg

@dg.op
def first_op(context: dg.OpExecutionContext) -> None:
    context.log.info("Creating op one")

@dg.op(ins={"start": dg.In(dg.Nothing)})
def second_op(context: dg.OpExecutionContext) -> None:
    context.log.info("Creating op two")

@dg.graph
def my_graph():
    second_op(start=first_op())

job_with_dependency = my_graph.to_job()



defs = dg.Definitions(
    jobs=[job_with_dependency]
)