create table if not exists repo_upstream ( id bigserial primary key, repo_uuid uuid not null unique, source_url varchar(255) not null, direction varchar(255) not null, schedule_cron varchar(255), last_run_at timestamp with time zone, next_run_at timestamp with time zone, status varchar(255) not null, created_at timestamp with time zone not null, updated_at timestamp with time zone not null ); create unique index if not exists idx_repo_upstream_repo on repo_upstream (repo_uuid);