| | |
|---|
| | | `id` VARCHAR(64) NOT NULL, |
|---|
| | | `type` varchar(50) NOT NULL, |
|---|
| | | `user_id` {$this->userIDType} NOT NULL, |
|---|
| | | |
|---|
| | | `request_data` JSON NOT NULL, |
|---|
| | | `count` int(11) NOT NULL DEFAULT 1, |
|---|
| | | `progress_count` int(11) DEFAULT 0, |
|---|
| | | |
|---|
| | | `total_items` int(11) NOT NULL DEFAULT 1, |
|---|
| | | `processed_items` int(11) DEFAULT 0, |
|---|
| | | `failed_items` JSON, |
|---|
| | | |
|---|
| | | `priority` enum('low', 'normal', 'high') DEFAULT 'normal', |
|---|
| | | `status` enum('pending', 'scheduled', 'processing','failed', 'failed_permanent', 'completed', 'completed_with_errors') DEFAULT 'pending', |
|---|
| | | `metadata` JSON DEFAULT NULL, |
|---|
| | | `merge` enum('merge', 'append', 'replace') DEFAULT 'merge', |
|---|
| | | `scheduled_at` datetime DEFAULT CURRENT_TIMESTAMP, |
|---|
| | | `created_at` datetime DEFAULT CURRENT_TIMESTAMP, |
|---|
| | | `updated_at` datetime DEFAULT CURRENT_TIMESTAMP, |
|---|
| | | `started_at` datetime DEFAULT NULL, |
|---|
| | | // `status` enum('pending', 'scheduled', 'processing','failed', 'failed_permanent', 'completed', 'completed_with_errors') DEFAULT 'pending', |
|---|
| | | `state` enum('pending', 'scheduled', 'processing', 'completed'), |
|---|
| | | `outcome` enum('success', 'partial', 'failed','failed_permanent'), |
|---|
| | | |
|---|
| | | `retries` int(11) DEFAULT 0, |
|---|
| | | `last_error_hash` CHAR(32) DEFAULT NULL, |
|---|
| | | `error_message` text, |
|---|
| | | |
|---|
| | | `scheduled_at` datetime DEFAULT CURRENT_TIMESTAMP, |
|---|
| | | `started_at` datetime DEFAULT CURRENT_TIMESTAMP, |
|---|
| | | `completed_at` datetime DEFAULT NULL, |
|---|
| | | `retries` int(11) DEFAULT 0, |
|---|
| | | |
|---|
| | | `metadata` JSON DEFAULT NULL, |
|---|
| | | `result` JSON, |
|---|
| | | `dependencies` JSON, |
|---|
| | | `error_message` text, |
|---|
| | | // `merge` enum('merge', 'append', 'replace') DEFAULT 'merge', |
|---|
| | | |
|---|
| | | `user_dismissed` tinyint(1) DEFAULT 0, |
|---|
| | | PRIMARY KEY (`id`), |
|---|
| | | KEY `idx_status_priority` (`status`, `priority`), |
|---|
| | | KEY `idx_user_type` (`user_id`, `type`), |
|---|
| | | KEY `idx_created_at` (`created_at`), |
|---|
| | | KEY `idx_completed_at` (`completed_at`), |
|---|
| | | KEY `idx_user_status` (`user_id`, `status`), |
|---|
| | | KEY `idx_retries_status` (`retries`, `status`), |
|---|
| | | KEY `idx_user_status_created` (`user_id`, `status`, `created_at`), |
|---|
| | | KEY `idx_scheduled_processing` (`scheduled_at`, `status`) |
|---|
| | | `created_at` DATETIME DEFAULT CURRENT_TIMESTAMP, |
|---|
| | | `updated_at` DATETIME DEFAULT CURRENT_TIMESTAMP, |
|---|
| | | PRIMARY KEY (`id`), |
|---|
| | | KEY `idx_run_queue` (state, priority, scheduled_at), |
|---|
| | | KEY `idx_user_ops` (user_id, state), |
|---|
| | | KEY `idx_user_type_pending` (user_id, type, state), |
|---|
| | | KEY `idx_completed_at` (completed_at) |
|---|
| | | )", |
|---|
| | | |
|---|
| | | 'stats__operation_queue' => "( |
|---|
| | | `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT, |
|---|
| | | `date` date NOT NULL, |
|---|
