mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-30 14:56:19 +00:00
Stephan BehnkeandDavid Reiss
8ee1f49318
## What changed? Added new flag to tdbg's `list-tasks` command to query the fairness table instead. ## Why? Allow operation on fairness table, too. ## How did you test it? - [ ] built - [x] run locally and tested manually - [ ] covered by existing tests - [ ] added new unit test(s) - [ ] added new functional test(s) ``` ./tdbg taskqueue list-tasks --task-queue-type TASK_QUEUE_TYPE_WORKFLOW --task-queue test --min-pass 1 ``` It's late ... I didn't manage to see a result, though. But it didn't fail and I saw the query being executed in the debugger.
18 lines
848 B
Cassandra CQL
18 lines
848 B
Cassandra CQL
CREATE TABLE tasks_v2
|
|
(
|
|
namespace_id uuid,
|
|
task_queue_name text,
|
|
task_queue_type int, -- enum TaskQueueType {ActivityTask, WorkflowTask}
|
|
type int, -- enum rowType {Task, TaskQueue} and subqueue id
|
|
pass bigint, -- pass for tasks (see stride scheduling algorithm for fairness)
|
|
task_id bigint, -- unique identifier for tasks
|
|
range_id bigint, -- used to ensure that only one process can write to the table
|
|
ack_level bigint, -- ack level for the task queue
|
|
task blob,
|
|
task_encoding text,
|
|
task_queue blob,
|
|
task_queue_encoding text,
|
|
PRIMARY KEY ((namespace_id, task_queue_name, task_queue_type), type, pass, task_id)
|
|
) WITH COMPACTION = {
|
|
'class': 'org.apache.cassandra.db.compaction.LeveledCompactionStrategy'
|
|
}; |