Skip to content

feat(domain multi-tenancy): Update Cassandra schema to be synced with recent IDL changes #7727

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.

Sign up for GitHub

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
Shaddoll merged 1 commit into from
Feb 19, 2026
Merged

feat(domain multi-tenancy): Update Cassandra schema to be synced with recent IDL changes #7727

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 3 additions & 1 deletion schema/cassandra/cadence/schema.cql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -134,6 +134,7 @@ CREATE TYPE transfer_task (
schedule_id bigint,
version bigint, -- the failover version when this task is created, used to compare against the mutable state, in case the events got overwritten
record_visibility boolean, -- indicates whether or not to create a visibility record
original_task_list text, -- the original task list of the task if the task is a sticky decision task
);

CREATE TYPE replication_task (
Expand Down Expand Up @@ -166,6 +167,7 @@ CREATE TYPE timer_task (
event_id bigint, -- Corresponds to event ID in history that is responsible for this timer.
schedule_attempt bigint, -- Used to retry failed decision tasks using mutable state
version bigint, -- the failover version when this task is created, used to compare against the mutable state, in case the events got overwritten
task_list text, -- the task list associated with the timer task
);

-- Workflow activity in progress mutable state
Expand Down Expand Up @@ -548,7 +550,7 @@ CREATE TABLE domain_audit_log (
state_after blob, -- state_after stores the domain state after the request
state_after_encoding text, -- the encoding type used for state_after

operation_type int, -- operation_type stores the type of operation that was performed. It is deserialized as an enum and can be used to customize the serialization/deserialization strategy.
operation_type int, -- operation_type stores the type of operation that was performed. It is deserialized as an enum and can be used to customize the serialization/deserialization strategy.

created_time timestamp, -- created_time the time this row was inserted
last_updated_time timestamp,
Expand Down
9 changes: 9 additions & 0 deletions schema/cassandra/cadence/versioned/v0.45/manifest.json
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,9 @@
{
"CurrVersion": "0.45",
"MinCompatibleVersion": "0.45",
"Description": "Adding original_task_list and task_list to transfer and timer tasks",
"SchemaUpdateCqlFiles": [
"transfer_task.cql",
"timer_task.cql"
]
}
1 change: 1 addition & 0 deletions schema/cassandra/cadence/versioned/v0.45/timer_task.cql
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
ALTER TYPE timer_task ADD task_list text;
1 change: 1 addition & 0 deletions schema/cassandra/cadence/versioned/v0.45/transfer_task.cql
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
ALTER TYPE transfer_task ADD original_task_list text;
2 changes: 1 addition & 1 deletion schema/cassandra/version.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ package cassandra
// NOTE: whenever there is a new data base schema update, plz update the following versions

// Version is the Cassandra database release version
const Version = "0.44"
const Version = "0.45"

// VisibilityVersion is the Cassandra visibility database release version
const VisibilityVersion = "0.10"
2 changes: 1 addition & 1 deletion tools/common/schema/updatetask_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -116,7 +116,7 @@ func (s *UpdateTaskTestSuite) TestReadSchemaDirFromEmbeddings() {
s.NoError(err)
ans, err := readSchemaDir(fsys, "0.30", "")
s.NoError(err)
s.Equal([]string{"v0.31", "v0.32", "v0.33", "v0.34", "v0.35", "v0.36", "v0.37", "v0.38", "v0.39", "v0.40", "v0.41", "v0.42", "v0.43", "v0.44"}, ans)
s.Equal([]string{"v0.31", "v0.32", "v0.33", "v0.34", "v0.35", "v0.36", "v0.37", "v0.38", "v0.39", "v0.40", "v0.41", "v0.42", "v0.43", "v0.44", "v0.45"}, ans)

fsys, err = fs.Sub(cassandra.SchemaFS, "visibility/versioned")
s.NoError(err)
Expand Down