mirror of
https://github.com/supabase/supabase.git
synced 2026-09-09 19:42:46 +08:00
## Summary Adds initial-copy scoping to Pipelines in Studio. Users can copy all existing rows, skip all initial copies, copy only selected publication tables, or skip selected table copies. All publication tables continue streaming new changes regardless of the initial-copy policy. The policy now round-trips through create, edit, validation, and the generated Management API contract. Initial-copy estimates and table-restart confirmations use the same scope. Edit requests also preserve redacted credentials and pipeline settings that Studio does not own. This completes the Studio layer of the [ETL API change](https://github.com/supabase/etl/pull/897) and [Management API change](https://github.com/supabase/platform/pull/35479). ## Screenshots ### Selector <img width="1153" height="465" alt="image" src="https://github.com/user-attachments/assets/bf615e82-ee61-4222-979d-a8695a957e82" /> ### Select certain tables only <img width="1153" height="465" alt="image" src="https://github.com/user-attachments/assets/28adaa24-f239-4d1d-8fb8-fdb1988320cd" /> ### Confirm copy costs As the final step before the pipeline is created: <img width="597" height="619" alt="image" src="https://github.com/user-attachments/assets/a660bd87-bfb8-41c5-8099-4cdbdef943bf" /> ### Policy-aware initial-copy estimate #### Copy no table is selected <img width="407" height="464" alt="image" src="https://github.com/user-attachments/assets/99d859ec-2ec3-452a-ab69-11924a8db260" /> #### Some tables are selected <img width="407" height="464" alt="image" src="https://github.com/user-attachments/assets/e68aedf4-66bc-4372-98ef-0dd7fecef324" /> <!-- This is an auto-generated comment: release notes by coderabbit.ai --> ## Summary by CodeRabbit - **New Features** - Added configurable “initial table copy” policies (copy/skip all and copy/skip selected) during replication setup, including table-picker behavior, pruning of stale selections, and updated restart/cost estimates. - **Bug Fixes** - Improved restart flows to consistently use `schema.table` identity and simplified “errored tables” targeting to match error-state tables. - Reduced unnecessary loading by gating publication/table fetches to when panels are visible; improved validation/toast handling when publication tables are unavailable. - **Tests** - Added/expanded coverage for destination form submission, table-copy selection, restart/cost dialogs, and copy-estimate summarization. - **Style** - Refreshed warning/label text for clearer configuration and confirmation messaging. <!-- end of auto-generated comment: release notes by coderabbit.ai --> --------- Co-authored-by: Victor Farazdagi <simple.square@gmail.com> Co-authored-by: Joshen Lim <joshenlimek@gmail.com>
79 lines
3.2 KiB
TypeScript
79 lines
3.2 KiB
TypeScript
import { useParams } from 'common'
|
|
import { CriticalIcon } from 'ui'
|
|
|
|
import { isValidRetryPolicy } from './ReplicationPipelineStatus/ReplicationPipelineStatus.utils'
|
|
import { RetryCountdown } from './RetryCountdown'
|
|
import { InlineLink } from '@/components/ui/InlineLink'
|
|
import { ReplicationPipelineTableStatus } from '@/data/replication/pipeline-replication-status-query'
|
|
|
|
interface ErroredTableDetailsProps {
|
|
table: ReplicationPipelineTableStatus
|
|
}
|
|
|
|
export const ErroredTableDetails = ({ table }: ErroredTableDetailsProps) => {
|
|
const { ref: projectRef } = useParams()
|
|
|
|
const state = table.state as Extract<ReplicationPipelineTableStatus['state'], { name: 'error' }>
|
|
const tableName = `${table.schema}.${table.name}`
|
|
const retryPolicy = state.retry_policy.policy
|
|
|
|
if (!isValidRetryPolicy(state.retry_policy)) {
|
|
return (
|
|
<div
|
|
role="region"
|
|
className="flex flex-col gap-y-3"
|
|
aria-label={`Error details for table ${tableName}`}
|
|
>
|
|
{state.solution && <div className="text-xs text-foreground-light">{state.solution}</div>}
|
|
<div className="text-xs text-foreground-lighter">Invalid retry policy configuration</div>
|
|
</div>
|
|
)
|
|
}
|
|
|
|
return (
|
|
<div role="region" aria-label={`Error details for table ${tableName}`}>
|
|
{retryPolicy === 'no_retry' ? (
|
|
<div className="flex flex-col gap-y-3">
|
|
<p className="text-xs text-foreground-lighter">
|
|
This error requires manual intervention from our{' '}
|
|
<InlineLink
|
|
className="text-foreground-lighter hover:text-foreground"
|
|
href={`/support?projectRef=${projectRef}&category=dashboard_bug&subject=Database%20replication%20error&error=${encodeURIComponent(state.reason ?? '')}`}
|
|
>
|
|
support
|
|
</InlineLink>
|
|
. Alternatively, you may also recreate the pipeline. Use the table actions menu on the
|
|
right to view the full error details.
|
|
</p>
|
|
</div>
|
|
) : retryPolicy === 'manual_retry' ? (
|
|
<div className="flex flex-col gap-y-3">
|
|
<div className="rounded-md border border-destructive-400 bg-destructive-100 px-3 py-3 space-y-2">
|
|
<div className="flex items-start gap-x-2">
|
|
<CriticalIcon />
|
|
<div className="flex-1 text-xs text-destructive-900">
|
|
<p className="font-semibold mb-1">Action required to continue replication</p>
|
|
<p className="text-foreground-light">
|
|
{state.solution}
|
|
{state.solution && !/[.!?]$/.test(state.solution.trim()) && '.'}
|
|
</p>
|
|
<p className="text-foreground-light mt-2">
|
|
Restart table replication from the table actions menu on the right. The pipeline
|
|
will restart automatically.
|
|
</p>
|
|
</div>
|
|
</div>
|
|
</div>
|
|
</div>
|
|
) : retryPolicy === 'timed_retry' ? (
|
|
<div className="flex flex-col text-foreground-lighter gap-y-3">
|
|
<p className="text-xs">
|
|
Replication will retry automatically. The pipeline will restart to apply the retry.
|
|
</p>
|
|
<RetryCountdown nextRetryTime={state.retry_policy.next_retry} />
|
|
</div>
|
|
) : null}
|
|
</div>
|
|
)
|
|
}
|