018d9fa8-75f8-405b-9b1e-38f93e6b0a11

Committed 12 Feb 2024 11:30PM UTC coverage: 62.748% (+0.05%) from 62.701%

Build # 018d9fa8-75f8-405b-9b1e-38f93e6b0a11

Build Type

Pull #5657

buildkite

Committed by

Shaddoll

Commit Message

Implement SignalWithStartWorkflowExecutionAsync API

Pull Request Pull Request #5657: Implement SignalWithStartWorkflowExecutionAsync API

Run Details

96 of 142 new or added lines in 5 files covered. (67.61%)

60 existing lines in 8 files now uncovered.

92596 of 147569 relevant lines covered (62.75%)

2318.9 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

65.5

/service/frontend/wrappers/metered/metered.go

// The MIT License (MIT)

// Copyright (c) 2017-2020 Uber Technologies Inc.

// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in all
// copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
// SOFTWARE.

package metered

import (
        "context"
        "errors"
        "fmt"

        "go.uber.org/yarpc/yarpcerrors"

        "github.com/uber/cadence/common/log"
        "github.com/uber/cadence/common/log/tag"
        "github.com/uber/cadence/common/metrics"
        "github.com/uber/cadence/common/types"
)

func (h *apiHandler) handleErr(err error, scope metrics.Scope, logger log.Logger) error {
        switch err := err.(type) {
        case *types.InternalServiceError:
                logger.Error("Internal service error", tag.Error(err))
                scope.IncCounter(metrics.CadenceFailures)
                return frontendInternalServiceError("cadence internal error, msg: %v", err.Message)
        case *types.BadRequestError:
                scope.IncCounter(metrics.CadenceErrBadRequestCounter)
                return err
        case *types.DomainNotActiveError:
                scope.IncCounter(metrics.CadenceErrBadRequestCounter)
                return err
        case *types.ServiceBusyError:
                scope.IncCounter(metrics.CadenceErrServiceBusyCounter)
                return err
        case *types.EntityNotExistsError:
                scope.IncCounter(metrics.CadenceErrEntityNotExistsCounter)
                return err
        case *types.WorkflowExecutionAlreadyCompletedError:
                scope.IncCounter(metrics.CadenceErrWorkflowExecutionAlreadyCompletedCounter)
                return err
        case *types.WorkflowExecutionAlreadyStartedError:
                scope.IncCounter(metrics.CadenceErrExecutionAlreadyStartedCounter)
                return err
        case *types.DomainAlreadyExistsError:
                scope.IncCounter(metrics.CadenceErrDomainAlreadyExistsCounter)
                return err
        case *types.CancellationAlreadyRequestedError:
                scope.IncCounter(metrics.CadenceErrCancellationAlreadyRequestedCounter)
                return err
        case *types.QueryFailedError:
                scope.IncCounter(metrics.CadenceErrQueryFailedCounter)
                return err
        case *types.LimitExceededError:
                scope.IncCounter(metrics.CadenceErrLimitExceededCounter)
                return err
        case *types.ClientVersionNotSupportedError:
                scope.IncCounter(metrics.CadenceErrClientVersionNotSupportedCounter)
                return err
        case *yarpcerrors.Status:
                if err.Code() == yarpcerrors.CodeDeadlineExceeded {
                        logger.Error("Frontend request timedout", tag.Error(err))
                        scope.IncCounter(metrics.CadenceErrContextTimeoutCounter)
                        return err
                }
        }
        if errors.Is(err, context.DeadlineExceeded) {
                logger.Error("Frontend request timedout", tag.Error(err))
                scope.IncCounter(metrics.CadenceErrContextTimeoutCounter)
                return err
        }
        logger.Error("Uncategorized error", tag.Error(err))
        scope.IncCounter(metrics.CadenceFailures)
        return frontendInternalServiceError("cadence internal uncategorized error, msg: %v", err.Error())
}

func (h *apiHandler) withSignalName(
        ctx context.Context,
        domainName string,
        signalName string,
) context.Context {
        if h.cfg.EmitSignalNameMetricsTag(domainName) {
                return metrics.TagContext(ctx, metrics.SignalNameTag(signalName))
        }
        return ctx
}

