CREATE TABLE crm_service.tasks_dm (
task_id VARCHAR,
name VARCHAR,
description VARCHAR,
due_date DATE,
assignee_id VARCHAR,
status VARCHAR,
priority VARCHAR,
resource_account_id VARCHAR,
resource_client_id VARCHAR,
resource_portfolio_id VARCHAR,
resource_referral_id VARCHAR,
resource_draft_account_id VARCHAR,
resource_party_id VARCHAR,
created_by VARCHAR,
updated_by VARCHAR,
disabled_at TIMESTAMPTZ,
disabled_reason VARCHAR,
is_automated BOOLEAN,
automation_type VARCHAR,
automated_unique_key VARCHAR,
trigger_conditions JSONB,
recurrence JSONB,
completion_note VARCHAR,
updated_fields JSONB,
is_overdue BOOLEAN,
created_at TIMESTAMPTZ,
updated_at TIMESTAMPTZ,
PRIMARY KEY (task_id)
)
WITH (
snapshot='true'
) FROM crm_service.crm_service_source TABLE 'public.tasks_dm'