| Actor | Fragment | Worker | State |
|---|---|---|---|
| 54451 | 2702 | 3 | running |
| 54452 | 2702 | 3 | running |
| 54453 | 2710 | 3 | running |
| 54454 | 2710 | 3 | running |
| 54455 | 2711 | 3 | running |
| 54456 | 2711 | 3 | running |
| 54457 | 2703 | 3 | running |
| 54458 | 2703 | 3 | running |
| 54459 | 2704 | 3 | running |
| 54460 | 2704 | 3 | running |
| 54461 | 2708 | 3 | running |
| 54462 | 2708 | 3 | running |
CREATE MATERIALIZED VIEW insights.party_to_account_groups_mv AS
WITH active_customer_parties AS (
SELECT
p.id AS party_id
FROM party.parties AS p
JOIN (
SELECT
party_id
FROM party.customer_relationships
WHERE
type = 'CUSTOMER' AND status = 'ACTIVE' AND disabled_at IS NULL
GROUP BY
party_id
) AS cr
ON cr.party_id = p.id
WHERE
p.disabled_at IS NULL
)
SELECT
party_id,
'account_group_' || MD5(CAST((
party_id || 'none'
) AS BYTEA)) AS account_group_id,
CAST('none' AS VARCHAR) AS type
FROM active_customer_parties
UNION ALL
SELECT
acp.party_id,
'account_group_' || MD5(CAST((
acp.party_id || 'all'
) AS BYTEA)) AS account_group_id,
CAST('all' AS VARCHAR) AS type
FROM active_customer_parties AS acp
JOIN insights.parties_with_accounts_mv AS pwa
ON pwa.party_id = acp.party_id
UNION ALL
SELECT
acp.party_id,
'account_group_' || MD5(CAST((
acp.party_id || 'restricted'
) AS BYTEA)) AS account_group_id,
CAST('restricted' AS VARCHAR) AS type
FROM active_customer_parties AS acp
JOIN insights.parties_with_accounts_mv AS pwa
ON pwa.party_id = acp.party_id
UNION ALL
SELECT
acp.party_id,
'account_group_' || MD5(CAST((
acp.party_id || 'un_restricted'
) AS BYTEA)) AS account_group_id,
CAST('un_restricted' AS VARCHAR) AS type
FROM active_customer_parties AS acp
JOIN insights.parties_with_accounts_mv AS pwa
ON pwa.party_id = acp.party_id