| Actor | Fragment | Worker | State |
|---|---|---|---|
| 53753 | 2668 | 3 | running |
| 53754 | 2668 | 3 | running |
| 54383 | 2669 | 3 | running |
| 54384 | 2669 | 3 | running |
| 54385 | 2670 | 3 | running |
| 54386 | 2670 | 3 | running |
| 54387 | 2673 | 3 | running |
| 54388 | 2673 | 3 | running |
| 54389 | 2676 | 3 | running |
| 54390 | 2676 | 3 | running |
| 54391 | 2671 | 3 | running |
| 54392 | 2671 | 3 | running |
CREATE MATERIALIZED VIEW authz.user_accessible_tasks_mv AS
SELECT
user_id,
task_id,
updated_at
FROM (
SELECT
user_id,
task_id,
updated_at,
ROW_NUMBER() OVER (PARTITION BY user_id, task_id ORDER BY updated_at DESC) AS rn
FROM (
SELECT
uac.user_id,
t.task_id,
t.updated_at
FROM olap.tasks_dm AS t
JOIN authz.user_accessible_clients_mv AS uac
ON uac.client_id = t.resource_client_id
WHERE
t.disabled_at IS NULL
UNION ALL
SELECT
uaa.user_id,
t.task_id,
t.updated_at
FROM olap.tasks_dm AS t
JOIN authz.user_accessible_accounts_mv AS uaa
ON uaa.account_id = t.resource_account_id
WHERE
t.disabled_at IS NULL
UNION ALL
SELECT
uap.user_id,
t.task_id,
t.updated_at
FROM olap.tasks_dm AS t
JOIN authz.user_accessible_portfolios_mv AS uap
ON uap.portfolio_id = t.resource_portfolio_id
WHERE
t.disabled_at IS NULL
UNION ALL
SELECT
t.assignee_id AS user_id,
t.task_id,
t.updated_at
FROM olap.tasks_dm AS t
WHERE
t.disabled_at IS NULL
AND NOT t.assignee_id IS NULL
AND t.resource_client_id IS NULL
AND t.resource_portfolio_id IS NULL
AND t.resource_account_id IS NULL
AND t.resource_referral_id IS NULL
AND t.resource_draft_account_id IS NULL
AND t.resource_party_id IS NULL
UNION ALL
SELECT
t.created_by AS user_id,
t.task_id,
t.updated_at
FROM olap.tasks_dm AS t
WHERE
t.disabled_at IS NULL
AND NOT t.created_by IS NULL
AND t.resource_client_id IS NULL
AND t.resource_portfolio_id IS NULL
AND t.resource_account_id IS NULL
AND t.resource_referral_id IS NULL
AND t.resource_draft_account_id IS NULL
AND t.resource_party_id IS NULL
)
)
WHERE
rn = 1