-
Notifications
You must be signed in to change notification settings - Fork 1.9k
DagsterInstance.report_dagster_event timestamp override #29406
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
Merged
dpeng817
merged 2 commits into
dpeng817/runs_obey_event_timestamp
from
dpeng817/timestamp_event_reporting_override
May 1, 2025
Merged
DagsterInstance.report_dagster_event timestamp override #29406
dpeng817
merged 2 commits into
dpeng817/runs_obey_event_timestamp
from
dpeng817/timestamp_event_reporting_override
May 1, 2025
Conversation
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Contributor
Author
This was referenced Apr 18, 2025
16ce37e to
558fac0
Compare
7736fee to
0c863ec
Compare
558fac0 to
18ec729
Compare
0c863ec to
02ff3cd
Compare
prha
approved these changes
Apr 22, 2025
| assert failed_partitions_by_step_key == failed_partitions | ||
|
|
||
| def test_timestamp_overrides(self, storage, instance: DagsterInstance) -> None: | ||
| # instance.report_dagster_event( |
Member
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.
remove
18ec729 to
e2cf599
Compare
02ff3cd to
2e156a6
Compare
e2cf599 to
dcd8450
Compare
2e156a6 to
aca4779
Compare
dcd8450 to
ad88867
Compare
aca4779 to
01d7a9a
Compare
ad88867 to
1042d1d
Compare
01d7a9a to
9382c81
Compare
1042d1d to
f6b9f49
Compare
9382c81 to
f384500
Compare
f6b9f49 to
2923b33
Compare
f384500 to
022d09e
Compare
2923b33 to
6125bf2
Compare
022d09e to
6470700
Compare
6125bf2 to
ad57047
Compare
6470700 to
051057d
Compare
ad57047 to
c33f358
Compare
051057d to
f0e31a5
Compare
c33f358 to
9417cf2
Compare
f0e31a5 to
8207c6f
Compare
9417cf2 to
813d40f
Compare
8207c6f to
67c8514
Compare
813d40f to
2a1333e
Compare
67c8514 to
4f426fa
Compare
2a1333e to
7e32499
Compare
4f426fa to
543adf6
Compare
7e32499 to
e30a5d8
Compare
543adf6 to
318ce50
Compare
e30a5d8 to
bafa107
Compare
318ce50 to
40306f7
Compare
bafa107 to
560b46c
Compare
40306f7 to
dc28ff0
Compare
This was referenced Apr 25, 2025
Closed
560b46c to
a7a7759
Compare
dc28ff0 to
803e7e4
Compare
Merged
a7a7759 to
f03f68a
Compare
803e7e4 to
eb8511b
Compare
Merged
f03f68a to
834b9f0
Compare
eb8511b to
fde1ebf
Compare
## Summary & Motivation Apply the downstack storage changes to Airlift - specifically: - Create correctly dated historical runs - Create correctly dated events ## How I Tested These Changes - Altered existing tests to have additional assertions around timing.
126d4fd
into
dpeng817/runs_obey_event_timestamp
1 check was pending
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.

Summary & Motivation
Allow overriding the timestamp set on the event log entry. This allows for backdating events.
How I Tested These Changes
Added a new storage test