-
Notifications
You must be signed in to change notification settings - Fork 1.3k
CHASM: SQL separate ID spaces #8915
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
base: main
Are you sure you want to change the base?
Conversation
| ctx context.Context, | ||
| row *sqlplugin.CurrentExecutionsRow, | ||
| ) (sql.Result, error) { | ||
| if row.ArchetypeID == chasm.WorkflowArchetypeID { |
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.
Don't we also need to check for 0 here for backward compatibility?
like archetypeID == chasm.WorkflowArchetypeID || archetypeID == chasm.UnspecifiedArchetypeID
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.
no, not really. Even for existing executions, application layer will pass down chasm.WorkflowArchetypeID.
There's also a check in execution manager to guarantee that 0 is never used: https://github.com/temporalio/temporal/blob/main/common/persistence/execution_manager.go#L1186
|
|
||
| func (s *ExecutionMutableStateSuite) TestArchetypeSeparateIDSpace() { | ||
| if strings.HasPrefix(s.T().Name(), "TestCassandra") { | ||
| s.T().Skip("Separate ID space is only implemented by sql persistence") |
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.
Please remember to remove this after merging Cassandra changes.
| SetupPostgreSQLSchema(p.T(), cfg) | ||
| store, err := sql.NewSQLDB(sqlplugin.DbKindMain, cfg, resolver.NewNoopResolver(), log.NewTestLogger(), metrics.NoopMetricsHandler) | ||
| if err != nil { | ||
| p.T().Fatalf("unable to create MySQL DB: %v", err) |
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.
| p.T().Fatalf("unable to create MySQL DB: %v", err) | |
| p.T().Fatalf("unable to create PostgreSQL DB: %v", err) |
What changed?
Why?
How did you test it?