-
Notifications
You must be signed in to change notification settings - Fork 1.5k
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
Add AssetGraphView.create_latest_time_window_slice #20352
Conversation
This stack of pull requests is managed by Graphite. Learn more about stacking. |
f976741
to
7ffcdd1
Compare
1f5e51f
to
90a0736
Compare
aa23d4e
to
0c64516
Compare
6210591
to
99cd2dc
Compare
0c64516
to
fb2c810
Compare
python_modules/dagster/dagster/_core/asset_graph_view/asset_graph_view.py
Outdated
Show resolved
Hide resolved
def latest_time_window_slice(self) -> "AssetSlice": | ||
"""Returns the latest time window for the asset slice. | ||
|
||
If the asset slice is time-window-partitiond (e.g. daily, hourly), |
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.
typo
b92518d
to
6bb9be9
Compare
fb2c810
to
aa748ae
Compare
aa748ae
to
5bfd3c4
Compare
b2a2725
to
25abc9f
Compare
5bfd3c4
to
8e151ba
Compare
25abc9f
to
1a3f697
Compare
8e151ba
to
1d2e500
Compare
fdc715f
to
1077b0d
Compare
def time_windows(self) -> Sequence[TimeWindow]: | ||
"""Get the time windows for the asset slice. Only supports explicitly time-windowed partitions for now.""" | ||
# Only supports explicitly time-windows partitions for 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.
I'm going to change this to support all time windows later. In a bit of rebase hell right 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.
@smackesey this is ready to look at
9e70a03
to
b0423d4
Compare
Deploy preview for dagit-core-storybook ready! ✅ Preview Built with commit b0423d4. |
Deploy preview for dagster-docs ready! Preview available at https://dagster-docs-aqw6hzff1-elementl.vercel.app Direct link to changed pages: |
Deploy preview for dagit-storybook ready! ✅ Preview Built with commit b0423d4. |
## Summary & Motivation Add `create_latest_time_window_slice` property to `AssetGraphView`. It gets an `AssetSlice` of the latest time window relative to the effective date of the `AssetGraphView`. ## How I Tested These Changes BK
Summary & Motivation
Add
create_latest_time_window_slice
property toAssetGraphView
. It gets anAssetSlice
of the latest time window relative to the effective date of theAssetGraphView
.How I Tested These Changes
BK