Skip to content
This repository was archived by the owner on May 26, 2023. It is now read-only.

Commit f99ac86

Browse files
feedmeapplesfeedmeapples
authored
Release v0.26.0 (#55)
* Release v0.26.0
1 parent a95e9f3 commit f99ac86

21 files changed

+406
-369
lines changed

‎client/App.vue‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -145,8 +145,8 @@ export default {
145145
<div class="detail-view workflow-id" v-if="$route.params.workflowId">
146146
<span>{{ $route.params.workflowId }}</span>
147147
</div>
148-
<div class="detail-view task-list" v-if="$route.params.taskList">
149-
<span>{{ $route.params.taskList }}</span>
148+
<div class="detail-view task-queue" v-if="$route.params.taskQueue">
149+
<span>{{ $route.params.taskQueue }}</span>
150150
</div>
151151
</header>
152152
<router-view @onNotification="onNotification"></router-view>
@@ -233,7 +233,7 @@ header.top-bar
233233
margin-right spacing
234234
div.workflow-id span::before
235235
content 'WORKFLOW ID'
236-
div.task-list span::before
236+
div.task-queue span::before
237237
content 'TASK LIST'
238238
.version {
239239
color: #c6c6c6;

‎client/helpers/get-key-value-pairs.js‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ import moment from 'moment';
22
import getJsonStringObject from './get-json-string-object';
33
import { jsonKeys, preKeys } from '~constants';
44

5-
const getKeyValuePairs = event => {
5+
const getKeyValuePairs = (event) => {
66
const kvps = [];
77
const flatten = (prefix, obj, root) => {
88
Object.entries(obj).forEach(([k, value]) => {
@@ -57,13 +57,13 @@ const getKeyValuePairs = event => {
5757
},
5858
value,
5959
});
60-
} else if (key === 'taskList.name' || key === 'Tasklist') {
60+
} else if (key === 'taskQueue.name' || key === 'Taskqueue') {
6161
kvps.push({
6262
key,
6363
routeLink: {
64-
name: 'task-list',
64+
name: 'task-queue',
6565
params: {
66-
taskList: value,
66+
taskQueue: value,
6767
},
6868
},
6969
value,

‎client/main.js‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ import History from './routes/workflow/history';
2020
import Query from './routes/workflow/query';
2121
import Root from './routes';
2222
import StackTrace from './routes/workflow/stack-trace';
23-
import TaskList from './routes/namespace/task-list';
23+
import TaskQueue from './routes/namespace/task-queue';
2424
import WorkflowArchival from './routes/namespace/workflow-archival';
2525
import WorkflowArchivalAdvanced from './routes/namespace/workflow-archival/advanced';
2626
import WorkflowArchivalBasic from './routes/namespace/workflow-archival/basic';
@@ -154,9 +154,9 @@ const routeOpts = {
154154
],
155155
},
156156
{
157-
name: 'task-list',
158-
path: '/namespaces/:namespace/task-lists/:taskList',
159-
component: TaskList,
157+
name: 'task-queue',
158+
path: '/namespaces/:namespace/task-queues/:taskQueue',
159+
component: TaskQueue,
160160
},
161161

162162
// redirects
@@ -198,7 +198,7 @@ const routeOpts = {
198198
},
199199
],
200200
parseQuery: qs.parse.bind(qs),
201-
stringifyQuery: query => {
201+
stringifyQuery: (query) => {
202202
const q = qs.stringify(query);
203203

204204
return q ? `?${q}` : '';
@@ -267,11 +267,11 @@ if (typeof mocha === 'undefined') {
267267
});
268268

269269
if (module.hot) {
270-
module.hot.addStatusHandler(status => {
270+
module.hot.addStatusHandler((status) => {
271271
if (status === 'apply') {
272272
document
273273
.querySelectorAll('link[href][rel=stylesheet]')
274-
.forEach(link => {
274+
.forEach((link) => {
275275
const nextStyleHref = link.href.replace(
276276
/(\?\d+)?$/,
277277
`?${Date.now()}`

‎client/routes/namespace/task-list.vue‎ renamed to ‎client/routes/namespace/task-queue.vue‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
<template>
2-
<section :class="{ 'task-list': true, loading }">
2+
<section :class="{ 'task-queue': true, loading }">
33
<header><h3>Pollers</h3></header>
44
<table v-if="pollers">
55
<thead>
@@ -33,18 +33,18 @@ export default {
3333
},
3434
created() {
3535
this.$http(
36-
`/api/namespaces/${this.$route.params.namespace}/task-lists/${this.$route.params.taskList}/pollers`
36+
`/api/namespaces/${this.$route.params.namespace}/task-queues/${this.$route.params.taskQueue}/pollers`
3737
)
3838
.then(
39-
p => {
40-
this.pollers = Object.keys(p).map(identity => ({
39+
(p) => {
40+
this.pollers = Object.keys(p).map((identity) => ({
4141
identity,
4242
lastAccessTime: moment(p[identity].lastAccessTime),
43-
handlesDecisions: p[identity].taskListTypes.includes('decision'),
44-
handlesActivities: p[identity].taskListTypes.includes('activity'),
43+
handlesDecisions: p[identity].taskQueueTypes.includes('decision'),
44+
handlesActivities: p[identity].taskQueueTypes.includes('activity'),
4545
}));
4646
},
47-
e => {
47+
(e) => {
4848
this.error = (e.json && e.json.message) || e.status || e.message;
4949
}
5050
)
@@ -59,7 +59,7 @@ export default {
5959
<style lang="stylus">
6060
@require "../../styles/definitions.styl"
6161
62-
section.task-list
62+
section.task-queue
6363
> header
6464
padding inline-spacing-medium
6565
table

‎client/routes/workflow/helpers/summarize-events.js‎

Lines changed: 21 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -4,44 +4,44 @@ import workflowLink from './workflow-link';
44
import { shortName } from '~helpers';
55

66
export const summarizeEvents = {
7-
ActivityTaskCancelRequested: d => ({ Id: d.activityId }),
8-
ActivityTaskCompleted: d => ({ result: d.result }),
9-
ActivityTaskFailed: d => ({
7+
ActivityTaskCancelRequested: (d) => ({ Id: d.activityId }),
8+
ActivityTaskCompleted: (d) => ({ result: d.result }),
9+
ActivityTaskFailed: (d) => ({
1010
details: d.details,
1111
reason: d.reason,
1212
}),
13-
ActivityTaskScheduled: d => ({
13+
ActivityTaskScheduled: (d) => ({
1414
'Close Timeout': moment
1515
.duration(d.scheduleToCloseTimeoutSeconds, 'seconds')
1616
.format(),
1717
Id: d.activityId,
1818
input: d.input,
1919
Name: shortName(d.activityType.name),
2020
}),
21-
ActivityTaskStarted: d => ({
21+
ActivityTaskStarted: (d) => ({
2222
attempt: d.attempt,
2323
identity: d.identity,
2424
requestId: d.requestId,
2525
}),
26-
ActivityTaskTimedOut: d => ({ 'Timeout Type': d.timeoutType }),
27-
ChildWorkflowExecutionCompleted: d => ({
26+
ActivityTaskTimedOut: (d) => ({ 'Timeout Type': d.timeoutType }),
27+
ChildWorkflowExecutionCompleted: (d) => ({
2828
result: d.result,
2929
Workflow: workflowLink(d, true),
3030
}),
31-
ChildWorkflowExecutionStarted: d => ({
31+
ChildWorkflowExecutionStarted: (d) => ({
3232
Workflow: workflowLink(d),
3333
}),
34-
DecisionTaskCompleted: d => ({ identity: d.identity }),
35-
DecisionTaskScheduled: d => ({
36-
Tasklist: d.taskList.name,
34+
DecisionTaskCompleted: (d) => ({ identity: d.identity }),
35+
DecisionTaskScheduled: (d) => ({
36+
Taskqueue: d.taskQueue.name,
3737
Timeout: moment.duration(d.startToCloseTimeoutSeconds, 'seconds').format(),
3838
}),
39-
DecisionTaskStarted: d => ({ requestId: d.requestId }),
40-
DecisionTaskTimedOut: d => ({ 'Timeout Type': d.timeoutType }),
41-
ExternalWorkflowExecutionSignaled: d => ({
39+
DecisionTaskStarted: (d) => ({ requestId: d.requestId }),
40+
DecisionTaskTimedOut: (d) => ({ 'Timeout Type': d.timeoutType }),
41+
ExternalWorkflowExecutionSignaled: (d) => ({
4242
Workflow: workflowLink(d),
4343
}),
44-
MarkerRecorded: d => {
44+
MarkerRecorded: (d) => {
4545
const details = d.details || {};
4646

4747
if (d.markerName === 'LocalActivity') {
@@ -78,23 +78,23 @@ export const summarizeEvents = {
7878

7979
return d;
8080
},
81-
StartChildWorkflowExecutionInitiated: d => ({
81+
StartChildWorkflowExecutionInitiated: (d) => ({
8282
input: d.input,
83-
Tasklist: d.taskList.name,
83+
Taskqueue: d.taskQueue.name,
8484
Workflow: shortName(d.workflowType.name),
8585
}),
86-
SignalExternalWorkflowExecutionInitiated: d => ({
86+
SignalExternalWorkflowExecutionInitiated: (d) => ({
8787
input: d.input,
8888
signal: d.signalName,
8989
Workflow: workflowLink(d),
9090
}),
91-
TimerStarted: d => ({
91+
TimerStarted: (d) => ({
9292
'Fire Timeout': moment
9393
.duration(d.startToFireTimeoutSeconds, 'seconds')
9494
.format(),
9595
'Timer ID': d.timerId,
9696
}),
97-
WorkflowExecutionStarted: d => {
97+
WorkflowExecutionStarted: (d) => {
9898
const summary = {
9999
'Close Timeout': moment
100100
.duration(d.executionStartToCloseTimeoutSeconds, 'seconds')
@@ -115,7 +115,7 @@ export const summarizeEvents = {
115115

116116
return summary;
117117
},
118-
WorkflowExecutionFailed: d => {
118+
WorkflowExecutionFailed: (d) => {
119119
return { message: d.failure.message };
120120
},
121121
};

‎client/routes/workflow/summary.vue‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -91,18 +91,18 @@
9191
</router-link>
9292
</dd>
9393
</div>
94-
<div class="task-list">
95-
<dt>Task List</dt>
94+
<div class="task-queue">
95+
<dt>Task Queue</dt>
9696
<dd>
9797
<router-link
9898
:to="{
99-
name: 'task-list',
99+
name: 'task-queue',
100100
params: {
101-
taskList: workflow.executionConfig.taskList.name,
101+
taskQueue: workflow.executionConfig.taskQueue.name,
102102
},
103103
}"
104104
>
105-
{{ workflow.executionConfig.taskList.name }}
105+
{{ workflow.executionConfig.taskQueue.name }}
106106
</router-link>
107107
</dd>
108108
</div>
@@ -198,15 +198,15 @@ export default {
198198
reason: this.terminationReason,
199199
})
200200
.then(
201-
r => {
201+
(r) => {
202202
this.$emit('onNotification', {
203203
message: 'Workflow terminated.',
204204
type: NOTIFICATION_TYPE_SUCCESS,
205205
});
206206
// eslint-disable-next-line no-console
207207
console.dir(r);
208208
},
209-
error => {
209+
(error) => {
210210
this.$emit('onNotification', {
211211
message: getErrorMessage(error, TERMINATE_DEFAULT_ERROR_MESSAGE),
212212
type: NOTIFICATION_TYPE_ERROR,
@@ -246,7 +246,7 @@ section.workflow-summary
246246
margin-bottom 1em
247247
dt
248248
padding 0 4px
249-
.run-id, .task-list, .workflow-id, .workflow-name
249+
.run-id, .task-queue, .workflow-id, .workflow-name
250250
dd
251251
font-weight 300
252252
font-family monospace-font-family

‎client/test/fixtures.js‎

Lines changed: 14 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,8 @@ export default {
1515
open: [
1616
{
1717
execution: {
18-
workflowId: 'github.com/temporalio/temporal-web/email-daily-summaries-2',
18+
workflowId:
19+
'github.com/temporalio/temporal-web/email-daily-summaries-2',
1920
runId: 'ef2c889e-e709-4d50-99ee-3748dfa0a101',
2021
},
2122
type: {
@@ -66,7 +67,7 @@ export default {
6667
workflowType: {
6768
name: 'email-daily-summaries',
6869
},
69-
taskList: {
70+
taskQueue: {
7071
name: 'ci-task-queue',
7172
},
7273
input: [839134, { env: 'prod' }],
@@ -79,7 +80,7 @@ export default {
7980
eventType: 'DecisionTaskScheduled',
8081
eventId: 2,
8182
details: {
82-
taskList: {
83+
taskQueue: {
8384
name: 'ci-task-queue',
8485
},
8586
zero: 0,
@@ -124,7 +125,7 @@ export default {
124125
activityType: {
125126
name: 'send-emails',
126127
},
127-
taskList: {
128+
taskQueue: {
128129
name: 'ci-task-queue',
129130
},
130131
input: [12345, ['[email protected]', '[email protected]']],
@@ -159,7 +160,7 @@ export default {
159160
timestamp: emailRun1Start.add(11, 'second').toISOString(),
160161
eventType: 'DecisionTaskScheduled',
161162
eventId: 9,
162-
details: { taskList: { name: 'ci-task-queue' } },
163+
details: { taskQueue: { name: 'ci-task-queue' } },
163164
},
164165
{
165166
timestamp: emailRun1Start.add(11, 'second').toISOString(),
@@ -196,7 +197,7 @@ export default {
196197
{
197198
details: {
198199
executionStartToCloseTimeoutSeconds: 360,
199-
taskList: {
200+
taskQueue: {
200201
name: 'canary-task-queue',
201202
},
202203
taskStartToCloseTimeoutSeconds: 180,
@@ -249,7 +250,7 @@ export default {
249250
scheduleToCloseTimeoutSeconds: 2,
250251
scheduleToStartTimeoutSeconds: 1,
251252
startToCloseTimeoutSeconds: 1,
252-
taskList: {
253+
taskQueue: {
253254
name: 'ci-task-queue',
254255
},
255256
},
@@ -279,7 +280,7 @@ export default {
279280
{
280281
details: {
281282
startToCloseTimeoutSeconds: 180,
282-
taskList: {
283+
taskQueue: {
283284
name: 'compute3330-sjc1:43b62b8e-aa2a-4b58-9571-39062a073d24',
284285
},
285286
},
@@ -324,7 +325,7 @@ export default {
324325
workflowType: {
325326
name: 'email-daily-summaries',
326327
},
327-
taskList: {
328+
taskQueue: {
328329
name: 'ci-task-queue',
329330
},
330331
input: [839134, { env: 'prod' }],
@@ -337,7 +338,7 @@ export default {
337338
eventType: 'DecisionTaskScheduled',
338339
eventId: 2,
339340
details: {
340-
taskList: {
341+
taskQueue: {
341342
name: 'ci-task-queue',
342343
},
343344
zero: 0,
@@ -382,7 +383,7 @@ export default {
382383
activityType: {
383384
name: 'search-for-treasure',
384385
},
385-
taskList: {
386+
taskQueue: {
386387
name: 'ci-task-queue',
387388
},
388389
input: { location: 'volcanic island' },
@@ -427,7 +428,7 @@ export default {
427428
eventId: 10,
428429
details: {
429430
workflowType: { name: 'sail-the-ocean' },
430-
taskList: { name: 'another-queue' },
431+
taskQueue: { name: 'another-queue' },
431432
input: { direction: 'west' },
432433
},
433434
},
@@ -454,7 +455,7 @@ export default {
454455
activityType: {
455456
name: 'swab-the-deck',
456457
},
457-
taskList: {
458+
taskQueue: {
458459
name: 'ci-task-queue',
459460
},
460461
input: { moveTheGrogToo: true },

0 commit comments

Comments
 (0)