Hi everyone. I wonder how to pass partition start and end to every ops in a graph/job? Like do we have some sort of global context for a graph/job so we can use for the ops when needed? It’s such a pain when I have to pass partition information (start/end time) to every ops.

take a look at https://github.com/dagster-io/dagster/blob/1dd639f69d3438dcff4a80efb95d7998314a28cf/examples/hacker_news/hacker_news/resources/partition_bounds.py

You should also be able to access

partition_key

off of the context, if the op is a partitioned job.

@op
def my_op(context):
    if context.has_partition_key:
        <http://context.log.info|context.log.info>(f"this job run has partition key {context.partition_key}")