func frontendInternalServiceError(fmtStr string, args ...interface{}) error {
        // NOTE: For internal error, we can't return thrift error from cadence-frontend.
        // Because in uber internal metrics, thrift errors are counted as user errors.
        return fmt.Errorf(fmtStr, args...)
}

func toCountWorkflowExecutionsRequestTags(req *types.CountWorkflowExecutionsRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
        }
}

func toDescribeTaskListRequestTags(req *types.DescribeTaskListRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowTaskListName(req.GetTaskList().GetName()),
                tag.WorkflowTaskListType(int(req.GetTaskListType())),
                tag.WorkflowTaskListKind(int32(req.GetTaskList().GetKind())),
        }
}

func toDescribeWorkflowExecutionRequestTags(req *types.DescribeWorkflowExecutionRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowID(req.GetExecution().GetWorkflowID()),
                tag.WorkflowRunID(req.GetExecution().GetRunID()),
        }
}

func toGetTaskListsByDomainRequestTags(req *types.GetTaskListsByDomainRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
        }
}

func toGetWorkflowExecutionHistoryRequestTags(req *types.GetWorkflowExecutionHistoryRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowID(req.GetExecution().GetWorkflowID()),
                tag.WorkflowRunID(req.GetExecution().GetRunID()),
        }
}

func toListArchivedWorkflowExecutionsRequestTags(req *types.ListArchivedWorkflowExecutionsRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
        }
}

func toListClosedWorkflowExecutionsRequestTags(req *types.ListClosedWorkflowExecutionsRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
        }
}

func toListOpenWorkflowExecutionsRequestTags(req *types.ListOpenWorkflowExecutionsRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
        }
}

func toListTaskListPartitionsRequestTags(req *types.ListTaskListPartitionsRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowTaskListName(req.GetTaskList().GetName()),
                tag.WorkflowTaskListKind(int32(req.GetTaskList().GetKind())),
        }
}

func toListWorkflowExecutionsRequestTags(req *types.ListWorkflowExecutionsRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
        }
}

func toPollForActivityTaskRequestTags(req *types.PollForActivityTaskRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowTaskListName(req.GetTaskList().GetName()),
                tag.WorkflowTaskListKind(int32(req.GetTaskList().GetKind())),
        }
}

func toPollForDecisionTaskRequestTags(req *types.PollForDecisionTaskRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowTaskListName(req.GetTaskList().GetName()),
                tag.WorkflowTaskListKind(int32(req.GetTaskList().GetKind())),
        }
}

func toQueryWorkflowRequestTags(req *types.QueryWorkflowRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowID(req.GetExecution().GetWorkflowID()),
                tag.WorkflowRunID(req.GetExecution().GetRunID()),
        }
}

func toRecordActivityTaskHeartbeatByIDRequestTags(req *types.RecordActivityTaskHeartbeatByIDRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowID(req.GetWorkflowID()),
                tag.WorkflowRunID(req.GetRunID()),
        }
}

func toRefreshWorkflowTasksRequestTags(req *types.RefreshWorkflowTasksRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowID(req.GetExecution().GetWorkflowID()),
                tag.WorkflowRunID(req.GetExecution().GetRunID()),
        }
}

func toRequestCancelWorkflowExecutionRequestTags(req *types.RequestCancelWorkflowExecutionRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowID(req.GetWorkflowExecution().GetWorkflowID()),
                tag.WorkflowRunID(req.GetWorkflowExecution().GetRunID()),
        }
}

func toResetStickyTaskListRequestTags(req *types.ResetStickyTaskListRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowID(req.GetExecution().GetWorkflowID()),
                tag.WorkflowRunID(req.GetExecution().GetRunID()),
        }
}

func toResetWorkflowExecutionRequestTags(req *types.ResetWorkflowExecutionRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowID(req.GetWorkflowExecution().GetWorkflowID()),
                tag.WorkflowRunID(req.GetWorkflowExecution().GetRunID()),
        }
}

func toRespondActivityTaskCanceledByIDRequestTags(req *types.RespondActivityTaskCanceledByIDRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowID(req.GetWorkflowID()),
                tag.WorkflowRunID(req.GetRunID()),
        }
}

