Skip to content
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

feat: add context.is_first_time_subgraph_is_scheduled to simplify replaying operators #906

Merged
merged 1 commit into from
Sep 14, 2023

Conversation

zzlk
Copy link
Contributor

@zzlk zzlk commented Sep 13, 2023

fixes #875

@MingweiSamuel
Copy link
Member

I think it would be cleaner to track the run info in SubgraphData, probably as a last_tick_run: usize field

@@ -50,6 +52,13 @@ impl Context {
self.current_tick_start
}

/// Gets whether this is the first time this subgraph is being scheduled for this tick
pub fn is_first_time_subgraph_is_scheduled(&self) -> bool {
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Maybe [is_]first_run_this_tick()?

@zzlk zzlk merged commit d254e2d into hydro-project:main Sep 14, 2023
11 checks passed
MingweiSamuel added a commit to MingweiSamuel/hydroflow that referenced this pull request Nov 7, 2023
MingweiSamuel added a commit to MingweiSamuel/hydroflow that referenced this pull request Nov 7, 2023
MingweiSamuel added a commit to MingweiSamuel/hydroflow that referenced this pull request Nov 7, 2023
MingweiSamuel added a commit that referenced this pull request Nov 7, 2023
…ck` check, fixes #958 (#959)

Introduced in #906

Also adds more `multiset_delta` tests.

Refs: #958, #906
nickjiang2378 pushed a commit to nickjiang2378/hydroflow that referenced this pull request Jan 24, 2024
nickjiang2378 pushed a commit to nickjiang2378/hydroflow that referenced this pull request Jan 24, 2024
nickjiang2378 pushed a commit to nickjiang2378/hydroflow that referenced this pull request Jan 25, 2024
nickjiang2378 pushed a commit to nickjiang2378/hydroflow that referenced this pull request Jan 25, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Add a is_new_tick (is_first_run_in_tick or !is_repeat_run) parameter to #context or somewhere else
2 participants