| Actor | Fragment | Worker | State |
|---|---|---|---|
| 53192 | 2452 | 3 | running |
| 53193 | 2452 | 3 | running |
| 53196 | 2445 | 3 | running |
| 53197 | 2445 | 3 | running |
| 53535 | 2444 | 3 | running |
| 53536 | 2444 | 3 | running |
| 53537 | 2446 | 3 | running |
| 53538 | 2446 | 3 | running |
| 53539 | 2451 | 3 | running |
| 53540 | 2451 | 3 | running |
| 53541 | 2448 | 3 | running |
| 53542 | 2448 | 3 | running |
CREATE MATERIALIZED VIEW authz.active_parties_to_accounts_mv
WITH (
backfill_order=FIXED(party.customer_relationships -> olap.party_involvements_dm)
) AS
SELECT
inv.party_id,
inv.entity_id AS account_id,
MAX(
GREATEST(
COALESCE(cr.updated_at, CAST(inv.effective_from AS TIMESTAMPTZ)),
COALESCE(cr.status_changed_at, CAST(inv.effective_from AS TIMESTAMPTZ)),
CAST(inv.effective_from AS TIMESTAMPTZ)
)
) AS updated_at
FROM (
SELECT
party_id,
customer_relationship_id,
entity_id,
effective_from
FROM olap.party_involvements_dm
WHERE
entity_type = 'ACCOUNT'
AND involvement_type = 'ACCOUNT_HOLDER'
AND status = 'ACTIVE'
AND disabled_at IS NULL
AND effective_from <= CURRENT_TIMESTAMP
AND (
effective_to IS NULL OR effective_to > CURRENT_TIMESTAMP
)
) AS inv
JOIN party.customer_relationships FOR SYSTEM_TIME AS OF PROCTIME() AS cr
ON cr.id = inv.customer_relationship_id
AND cr.type = 'CUSTOMER'
AND cr.status = 'ACTIVE'
AND cr.disabled_at IS NULL
GROUP BY
inv.party_id,
inv.entity_id