func toRespondActivityTaskCompletedByIDRequestTags(req *types.RespondActivityTaskCompletedByIDRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowID(req.GetWorkflowID()),
                tag.WorkflowRunID(req.GetRunID()),
        }
}

func toRespondActivityTaskFailedByIDRequestTags(req *types.RespondActivityTaskFailedByIDRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowID(req.GetWorkflowID()),
                tag.WorkflowRunID(req.GetRunID()),
        }
}

func toRestartWorkflowExecutionRequestTags(req *types.RestartWorkflowExecutionRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowID(req.GetWorkflowExecution().GetWorkflowID()),
                tag.WorkflowRunID(req.GetWorkflowExecution().GetRunID()),
        }
}

func toSignalWithStartWorkflowExecutionRequestTags(req *types.SignalWithStartWorkflowExecutionRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowID(req.GetWorkflowID()),
                tag.WorkflowType(req.WorkflowType.GetName()),
                tag.WorkflowSignalName(req.GetSignalName()),
        }
}

func toSignalWithStartWorkflowExecutionAsyncRequestTags(req *types.SignalWithStartWorkflowExecutionAsyncRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowID(req.GetWorkflowID()),
                tag.WorkflowType(req.WorkflowType.GetName()),
                tag.WorkflowSignalName(req.GetSignalName()),
        }
}

func toSignalWorkflowExecutionRequestTags(req *types.SignalWorkflowExecutionRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowID(req.GetWorkflowExecution().GetWorkflowID()),
                tag.WorkflowRunID(req.GetWorkflowExecution().GetRunID()),
                tag.WorkflowSignalName(req.GetSignalName()),
        }
}

func toStartWorkflowExecutionRequestTags(req *types.StartWorkflowExecutionRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowID(req.GetWorkflowID()),
                tag.WorkflowType(req.WorkflowType.GetName()),
                tag.WorkflowCronSchedule(req.GetCronSchedule()),
        }
}

func toStartWorkflowExecutionAsyncRequestTags(req *types.StartWorkflowExecutionAsyncRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowID(req.GetWorkflowID()),
                tag.WorkflowType(req.WorkflowType.GetName()),
                tag.WorkflowCronSchedule(req.GetCronSchedule()),
        }
}

func toTerminateWorkflowExecutionRequestTags(req *types.TerminateWorkflowExecutionRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
                tag.WorkflowID(req.GetWorkflowExecution().GetWorkflowID()),
                tag.WorkflowRunID(req.GetWorkflowExecution().GetRunID()),
        }
}

func toScanWorkflowExecutionsRequestTags(req *types.ListWorkflowExecutionsRequest) []tag.Tag {
        return []tag.Tag{
                tag.WorkflowDomainName(req.GetDomain()),
        }
}

