Son Giang05/09/2022, 4:17 AM
yuhan05/09/2022, 5:30 PM
Son Giang05/10/2022, 2:21 AM
One resolution is pass the start_time and end_time in resource for ops to get it out. But it requires a lot of boiler plate when I have to pass the partition_bounds to every job resource config.
The another comments suggest to use context.partition_key, but the context.partition_key contains only start_time (it doesn’t include end_time). How can I also get end_time in this situation?
from dagster import make_values_resource
partition_bounds = make_values_resource(start=str, end=str)