CREATE SINK alinma_bff.tasks_sink AS
SELECT
task_id,
name,
description,
due_date,
status,
priority,
assignee_id,
created_by,
updated_by,
created_at,
updated_at,
is_automated,
automation_type,
resource_account_id,
resource_client_id,
resource_portfolio_id,
resource_party_id,
resource_draft_account_id,
resource_referral_id,
resource_type,
resource_id
FROM alinma_bff.tasks_mv
WITH (
connector='postgres',
host='psql-nonprod-uae-derived.postgres.database.azure.com',
port='6432',
user='migration_user',
password='***',
database='alinma-int-advisor-portal-bff',
table='tasks',
schema='advisor_portal_bff',
type='upsert',
force_compaction='true',
primary_key='task_id'
)