diff --git a/airbyte-webapp/src/area/connection/components/JobHistoryItem/JobStatusLabel.tsx b/airbyte-webapp/src/area/connection/components/JobHistoryItem/JobStatusLabel.tsx index d33efde3823..cf000717ca8 100644 --- a/airbyte-webapp/src/area/connection/components/JobHistoryItem/JobStatusLabel.tsx +++ b/airbyte-webapp/src/area/connection/components/JobHistoryItem/JobStatusLabel.tsx @@ -5,17 +5,23 @@ import { Text } from "components/ui/Text"; import { JobWithAttempts } from "area/connection/types/jobs"; import { isJobPartialSuccess, getJobAttempts, getJobStatus } from "area/connection/utils/jobs"; import { JobStatus } from "core/api/types/AirbyteClient"; +import { useExperiment } from "hooks/services/Experiment"; interface JobStatusLabelProps { jobWithAttempts: JobWithAttempts; } export const JobStatusLabel: React.FC = ({ jobWithAttempts }) => { + const sayClearInsteadOfReset = useExperiment("connection.clearNotReset", false); + const attempts = getJobAttempts(jobWithAttempts); const jobStatus = getJobStatus(jobWithAttempts); const jobIsPartialSuccess = isJobPartialSuccess(attempts); const streamsToReset = "job" in jobWithAttempts ? jobWithAttempts.job.resetConfig?.streamsToReset : undefined; - const jobConfigType = jobWithAttempts.job.configType; + const jobConfigType = + sayClearInsteadOfReset && jobWithAttempts.job.configType === "reset_connection" + ? "clear_data" + : jobWithAttempts.job.configType; let status = ""; if (jobIsPartialSuccess) { diff --git a/airbyte-webapp/src/locales/en.json b/airbyte-webapp/src/locales/en.json index 8ba1659c007..c89263fed4b 100644 --- a/airbyte-webapp/src/locales/en.json +++ b/airbyte-webapp/src/locales/en.json @@ -445,6 +445,11 @@ "jobs.jobStatus.reset_connection.succeeded": "Reset Succeeded ({count, plural, =0 {0 streams} one {# stream} other {# streams}})", "jobs.jobStatus.reset_connection.cancelled": "Reset Cancelled ({count, plural, =0 {0 streams} one {# stream} other {# streams}})", "jobs.jobStatus.reset_connection.partialSuccess": "Reset Partial Success ({count, plural, =0 {0 streams} one {# stream} other {# streams}})", + "jobs.jobStatus.clear_data.failed": "Clearing {count, plural, =0 {0 Streams} one {Stream} other {Streams}} Failed", + "jobs.jobStatus.clear_data.running": "Clearing {count, plural, =0 {0 Streams} one {Stream} other {Streams}} Running", + "jobs.jobStatus.clear_data.succeeded": "Clearing {count, plural, =0 {0 Streams} one {Stream} other {Streams}} Succeeded", + "jobs.jobStatus.clear_data.cancelled": "Clearing {count, plural, =0 {0 Streams} one {Stream} other {Streams}} Cancelled", + "jobs.jobStatus.clear_data.partialSuccess": "Clearing {count, plural, =0 {0 Streams} one {Stream} other {Streams}} Partially Succeeded", "jobs.jobStatus.sync.failed": "Sync Failed", "jobs.jobStatus.sync.running": "Sync Running", "jobs.jobStatus.sync.succeeded": "Sync Succeeded",