Workflows app queues

workflows_app_queues

• Schema: public
• PK: workflows_app_queue_id (uuid, gen_random_uuid())

Columns

Column	Type	Nullable	Default	Notes
workflows_app_queue_id	uuid	NO	gen_random_uuid()	PK
workflows_app_queue_name	varchar	YES
workflows_app_queue_status	varchar	YES		active, paused, deleted
consumer_workflow_id	uuid	YES		FK to workflows
consumer_workflow_module_instance_id	varchar	YES		Module instance consuming this queue
flush_batch_size	int4	NO		Records per flush
flush_record_max_age	int4	YES		Max age (seconds) before forced flush
workspace_id	bigint	YES		FK to workspaces
created_by	bigint	YES
created_time	timestamp	YES	now()
last_modified_by	bigint	YES
last_modified_time	timestamp	YES	now()
options	jsonb	YES
flush_rate_limit_max_flush_count	int4	YES		Max flushes per window
flush_rate_limit_time_window	int4	YES		Window size (seconds)
flush_strategy	varchar	YES	'fifo'	fifo or other strategies
workflows_app_queue_resource_id	varchar	NO		Human-readable resource ID
parent_folders	jsonb	YES		Folder hierarchy path
force_queue_flush_count	int4	YES		Force flush after N records

Key indexes

• workflows_app_queues_pkey on (workflows_app_queue_id)
• unique_workflows_app_queue_resource_id UNIQUE on (workflows_app_queue_resource_id, workspace_id) WHERE workflows_app_queue_status <> 'deleted'
• unique_workflow_app_queue_name UNIQUE on (workflows_app_queue_name, workspace_id) WHERE workflows_app_queue_status <> 'deleted'

Notes

• Durable queue between syncs/workflows; records accumulate until flush criteria are met.
• Soft-deleted via workflows_app_queue_status = 'deleted'.

---