-
Notifications
You must be signed in to change notification settings - Fork 69
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* Mock versioning rules * MVP of assignment rules table and header. just need to test when ready * Merge in main and fix conflicts * Fix rules type * Refactor to use PollerIcon * Bump to latest api version * Update README for running Temporal server locally * Remove test api, set notifyOnError to false * Remove commented out mock
- Loading branch information
1 parent
6caf9ec
commit d27f01a
Showing
18 changed files
with
865 additions
and
258 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Large diffs are not rendered by default.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,47 @@ | ||
| { | ||
| "assignmentRules": [ | ||
| { | ||
| "rule": { | ||
| "targetBuildId": "1.10", | ||
| "ramp": { | ||
| "percentageRamp": { | ||
| "rampPercentage": 0.2 | ||
| } | ||
| } | ||
| }, | ||
| "createTime": "2024-01-01T00:00:00Z" | ||
| }, | ||
| { | ||
| "rule": { | ||
| "targetBuildId": "1.11", | ||
| "ramp": { | ||
| "percentageRamp": { | ||
| "rampPercentage": 0.4 | ||
| } | ||
| } | ||
| }, | ||
| "createTime": "2024-02-01T00:00:00Z" | ||
| }, | ||
| { | ||
| "rule": { | ||
| "targetBuildId": "1.12", | ||
| "ramp": { | ||
| "percentageRamp": { | ||
| "rampPercentage": 0.5 | ||
| } | ||
| } | ||
| }, | ||
| "createTime": "2024-03-01T00:00:00Z" | ||
| } | ||
| ], | ||
| "compatibleRedirectRules": [ | ||
| { | ||
| "rule": { | ||
| "sourceBuildId": "1.12", | ||
| "targetBuildId": "1.13" | ||
| }, | ||
| "createTime": "2024-01-01T00:00:00Z" | ||
| } | ||
| ], | ||
| "conflictToken": "abcd1234" | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,14 @@ | ||
| <script lang="ts"> | ||
| import Icon from '$lib/holocene/icon/icon.svelte'; | ||
| import { translate } from '$lib/i18n/translate'; | ||
| export let includesTaskQueueType: boolean; | ||
| </script> | ||
|
|
||
| <Icon | ||
| name={includesTaskQueueType ? 'checkmark' : 'close'} | ||
| class="m-auto {includesTaskQueueType ? 'text-blue-700' : 'text-primary'}" | ||
| title={includesTaskQueueType | ||
| ? translate('common.yes') | ||
| : translate('common.no')} | ||
| /> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,175 @@ | ||
| <script lang="ts"> | ||
| import Badge from '$lib/holocene/badge.svelte'; | ||
| import CompatibilityBadge from '$lib/holocene/compatibility-badge.svelte'; | ||
| import EmptyState from '$lib/holocene/empty-state.svelte'; | ||
| import TableHeaderRow from '$lib/holocene/table/table-header-row.svelte'; | ||
| import TableRow from '$lib/holocene/table/table-row.svelte'; | ||
| import Table from '$lib/holocene/table/table.svelte'; | ||
| import { translate } from '$lib/i18n/translate'; | ||
| import { | ||
| getBuildIdReachability, | ||
| type GetPollersResponse, | ||
| type TaskQueueCompatibility, | ||
| type WorkerReachability, | ||
| } from '$lib/services/pollers-service'; | ||
| import { relativeTime, timeFormat } from '$lib/stores/time-format'; | ||
| import { formatDate } from '$lib/utilities/format-date'; | ||
| import { | ||
| getCurrentCompatibilityDefaultVersion, | ||
| getCurrentPollerBuildId, | ||
| getDefaultVersionForSet, | ||
| getNonDefaultVersionsForSet, | ||
| getOrderedVersionSets, | ||
| } from '$lib/utilities/task-queue-compatibility'; | ||
| import PollerIcon from './poller-icon.svelte'; | ||
| export let taskQueue: string; | ||
| export let workers: GetPollersResponse; | ||
| export let reachability: WorkerReachability | undefined = undefined; | ||
| export let compatibility: TaskQueueCompatibility | undefined = undefined; | ||
| $: versionSets = getOrderedVersionSets(compatibility); | ||
| $: defaultVersion = getCurrentCompatibilityDefaultVersion(compatibility); | ||
| </script> | ||
|
|
||
| <h2 class="text-base font-medium" data-testid="version-sets"> | ||
| {translate('workers.version-sets')} | ||
| </h2> | ||
| <Table class="mb-6 w-full min-w-[600px] table-fixed"> | ||
| <TableHeaderRow slot="headers"> | ||
| <th class="w-3/12">{translate('workers.default')}</th> | ||
| <th class="w-9/12">{translate('workers.compatible-build-ids')}</th> | ||
| </TableHeaderRow> | ||
| {#each versionSets as set, index (index)} | ||
| <TableRow data-testid="version-row"> | ||
| <td class="text-left" data-testid="version-default"> | ||
| <CompatibilityBadge | ||
| defaultVersion | ||
| active={index === 0} | ||
| buildId={getDefaultVersionForSet(set.buildIds)} | ||
| > | ||
| <svelte:fragment slot="overall-default-worker"> | ||
| {#if index === 0}{translate('workers.overall')}{/if} | ||
| </svelte:fragment> | ||
| <svelte:fragment slot="default-worker"> | ||
| {translate('workers.default')} | ||
| </svelte:fragment> | ||
| </CompatibilityBadge> | ||
| </td> | ||
| <td class="text-left" data-testid="version-compatible-builds"> | ||
| <div class="flex flex-wrap gap-2 font-mono"> | ||
| {#each getNonDefaultVersionsForSet(set.buildIds) as buildId} | ||
| <CompatibilityBadge active={false} {buildId}> | ||
| <svelte:fragment slot="default-worker"> | ||
| {translate('workers.default')} | ||
| </svelte:fragment> | ||
| </CompatibilityBadge> | ||
| {/each} | ||
| </div> | ||
| </td> | ||
| </TableRow> | ||
| {:else} | ||
| <tr class="w-full"> | ||
| <td colspan="6"> | ||
| <EmptyState title={translate('workers.no-version-sets-found')} /> | ||
| </td> | ||
| </tr> | ||
| {/each} | ||
| </Table> | ||
| <h2 class="flex items-center gap-2 text-base font-medium" data-testid="workers"> | ||
| {translate('workers.workers')} | ||
| <Badge type="count" class="rounded-sm">{workers?.pollers?.length || 0}</Badge> | ||
| </h2> | ||
| <Table class="mb-6 w-full min-w-[600px] table-fixed"> | ||
| <caption class="sr-only" slot="caption" | ||
| >{translate('workflows.workers-tab')}</caption | ||
| > | ||
| <TableHeaderRow slot="headers"> | ||
| <th class={reachability?.buildIdReachability?.length ? 'w-3/12' : 'w-6/12'} | ||
| >{translate('common.id')}</th | ||
| > | ||
| {#if reachability?.buildIdReachability?.length} | ||
| <th class="w-3/12">{translate('workers.version')}</th> | ||
| <th class="w-2/12">{translate('workers.retirability')}</th> | ||
| {/if} | ||
| <th class="w-2/12">{translate('workflows.last-accessed')}</th> | ||
| <th class="w-2/12"> | ||
| <p class="text-center"> | ||
| {translate('workflows.workflow-task-handler')} | ||
| </p> | ||
| </th> | ||
| <th class="w-2/12 text-center"> | ||
| <p class="text-center">{translate('workflows.activity-handler')}</p> | ||
| </th> | ||
| </TableHeaderRow> | ||
| {#each workers?.pollers as poller (poller.identity)} | ||
| {@const buildId = getCurrentPollerBuildId(poller)} | ||
| {@const pollerReachability = getBuildIdReachability( | ||
| reachability, | ||
| taskQueue, | ||
| buildId, | ||
| )} | ||
| <TableRow data-testid="worker-row"> | ||
| <td class="text-left" data-testid="worker-identity"> | ||
| <p class="select-all">{poller.identity}</p> | ||
| </td> | ||
| {#if reachability?.buildIdReachability?.length} | ||
| <td class="text-left" data-testid="worker-identity"> | ||
| <p class="select-all"> | ||
| <CompatibilityBadge | ||
| defaultVersion={buildId === defaultVersion} | ||
| active={buildId === defaultVersion} | ||
| {buildId} | ||
| > | ||
| <svelte:fragment slot="overall-default-worker"> | ||
| {#if buildId === defaultVersion}{translate( | ||
| 'workers.overall', | ||
| )}{/if} | ||
| </svelte:fragment> | ||
| <svelte:fragment slot="default-worker"> | ||
| {translate('workers.default')} | ||
| </svelte:fragment> | ||
| </CompatibilityBadge> | ||
| </p> | ||
| </td> | ||
| <td class="text-left" data-testid="worker-last-access-time"> | ||
| <p> | ||
| <span class:reachability={!!pollerReachability} | ||
| >{pollerReachability}</span | ||
| > | ||
| </p> | ||
| </td> | ||
| {/if} | ||
| <td class="text-left" data-testid="worker-last-access-time"> | ||
| <p class="select-all"> | ||
| {formatDate(poller.lastAccessTime, $timeFormat, { | ||
| relative: $relativeTime, | ||
| })} | ||
| </p> | ||
| </td> | ||
| <td data-testid="workflow-poller"> | ||
| <PollerIcon | ||
| includesTaskQueueType={poller.taskQueueTypes.includes('WORKFLOW')} | ||
| /> | ||
| </td> | ||
| <td data-testid="activity-poller"> | ||
| <PollerIcon | ||
| includesTaskQueueType={poller.taskQueueTypes.includes('ACTIVITY')} | ||
| /> | ||
| </td> | ||
| </TableRow> | ||
| {:else} | ||
| <tr class="w-full"> | ||
| <td colspan={reachability?.buildIdReachability?.length ? 8 : 6}> | ||
| <EmptyState title={translate('workflows.workers-empty-state')} /> | ||
| </td> | ||
| </tr> | ||
| {/each} | ||
| </Table> | ||
|
|
||
| <style lang="postcss"> | ||
| .reachability { | ||
| @apply rounded-sm bg-slate-200 px-2 py-1; | ||
| } | ||
| </style> |
Oops, something went wrong.