Hi, I have A -> B, and B is dynamically partitioned and scheduled. However, A is valid for all the Bs and does not need to be computed three times (for three partitions). Adding a freshness policy might help, and is the way here to be selective with the assets for the job? Like "upstream(), but exclude A"? Or is there a better way?

Hi Philipp. Just to make sure I understand, you mean that you want to create a job that selects the upstreams of B (including B), excluding A. The

AssetSelection

class supports subtraction, so you could do something like:

AssetSelection.keys("B").upstream() - AssetSelection.keys("A")