-
Notifications
You must be signed in to change notification settings - Fork 1.4k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Freshness sensor fix instance method + in-progress checks handling #22013
Conversation
This stack of pull requests is managed by Graphite. Learn more about stacking. |
a287102
to
2758648
Compare
2758648
to
dfd952f
Compare
@@ -155,7 +122,70 @@ def ordered_iterator_freshness_checks_starting_with_key( | |||
# Offset based on the left off asset check key, but then iterate back through the beginning afterwards | |||
if left_off_asset_check_key: | |||
left_off_idx = asset_check_keys_sorted.index(left_off_asset_check_key) | |||
yield from asset_check_keys_sorted[left_off_idx:] | |||
yield from asset_check_keys_sorted[:left_off_idx] | |||
yield from asset_check_keys_sorted[left_off_idx + 1 :] |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
why +1 now?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
realized that this method of indexing was actually inclusive; meaning we would start iterating at the item we evaluated the previous run of the sensor, rather than the item after the last one we evaluated. this fixes (and I added a test for the ordering behavior)
Uses the newly added get_asset_check_summary_record to implement the freshness check sensor. Adds some more tests for previously under-handled cases; having an asset which is currently in planned state, and ensuring that cursoring works properly.
Uses the newly added get_asset_check_summary_record to implement the freshness check sensor. Adds some more tests for previously under-handled cases; having an asset which is currently in planned state, and ensuring that cursoring works properly.
Uses the newly added get_asset_check_summary_record to implement the freshness check sensor. Adds some more tests for previously under-handled cases; having an asset which is currently in planned state, and ensuring that cursoring works properly.
Uses the newly added get_asset_check_summary_record to implement the freshness check sensor.
Adds some more tests for previously under-handled cases; having an asset which is currently in planned state, and ensuring that cursoring works properly.