One specific question: Can I make a sensor that triggers on backfill completions?

Another specific question: Can I tell whether an EventLogRecord is related to a backfill?

One thing I am considering is some kind of stateful cursor-based approach to only launch the job conditionally. The cursor would hold the sensor’s state, one of two possible states: • WAITING - no materialization of any assets, nothing to be done • LAUNCHING - an asset has been materialized, but lets wait 1 hour for others to materialize before launching a job The cursor would also hold the last sensor-launched run’s start timestamp. The sensor’s body would switch based on what the cursor’s state is. In the WAITING state, call

context.instance.get_latest_materialization_event(…)

for each of the three assets to check for new materializations. A “new” materialization is one since the last run timestamp. If there are any new ones, go to “LAUNCHING” state, recording the latest materialization event’s time. In “LAUNCHING” state, check to see if at least 1 hour has elapsed since the triggering event. If so, launch the job, and go to WAITING state; else, stay in LAUNCHING.

This feels pretty complicated! Is there a better way?