1	// The MIT License (MIT)
2
3	// Copyright (c) 2017-2020 Uber Technologies Inc.
4
5	// Permission is hereby granted, free of charge, to any person obtaining a copy
6	// of this software and associated documentation files (the "Software"), to deal
7	// in the Software without restriction, including without limitation the rights
8	// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
9	// copies of the Software, and to permit persons to whom the Software is
10	// furnished to do so, subject to the following conditions:
11	//
12	// The above copyright notice and this permission notice shall be included in all
13	// copies or substantial portions of the Software.
14	//
15	// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
16	// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
17	// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
18	// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
19	// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
20	// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
21	// SOFTWARE.
22
23	package metered
24
25	import (
26	"context"
27	"errors"
28	"fmt"
29
30	"go.uber.org/yarpc/yarpcerrors"
31
32	"github.com/uber/cadence/common/log"
33	"github.com/uber/cadence/common/log/tag"
34	"github.com/uber/cadence/common/metrics"
35	"github.com/uber/cadence/common/types"
36	)
37
38	func (h *apiHandler) handleErr(err error, scope metrics.Scope, logger log.Logger) error {	641✔
39	switch err := err.(type) {	641✔
40	case *types.InternalServiceError:	2✔
41	logger.Error("Internal service error", tag.Error(err))	2✔
42	scope.IncCounter(metrics.CadenceFailures)	2✔
43	return frontendInternalServiceError("cadence internal error, msg: %v", err.Message)	2✔
44	case *types.BadRequestError:	×
45	scope.IncCounter(metrics.CadenceErrBadRequestCounter)	×
46	return err	×
47	case *types.DomainNotActiveError:	×
48	scope.IncCounter(metrics.CadenceErrBadRequestCounter)	×
49	return err	×
50	case *types.ServiceBusyError:	×
51	scope.IncCounter(metrics.CadenceErrServiceBusyCounter)	×
52	return err	×
53	case *types.EntityNotExistsError:	597✔
54	scope.IncCounter(metrics.CadenceErrEntityNotExistsCounter)	597✔
55	return err	597✔
56	case *types.WorkflowExecutionAlreadyCompletedError:	3✔
57	scope.IncCounter(metrics.CadenceErrWorkflowExecutionAlreadyCompletedCounter)	3✔
58	return err	3✔
59	case *types.WorkflowExecutionAlreadyStartedError:	24✔
60	scope.IncCounter(metrics.CadenceErrExecutionAlreadyStartedCounter)	24✔
61	return err	24✔
62	case *types.DomainAlreadyExistsError:	×
63	scope.IncCounter(metrics.CadenceErrDomainAlreadyExistsCounter)	×
64	return err	×
65	case *types.CancellationAlreadyRequestedError:	3✔
66	scope.IncCounter(metrics.CadenceErrCancellationAlreadyRequestedCounter)	3✔
67	return err	3✔
68	case *types.QueryFailedError:	9✔
69	scope.IncCounter(metrics.CadenceErrQueryFailedCounter)	9✔
70	return err	9✔
71	case *types.LimitExceededError:	×
72	scope.IncCounter(metrics.CadenceErrLimitExceededCounter)	×
73	return err	×
74	case *types.ClientVersionNotSupportedError:	×
75	scope.IncCounter(metrics.CadenceErrClientVersionNotSupportedCounter)	×
76	return err	×
77	case *yarpcerrors.Status:	3✔
78	if err.Code() == yarpcerrors.CodeDeadlineExceeded {	6✔
79	logger.Error("Frontend request timedout", tag.Error(err))	3✔
80	scope.IncCounter(metrics.CadenceErrContextTimeoutCounter)	3✔
81	return err	3✔
82	}	3✔
83	}
84	if errors.Is(err, context.DeadlineExceeded) {	×
85	logger.Error("Frontend request timedout", tag.Error(err))	×
86	scope.IncCounter(metrics.CadenceErrContextTimeoutCounter)	×
87	return err	×
88	}	×
89	logger.Error("Uncategorized error", tag.Error(err))	×
90	scope.IncCounter(metrics.CadenceFailures)	×
91	return frontendInternalServiceError("cadence internal uncategorized error, msg: %v", err.Error())	×
92	}
93
94	func (h *apiHandler) withSignalName(
95	ctx context.Context,
96	domainName string,
97	signalName string,
98	) context.Context {	724✔
99	if h.cfg.EmitSignalNameMetricsTag(domainName) {	725✔
100	return metrics.TagContext(ctx, metrics.SignalNameTag(signalName))	1✔
101	}	1✔
102	return ctx	723✔
103	}
104
105	func frontendInternalServiceError(fmtStr string, args ...interface{}) error {	2✔
106	// NOTE: For internal error, we can't return thrift error from cadence-frontend.	2✔
107	// Because in uber internal metrics, thrift errors are counted as user errors.	2✔
108	return fmt.Errorf(fmtStr, args...)	2✔
109	}	2✔
110
111	func toCountWorkflowExecutionsRequestTags(req *types.CountWorkflowExecutionsRequest) []tag.Tag {	14✔
112	return []tag.Tag{	14✔
113	tag.WorkflowDomainName(req.GetDomain()),	14✔
114	}	14✔
115	}	14✔
116
117	func toDescribeTaskListRequestTags(req *types.DescribeTaskListRequest) []tag.Tag {	18✔
118	return []tag.Tag{	18✔
119	tag.WorkflowDomainName(req.GetDomain()),	18✔
120	tag.WorkflowTaskListName(req.GetTaskList().GetName()),	18✔
121	tag.WorkflowTaskListType(int(req.GetTaskListType())),	18✔
122	tag.WorkflowTaskListKind(int32(req.GetTaskList().GetKind())),	18✔
123	}	18✔
124	}	18✔
125
126	func toDescribeWorkflowExecutionRequestTags(req *types.DescribeWorkflowExecutionRequest) []tag.Tag {	93✔
127	return []tag.Tag{	93✔
128	tag.WorkflowDomainName(req.GetDomain()),	93✔
129	tag.WorkflowID(req.GetExecution().GetWorkflowID()),	93✔
130	tag.WorkflowRunID(req.GetExecution().GetRunID()),	93✔
131	}	93✔
132	}	93✔
133
134	func toGetTaskListsByDomainRequestTags(req *types.GetTaskListsByDomainRequest) []tag.Tag {	×
135	return []tag.Tag{	×
136	tag.WorkflowDomainName(req.GetDomain()),	×
137	}	×
138	}	×
139
140	func toGetWorkflowExecutionHistoryRequestTags(req *types.GetWorkflowExecutionHistoryRequest) []tag.Tag {	457✔
141	return []tag.Tag{	457✔
142	tag.WorkflowDomainName(req.GetDomain()),	457✔
143	tag.WorkflowID(req.GetExecution().GetWorkflowID()),	457✔
144	tag.WorkflowRunID(req.GetExecution().GetRunID()),	457✔
145	}	457✔
146	}	457✔
147
148	func toListArchivedWorkflowExecutionsRequestTags(req *types.ListArchivedWorkflowExecutionsRequest) []tag.Tag {	9✔
149	return []tag.Tag{	9✔
150	tag.WorkflowDomainName(req.GetDomain()),	9✔
151	}	9✔
152	}	9✔
153
154	func toListClosedWorkflowExecutionsRequestTags(req *types.ListClosedWorkflowExecutionsRequest) []tag.Tag {	25✔
155	return []tag.Tag{	25✔
156	tag.WorkflowDomainName(req.GetDomain()),	25✔
157	}	25✔
158	}	25✔
159
160	func toListOpenWorkflowExecutionsRequestTags(req *types.ListOpenWorkflowExecutionsRequest) []tag.Tag {	103✔
161	return []tag.Tag{	103✔
162	tag.WorkflowDomainName(req.GetDomain()),	103✔
163	}	103✔
164	}	103✔
165
166	func toListTaskListPartitionsRequestTags(req *types.ListTaskListPartitionsRequest) []tag.Tag {	×
167	return []tag.Tag{	×
168	tag.WorkflowDomainName(req.GetDomain()),	×
169	tag.WorkflowTaskListName(req.GetTaskList().GetName()),	×
170	tag.WorkflowTaskListKind(int32(req.GetTaskList().GetKind())),	×
171	}	×
172	}	×
173
174	func toListWorkflowExecutionsRequestTags(req *types.ListWorkflowExecutionsRequest) []tag.Tag {	136✔
175	return []tag.Tag{	136✔
176	tag.WorkflowDomainName(req.GetDomain()),	136✔
177	}	136✔
178	}	136✔
179
180	func toPollForActivityTaskRequestTags(req *types.PollForActivityTaskRequest) []tag.Tag {	706✔
181	return []tag.Tag{	706✔
182	tag.WorkflowDomainName(req.GetDomain()),	706✔
183	tag.WorkflowTaskListName(req.GetTaskList().GetName()),	706✔
184	tag.WorkflowTaskListKind(int32(req.GetTaskList().GetKind())),	706✔
185	}	706✔
186	}	706✔
187
188	func toPollForDecisionTaskRequestTags(req *types.PollForDecisionTaskRequest) []tag.Tag {	1,484✔
189	return []tag.Tag{	1,484✔
190	tag.WorkflowDomainName(req.GetDomain()),	1,484✔
191	tag.WorkflowTaskListName(req.GetTaskList().GetName()),	1,484✔
192	tag.WorkflowTaskListKind(int32(req.GetTaskList().GetKind())),	1,484✔
193	}	1,484✔
194	}	1,484✔
195
196	func toQueryWorkflowRequestTags(req *types.QueryWorkflowRequest) []tag.Tag {	45✔
197	return []tag.Tag{	45✔
198	tag.WorkflowDomainName(req.GetDomain()),	45✔
199	tag.WorkflowID(req.GetExecution().GetWorkflowID()),	45✔
200	tag.WorkflowRunID(req.GetExecution().GetRunID()),	45✔
201	}	45✔
202	}	45✔
203
204	func toRecordActivityTaskHeartbeatByIDRequestTags(req *types.RecordActivityTaskHeartbeatByIDRequest) []tag.Tag {	×
205	return []tag.Tag{	×
206	tag.WorkflowDomainName(req.GetDomain()),	×
207	tag.WorkflowID(req.GetWorkflowID()),	×
208	tag.WorkflowRunID(req.GetRunID()),	×
209	}	×
210	}	×
211
212	func toRefreshWorkflowTasksRequestTags(req *types.RefreshWorkflowTasksRequest) []tag.Tag {	×
213	return []tag.Tag{	×
214	tag.WorkflowDomainName(req.GetDomain()),	×
215	tag.WorkflowID(req.GetExecution().GetWorkflowID()),	×
216	tag.WorkflowRunID(req.GetExecution().GetRunID()),	×
217	}	×
218	}	×
219
220	func toRequestCancelWorkflowExecutionRequestTags(req *types.RequestCancelWorkflowExecutionRequest) []tag.Tag {	6✔
221	return []tag.Tag{	6✔
222	tag.WorkflowDomainName(req.GetDomain()),	6✔
223	tag.WorkflowID(req.GetWorkflowExecution().GetWorkflowID()),	6✔
224	tag.WorkflowRunID(req.GetWorkflowExecution().GetRunID()),	6✔
225	}	6✔
226	}	6✔
227
228	func toResetStickyTaskListRequestTags(req *types.ResetStickyTaskListRequest) []tag.Tag {	3✔
229	return []tag.Tag{	3✔
230	tag.WorkflowDomainName(req.GetDomain()),	3✔
231	tag.WorkflowID(req.GetExecution().GetWorkflowID()),	3✔
232	tag.WorkflowRunID(req.GetExecution().GetRunID()),	3✔
233	}	3✔
234	}	3✔
235
236	func toResetWorkflowExecutionRequestTags(req *types.ResetWorkflowExecutionRequest) []tag.Tag {	15✔
237	return []tag.Tag{	15✔
238	tag.WorkflowDomainName(req.GetDomain()),	15✔
239	tag.WorkflowID(req.GetWorkflowExecution().GetWorkflowID()),	15✔
240	tag.WorkflowRunID(req.GetWorkflowExecution().GetRunID()),	15✔
241	}	15✔
242	}	15✔
243
244	func toRespondActivityTaskCanceledByIDRequestTags(req *types.RespondActivityTaskCanceledByIDRequest) []tag.Tag {	×
245	return []tag.Tag{	×
246	tag.WorkflowDomainName(req.GetDomain()),	×
247	tag.WorkflowID(req.GetWorkflowID()),	×
248	tag.WorkflowRunID(req.GetRunID()),	×
249	}	×
250	}	×
251
252	func toRespondActivityTaskCompletedByIDRequestTags(req *types.RespondActivityTaskCompletedByIDRequest) []tag.Tag {	75✔
253	return []tag.Tag{	75✔
254	tag.WorkflowDomainName(req.GetDomain()),	75✔
255	tag.WorkflowID(req.GetWorkflowID()),	75✔
256	tag.WorkflowRunID(req.GetRunID()),	75✔
257	}	75✔
258	}	75✔
259
260	func toRespondActivityTaskFailedByIDRequestTags(req *types.RespondActivityTaskFailedByIDRequest) []tag.Tag {	×
261	return []tag.Tag{	×
262	tag.WorkflowDomainName(req.GetDomain()),	×
263	tag.WorkflowID(req.GetWorkflowID()),	×
264	tag.WorkflowRunID(req.GetRunID()),	×
265	}	×
266	}	×
267
268	func toRestartWorkflowExecutionRequestTags(req *types.RestartWorkflowExecutionRequest) []tag.Tag {	×
269	return []tag.Tag{	×
270	tag.WorkflowDomainName(req.GetDomain()),	×
271	tag.WorkflowID(req.GetWorkflowExecution().GetWorkflowID()),	×
272	tag.WorkflowRunID(req.GetWorkflowExecution().GetRunID()),	×
273	}	×
274	}	×
275
276	func toSignalWithStartWorkflowExecutionRequestTags(req *types.SignalWithStartWorkflowExecutionRequest) []tag.Tag {	33✔
277	return []tag.Tag{	33✔
278	tag.WorkflowDomainName(req.GetDomain()),	33✔
279	tag.WorkflowID(req.GetWorkflowID()),	33✔
280	tag.WorkflowType(req.WorkflowType.GetName()),	33✔
281	tag.WorkflowSignalName(req.GetSignalName()),	33✔
282	}	33✔
283	}	33✔
284
NEW 285	func toSignalWithStartWorkflowExecutionAsyncRequestTags(req *types.SignalWithStartWorkflowExecutionAsyncRequest) []tag.Tag {	×
NEW 286	return []tag.Tag{	×
NEW 287	tag.WorkflowDomainName(req.GetDomain()),	×
NEW 288	tag.WorkflowID(req.GetWorkflowID()),	×
NEW 289	tag.WorkflowType(req.WorkflowType.GetName()),	×
NEW 290	tag.WorkflowSignalName(req.GetSignalName()),	×
NEW 291	}	×
NEW 292	}	×
293
294	func toSignalWorkflowExecutionRequestTags(req *types.SignalWorkflowExecutionRequest) []tag.Tag {	724✔
295	return []tag.Tag{	724✔
296	tag.WorkflowDomainName(req.GetDomain()),	724✔
297	tag.WorkflowID(req.GetWorkflowExecution().GetWorkflowID()),	724✔
298	tag.WorkflowRunID(req.GetWorkflowExecution().GetRunID()),	724✔
299	tag.WorkflowSignalName(req.GetSignalName()),	724✔
300	}	724✔
301	}	724✔
302
303	func toStartWorkflowExecutionRequestTags(req *types.StartWorkflowExecutionRequest) []tag.Tag {	444✔
304	return []tag.Tag{	444✔
305	tag.WorkflowDomainName(req.GetDomain()),	444✔
306	tag.WorkflowID(req.GetWorkflowID()),	444✔
307	tag.WorkflowType(req.WorkflowType.GetName()),	444✔
308	tag.WorkflowCronSchedule(req.GetCronSchedule()),	444✔
309	}	444✔
310	}	444✔
311
312	func toStartWorkflowExecutionAsyncRequestTags(req *types.StartWorkflowExecutionAsyncRequest) []tag.Tag {	×
313	return []tag.Tag{	×
314	tag.WorkflowDomainName(req.GetDomain()),	×
315	tag.WorkflowID(req.GetWorkflowID()),	×
316	tag.WorkflowType(req.WorkflowType.GetName()),	×
317	tag.WorkflowCronSchedule(req.GetCronSchedule()),	×
318	}	×
319	}	×
320
321	func toTerminateWorkflowExecutionRequestTags(req *types.TerminateWorkflowExecutionRequest) []tag.Tag {	48✔
322	return []tag.Tag{	48✔
323	tag.WorkflowDomainName(req.GetDomain()),	48✔
324	tag.WorkflowID(req.GetWorkflowExecution().GetWorkflowID()),	48✔
325	tag.WorkflowRunID(req.GetWorkflowExecution().GetRunID()),	48✔
326	}	48✔
327	}	48✔
328
329	func toScanWorkflowExecutionsRequestTags(req *types.ListWorkflowExecutionsRequest) []tag.Tag {	27✔
330	return []tag.Tag{	27✔
331	tag.WorkflowDomainName(req.GetDomain()),	27✔
332	}	27✔
333	}	27✔

uber / cadence / 018d9fa8-75f8-405b-9b1e-38f93e6b0a11

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous