diff --git a/common/testing/mocksdk/client_mock.go b/common/testing/mocksdk/client_mock.go index a0ba8ab3969..562985e15d2 100644 --- a/common/testing/mocksdk/client_mock.go +++ b/common/testing/mocksdk/client_mock.go @@ -484,6 +484,41 @@ func (mr *MockClientMockRecorder) TerminateWorkflow(arg0, arg1, arg2, arg3 inter return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "TerminateWorkflow", reflect.TypeOf((*MockClient)(nil).TerminateWorkflow), varargs...) } +// UpdateWorkflow mocks base method. +func (m *MockClient) UpdateWorkflow(arg0 context.Context, arg1, arg2, arg3 string, arg4 ...interface{}) (client.WorkflowUpdateHandle, error) { + m.ctrl.T.Helper() + varargs := []interface{}{arg0, arg1, arg2, arg3} + for _, a := range arg4 { + varargs = append(varargs, a) + } + ret := m.ctrl.Call(m, "UpdateWorkflow", varargs...) + ret0, _ := ret[0].(client.WorkflowUpdateHandle) + ret1, _ := ret[1].(error) + return ret0, ret1 +} + +// UpdateWorkflow indicates an expected call of UpdateWorkflow. +func (mr *MockClientMockRecorder) UpdateWorkflow(arg0, arg1, arg2, arg3 interface{}, arg4 ...interface{}) *gomock.Call { + mr.mock.ctrl.T.Helper() + varargs := append([]interface{}{arg0, arg1, arg2, arg3}, arg4...) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateWorkflow", reflect.TypeOf((*MockClient)(nil).UpdateWorkflow), varargs...) +} + +// UpdateWorkflowWithOptions mocks base method. +func (m *MockClient) UpdateWorkflowWithOptions(arg0 context.Context, arg1 *client.UpdateWorkflowWithOptionsRequest) (client.WorkflowUpdateHandle, error) { + m.ctrl.T.Helper() + ret := m.ctrl.Call(m, "UpdateWorkflowWithOptions", arg0, arg1) + ret0, _ := ret[0].(client.WorkflowUpdateHandle) + ret1, _ := ret[1].(error) + return ret0, ret1 +} + +// UpdateWorkflowWithOptions indicates an expected call of UpdateWorkflowWithOptions. +func (mr *MockClientMockRecorder) UpdateWorkflowWithOptions(arg0, arg1 interface{}) *gomock.Call { + mr.mock.ctrl.T.Helper() + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateWorkflowWithOptions", reflect.TypeOf((*MockClient)(nil).UpdateWorkflowWithOptions), arg0, arg1) +} + // WorkflowService mocks base method. func (m *MockClient) WorkflowService() workflowservice.WorkflowServiceClient { m.ctrl.T.Helper() diff --git a/go.mod b/go.mod index e5adc90e1ce..7a9ca5642c0 100644 --- a/go.mod +++ b/go.mod @@ -44,8 +44,8 @@ require ( go.opentelemetry.io/otel/metric v0.33.0 go.opentelemetry.io/otel/sdk v1.11.1 go.opentelemetry.io/otel/sdk/metric v0.31.0 - go.temporal.io/api v1.13.1-0.20221110200459-6a3cb21a3415 - go.temporal.io/sdk v1.19.0 + go.temporal.io/api v1.14.0 + go.temporal.io/sdk v1.20.0 go.temporal.io/version v0.3.0 go.uber.org/atomic v1.10.0 go.uber.org/fx v1.18.2 @@ -68,7 +68,7 @@ require cloud.google.com/go/compute/metadata v0.2.2 // indirect require ( cloud.google.com/go v0.107.0 // indirect cloud.google.com/go/compute v1.13.0 // indirect - cloud.google.com/go/iam v0.7.0 // indirect + cloud.google.com/go/iam v0.8.0 // indirect github.com/apache/thrift v0.17.0 // indirect github.com/benbjohnson/clock v1.3.0 // indirect github.com/beorn7/perks v1.0.1 // indirect @@ -122,13 +122,13 @@ require ( go.uber.org/dig v1.15.0 // indirect golang.org/x/crypto v0.3.0 // indirect golang.org/x/mod v0.7.0 // indirect - golang.org/x/net v0.2.0 // indirect - golang.org/x/sys v0.2.0 // indirect - golang.org/x/text v0.4.0 // indirect + golang.org/x/net v0.4.0 // indirect + golang.org/x/sys v0.3.0 // indirect + golang.org/x/text v0.5.0 // indirect golang.org/x/tools v0.3.0 // indirect golang.org/x/xerrors v0.0.0-20220907171357-04be3eba64a2 // indirect google.golang.org/appengine v1.6.7 // indirect - google.golang.org/genproto v0.0.0-20221201204527-e3fa12d562f3 // indirect + google.golang.org/genproto v0.0.0-20221207170731-23e4bf6bdc37 // indirect google.golang.org/protobuf v1.28.1 // indirect gopkg.in/inf.v0 v0.9.1 // indirect lukechampine.com/uint128 v1.2.0 // indirect @@ -141,3 +141,5 @@ require ( modernc.org/strutil v1.1.3 // indirect modernc.org/token v1.1.0 // indirect ) + +replace go.temporal.io/sdk v1.20.0 => ../sdk-go diff --git a/go.sum b/go.sum index 16a5a75cfc7..3fc614d75d5 100644 --- a/go.sum +++ b/go.sum @@ -26,6 +26,7 @@ cloud.google.com/go v0.93.3/go.mod h1:8utlLll2EF5XMAV15woO4lSbWQlk8rer9aLOfLh7+Y cloud.google.com/go v0.94.1/go.mod h1:qAlAugsXlC+JWO+Bke5vCtc9ONxjQT3drlTTnAplMW4= cloud.google.com/go v0.97.0/go.mod h1:GF7l59pYBVlXQIBLx3a761cZ41F9bBH3JUlihCt2Udc= cloud.google.com/go v0.99.0/go.mod h1:w0Xx2nLzqWJPuozYQX+hFfCSI8WioryfRDzkoI/Y2ZA= +cloud.google.com/go v0.100.1/go.mod h1:fs4QogzfH5n2pBXBP9vRiU+eCny7lD2vmFZy79Iuw1U= cloud.google.com/go v0.100.2/go.mod h1:4Xra9TjzAeYHrl5+oeLlzbM2k3mjVhZh4UqTZ//w99A= cloud.google.com/go v0.102.0/go.mod h1:oWcCzKlqJ5zgHQt9YsaeTY9KzIvjyy0ArmiBUgpQ+nc= cloud.google.com/go v0.102.1/go.mod h1:XZ77E9qnTEnrgEOvr4xzfdX5TRo7fB4T2F4O6+34hIU= @@ -39,6 +40,7 @@ cloud.google.com/go/accesscontextmanager v1.3.0/go.mod h1:TgCBehyr5gNMz7ZaH9xubp cloud.google.com/go/accesscontextmanager v1.4.0/go.mod h1:/Kjh7BBu/Gh83sv+K60vN9QE5NJcd80sU33vIe2IFPE= cloud.google.com/go/aiplatform v1.22.0/go.mod h1:ig5Nct50bZlzV6NvKaTwmplLLddFx0YReh9WfTO5jKw= cloud.google.com/go/aiplatform v1.24.0/go.mod h1:67UUvRBKG6GTayHKV8DBv2RtR1t93YRu5B1P3x99mYY= +cloud.google.com/go/aiplatform v1.27.0/go.mod h1:Bvxqtl40l0WImSb04d0hXFU7gDOiq9jQmorivIiWcKg= cloud.google.com/go/analytics v0.11.0/go.mod h1:DjEWCu41bVbYcKyvlws9Er60YE4a//bK6mnhWvQeFNI= cloud.google.com/go/analytics v0.12.0/go.mod h1:gkfj9h6XRf9+TS4bmuhPEShsh3hH8PAZzm/41OOhQd4= cloud.google.com/go/apigateway v1.3.0/go.mod h1:89Z8Bhpmxu6AmUxuVRg/ECRGReEdiP3vQtk4Z1J9rJk= @@ -81,6 +83,7 @@ cloud.google.com/go/bigquery v1.7.0/go.mod h1://okPTzCYNXSlb24MZs83e2Do+h+VXtc4g cloud.google.com/go/bigquery v1.8.0/go.mod h1:J5hqkt3O0uAFnINi6JXValWIb1v0goeZM77hZzJN/fQ= cloud.google.com/go/bigquery v1.42.0/go.mod h1:8dRTJxhtG+vwBKzE5OseQn/hiydoQN3EedCaOdYmxRA= cloud.google.com/go/bigquery v1.43.0/go.mod h1:ZMQcXHsl+xmU1z36G2jNGZmKp9zNY5BUua5wDgmNCfw= +cloud.google.com/go/bigquery v1.44.0/go.mod h1:0Y33VqXTEsbamHJvJHdFmtqHvMIY28aK1+dFsvaChGc= cloud.google.com/go/billing v1.4.0/go.mod h1:g9IdKBEFlItS8bTtlrZdVLWSSdSyFUZKXNS02zKMOZY= cloud.google.com/go/billing v1.5.0/go.mod h1:mztb1tBc3QekhjSgmpf/CV4LzWXLzCArwpLmP2Gm88s= cloud.google.com/go/billing v1.6.0/go.mod h1:WoXzguj+BeHXPbKfNWkqVtDdzORazmCjraY+vrxcyvI= @@ -144,6 +147,7 @@ cloud.google.com/go/dataqna v0.5.0/go.mod h1:90Hyk596ft3zUQ8NkFfvICSIfHFh1Bc7C4c cloud.google.com/go/dataqna v0.6.0/go.mod h1:1lqNpM7rqNLVgWBJyk5NF6Uen2PHym0jtVJonplVsDA= cloud.google.com/go/datastore v1.0.0/go.mod h1:LXYbyblFSglQ5pkeyhO+Qmw7ukd3C+pD7TKLgZqpHYE= cloud.google.com/go/datastore v1.1.0/go.mod h1:umbIZjpQpHh4hmRpGhH4tLFup+FVzqBi1b3c64qFpCk= +cloud.google.com/go/datastore v1.10.0/go.mod h1:PC5UzAmDEkAmkfaknstTYbNpgE49HAgW2J1gcgUfmdM= cloud.google.com/go/datastream v1.2.0/go.mod h1:i/uTP8/fZwgATHS/XFu0TcNUhuA0twZxxQ3EyCUQMwo= cloud.google.com/go/datastream v1.3.0/go.mod h1:cqlOX8xlyYF/uxhiKn6Hbv6WjwPPuI9W2M9SAXwaLLQ= cloud.google.com/go/datastream v1.4.0/go.mod h1:h9dpzScPhDTs5noEMQVWP8Wx8AFBRyS0s8KWPx/9r0g= @@ -165,12 +169,14 @@ cloud.google.com/go/domains v0.6.0/go.mod h1:T9Rz3GasrpYk6mEGHh4rymIhjlnIuB4ofT1 cloud.google.com/go/domains v0.7.0/go.mod h1:PtZeqS1xjnXuRPKE/88Iru/LdfoRyEHYA9nFQf4UKpg= cloud.google.com/go/edgecontainer v0.1.0/go.mod h1:WgkZ9tp10bFxqO8BLPqv2LlfmQF1X8lZqwW4r1BTajk= cloud.google.com/go/edgecontainer v0.2.0/go.mod h1:RTmLijy+lGpQ7BXuTDa4C4ssxyXT34NIuHIgKuP4s5w= +cloud.google.com/go/errorreporting v0.3.0/go.mod h1:xsP2yaAp+OAW4OIm60An2bbLpqIhKXdWR/tawvl7QzU= cloud.google.com/go/essentialcontacts v1.3.0/go.mod h1:r+OnHa5jfj90qIfZDO/VztSFqbQan7HV75p8sA+mdGI= cloud.google.com/go/essentialcontacts v1.4.0/go.mod h1:8tRldvHYsmnBCHdFpvU+GL75oWiBKl80BiqlFh9tp+8= cloud.google.com/go/eventarc v1.7.0/go.mod h1:6ctpF3zTnaQCxUjHUdcfgcA1A2T309+omHZth7gDfmc= cloud.google.com/go/eventarc v1.8.0/go.mod h1:imbzxkyAU4ubfsaKYdQg04WS1NvncblHEup4kvF+4gw= cloud.google.com/go/filestore v1.3.0/go.mod h1:+qbvHGvXU1HaKX2nD0WEPo92TP/8AQuCVEBXNY9z0+w= cloud.google.com/go/filestore v1.4.0/go.mod h1:PaG5oDfo9r224f8OYXURtAsY+Fbyq/bLYoINEK8XQAI= +cloud.google.com/go/firestore v1.9.0/go.mod h1:HMkjKHNTtRyZNiMzu7YAsLr9K3X2udY2AMwDaMEQiiE= cloud.google.com/go/functions v1.6.0/go.mod h1:3H1UA3qiIPRWD7PeZKLvHZ9SaQhR26XIJcC0A5GbvAk= cloud.google.com/go/functions v1.7.0/go.mod h1:+d+QBcWM+RsrgZfV9xo6KfA1GlzJfxcfZcRPEhDDfzg= cloud.google.com/go/functions v1.8.0/go.mod h1:RTZ4/HsQjIqIYP9a9YPbU+QFoQsAlYgrwOXJWHn1POY= @@ -190,17 +196,20 @@ cloud.google.com/go/gkemulticloud v0.4.0/go.mod h1:E9gxVBnseLWCk24ch+P9+B2CoDFJZ cloud.google.com/go/grafeas v0.2.0/go.mod h1:KhxgtF2hb0P191HlY5besjYm6MqTSTj3LSI+M+ByZHc= cloud.google.com/go/gsuiteaddons v1.3.0/go.mod h1:EUNK/J1lZEZO8yPtykKxLXI6JSVN2rg9bN8SXOa0bgM= cloud.google.com/go/gsuiteaddons v1.4.0/go.mod h1:rZK5I8hht7u7HxFQcFei0+AtfS9uSushomRlg+3ua1o= +cloud.google.com/go/iam v0.1.0/go.mod h1:vcUNEa0pEm0qRVpmWepWaFMIAI8/hjB9mO8rNCJtF6c= cloud.google.com/go/iam v0.3.0/go.mod h1:XzJPvDayI+9zsASAFO68Hk07u3z+f+JrT2xXNdp4bnY= cloud.google.com/go/iam v0.5.0/go.mod h1:wPU9Vt0P4UmCux7mqtRu6jcpPAb74cP1fh50J3QpkUc= cloud.google.com/go/iam v0.6.0/go.mod h1:+1AH33ueBne5MzYccyMHtEKqLE4/kJOibtffMHDMFMc= -cloud.google.com/go/iam v0.7.0 h1:k4MuwOsS7zGJJ+QfZ5vBK8SgHBAvYN/23BWsiihJ1vs= cloud.google.com/go/iam v0.7.0/go.mod h1:H5Br8wRaDGNc8XP3keLc4unfUUZeyH3Sfl9XpQEYOeg= +cloud.google.com/go/iam v0.8.0 h1:E2osAkZzxI/+8pZcxVLcDtAQx/u+hZXVryUaYQ5O0Kk= +cloud.google.com/go/iam v0.8.0/go.mod h1:lga0/y3iH6CX7sYqypWJ33hf7kkfXJag67naqGESjkE= cloud.google.com/go/iap v1.4.0/go.mod h1:RGFwRJdihTINIe4wZ2iCP0zF/qu18ZwyKxrhMhygBEc= cloud.google.com/go/iap v1.5.0/go.mod h1:UH/CGgKd4KyohZL5Pt0jSKE4m3FR51qg6FKQ/z/Ix9A= cloud.google.com/go/ids v1.1.0/go.mod h1:WIuwCaYVOzHIj2OhN9HAwvW+DBdmUAdcWlFxRl+KubM= cloud.google.com/go/ids v1.2.0/go.mod h1:5WXvp4n25S0rA/mQWAg1YEEBBq6/s+7ml1RDCW1IrcY= cloud.google.com/go/iot v1.3.0/go.mod h1:r7RGh2B61+B8oz0AGE+J72AhA0G7tdXItODWsaA2oLs= cloud.google.com/go/iot v1.4.0/go.mod h1:dIDxPOn0UvNDUMD8Ger7FIaTuvMkj+aGk94RPP0iV+g= +cloud.google.com/go/kms v1.4.0/go.mod h1:fajBHndQ+6ubNw6Ss2sSd+SWvjL26RNo/dr7uxsnnOA= cloud.google.com/go/kms v1.5.0/go.mod h1:QJS2YY0eJGBg3mnDfuaCyLauWwBJiHRboYxJ++1xJNg= cloud.google.com/go/kms v1.6.0/go.mod h1:Jjy850yySiasBUDi6KFUwUv2n1+o7QZFyuUJg6OgjA0= cloud.google.com/go/language v1.4.0/go.mod h1:F9dRpNFQmJbkaop6g0JhSBXCNlO90e1KWx5iDdxbWic= @@ -209,11 +218,13 @@ cloud.google.com/go/language v1.7.0/go.mod h1:DJ6dYN/W+SQOjF8e1hLQXMF21AkH2w9wiP cloud.google.com/go/language v1.8.0/go.mod h1:qYPVHf7SPoNNiCL2Dr0FfEFNil1qi3pQEyygwpgVKB8= cloud.google.com/go/lifesciences v0.5.0/go.mod h1:3oIKy8ycWGPUyZDR/8RNnTOYevhaMLqh5vLUXs9zvT8= cloud.google.com/go/lifesciences v0.6.0/go.mod h1:ddj6tSX/7BOnhxCSd3ZcETvtNr8NZ6t/iPhY2Tyfu08= +cloud.google.com/go/logging v1.6.1/go.mod h1:5ZO0mHHbvm8gEmeEUHrmDlTDSu5imF6MUP9OfilNXBw= cloud.google.com/go/longrunning v0.1.1/go.mod h1:UUFxuDWkv22EuY93jjmDMFT5GPQKeFVJBIF6QlTqdsE= cloud.google.com/go/longrunning v0.3.0 h1:NjljC+FYPV3uh5/OwWT6pVU+doBqMg2x/rZlE+CamDs= cloud.google.com/go/longrunning v0.3.0/go.mod h1:qth9Y41RRSUE69rDcOn6DdK3HfQfsUI0YSmW3iIlLJc= cloud.google.com/go/managedidentities v1.3.0/go.mod h1:UzlW3cBOiPrzucO5qWkNkh0w33KFtBJU281hacNvsdE= cloud.google.com/go/managedidentities v1.4.0/go.mod h1:NWSBYbEMgqmbZsLIyKvxrYbtqOsxY1ZrGM+9RgDqInM= +cloud.google.com/go/maps v0.1.0/go.mod h1:BQM97WGyfw9FWEmQMpZ5T6cpovXXSd1cGmFma94eubI= cloud.google.com/go/mediatranslation v0.5.0/go.mod h1:jGPUhGTybqsPQn91pNXw0xVHfuJ3leR1wj37oU3y1f4= cloud.google.com/go/mediatranslation v0.6.0/go.mod h1:hHdBCTYNigsBxshbznuIMFNe5QXEowAuNmmC7h8pu5w= cloud.google.com/go/memcache v1.4.0/go.mod h1:rTOfiGZtJX1AaFUrOgsMHX5kAzaTQ8azHiuDoTPzNsE= @@ -262,6 +273,9 @@ cloud.google.com/go/pubsub v1.0.1/go.mod h1:R0Gpsv3s54REJCy4fxDixWD93lHJMoZTyQ2k cloud.google.com/go/pubsub v1.1.0/go.mod h1:EwwdRX2sKPjnvnqCa270oGRyludottCI76h+R3AArQw= cloud.google.com/go/pubsub v1.2.0/go.mod h1:jhfEVHT8odbXTkndysNHCcx0awwzvfOlguIAii9o8iA= cloud.google.com/go/pubsub v1.3.1/go.mod h1:i+ucay31+CNRpDW4Lu78I4xXG+O1r/MAHgjpRVR+TSU= +cloud.google.com/go/pubsub v1.26.0/go.mod h1:QgBH3U/jdJy/ftjPhTkyXNj543Tin1pRYcdcPRnFIRI= +cloud.google.com/go/pubsub v1.27.1/go.mod h1:hQN39ymbV9geqBnfQq6Xf63yNhUAhv9CZhzp5O6qsW0= +cloud.google.com/go/pubsublite v1.5.0/go.mod h1:xapqNQ1CuLfGi23Yda/9l4bBCKz/wC3KIJ5gKcxveZg= cloud.google.com/go/recaptchaenterprise v1.3.1/go.mod h1:OdD+q+y4XGeAlxRaMn1Y7/GveP6zmq76byL6tjPE7d4= cloud.google.com/go/recaptchaenterprise/v2 v2.1.0/go.mod h1:w9yVqajwroDNTfGuhmOjPDN//rZGySaf6PtFVcSCa7o= cloud.google.com/go/recaptchaenterprise/v2 v2.2.0/go.mod h1:/Zu5jisWGeERrd5HnlS3EUGb/D335f9k51B/FVil0jk= @@ -316,6 +330,7 @@ cloud.google.com/go/serviceusage v1.3.0/go.mod h1:Hya1cozXM4SeSKTAgGXgj97GlqUvF5 cloud.google.com/go/serviceusage v1.4.0/go.mod h1:SB4yxXSaYVuUBYUml6qklyONXNLt83U0Rb+CXyhjEeU= cloud.google.com/go/shell v1.3.0/go.mod h1:VZ9HmRjZBsjLGXusm7K5Q5lzzByZmJHf1d0IWHEN5X4= cloud.google.com/go/shell v1.4.0/go.mod h1:HDxPzZf3GkDdhExzD/gs8Grqk+dmYcEjGShZgYa9URw= +cloud.google.com/go/spanner v1.41.0/go.mod h1:MLYDBJR/dY4Wt7ZaMIQ7rXOTLjYrmxLE/5ve9vFfWos= cloud.google.com/go/speech v1.6.0/go.mod h1:79tcr4FHCimOp56lwC01xnt/WPJZc4v3gzyT7FoBkCM= cloud.google.com/go/speech v1.7.0/go.mod h1:KptqL+BAQIhMsj1kOP2la5DSEEerPDuOP/2mmkhHhZQ= cloud.google.com/go/speech v1.8.0/go.mod h1:9bYIl1/tjsAnMgKGHKmBZzXKEkGgtU+MpdDPTE9f7y0= @@ -357,6 +372,7 @@ cloud.google.com/go/vision/v2 v2.4.0/go.mod h1:VtI579ll9RpVTrdKdkMzckdnwMyX2JILb cloud.google.com/go/vision/v2 v2.5.0/go.mod h1:MmaezXOOE+IWa+cS7OhRRLK2cNv1ZL98zhqFFZaaH2E= cloud.google.com/go/vmmigration v1.2.0/go.mod h1:IRf0o7myyWFSmVR1ItrBSFLFD/rJkfDCUTO4vLlJvsE= cloud.google.com/go/vmmigration v1.3.0/go.mod h1:oGJ6ZgGPQOFdjHuocGcLqX4lc98YQ7Ygq8YQwHh9A7g= +cloud.google.com/go/vmwareengine v0.1.0/go.mod h1:RsdNEf/8UDvKllXhMz5J40XxDrNJNN4sagiox+OI208= cloud.google.com/go/vpcaccess v1.4.0/go.mod h1:aQHVbTWDYUR1EbTApSVvMq1EnT57ppDmQzZ3imqIk4w= cloud.google.com/go/vpcaccess v1.5.0/go.mod h1:drmg4HLk9NkZpGfCmZ3Tz0Bwnm2+DKqViEpeEpOq0m8= cloud.google.com/go/webrisk v1.4.0/go.mod h1:Hn8X6Zr+ziE2aNd8SliSDWpEnSS1u4R9+xXZmFiHmGE= @@ -411,6 +427,7 @@ github.com/cactus/go-statsd-client/v4 v4.0.0/go.mod h1:m73kwJp6TN0Ja9P6ycdZhWM1M github.com/cenkalti/backoff/v4 v4.2.0 h1:HN5dHm3WBOgndBH6E8V0q2jIYIR3s9yglV8k/+MN3u4= github.com/cenkalti/backoff/v4 v4.2.0/go.mod h1:Y3VNntkOUPxTVeUxJ/G5vcM//AlwfmyYozVcomhLiZE= github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU= +github.com/census-instrumentation/opencensus-proto v0.3.0/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU= github.com/cespare/xxhash v1.1.0/go.mod h1:XrSqR1VqqWfGrhpAt58auRo0WTKS1nRRg3ghfAqPWnc= github.com/cespare/xxhash/v2 v2.1.1/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs= github.com/cespare/xxhash/v2 v2.1.2 h1:YRXhKfTDauu4ajMg1TPgFO5jnlC2HCbmLXMcTG5cbYE= @@ -823,11 +840,8 @@ go.opentelemetry.io/otel/trace v1.11.1/go.mod h1:f/Q9G7vzk5u91PhbmKbg1Qn0rzH1LJ4 go.opentelemetry.io/proto/otlp v0.7.0/go.mod h1:PqfVotwruBrMGOCsRd/89rSnXhoiJIqeYNgFYFoEGnI= go.opentelemetry.io/proto/otlp v0.19.0 h1:IVN6GR+mhC4s5yfcTbmzHYODqvWAp3ZedA2SJPI1Nnw= go.opentelemetry.io/proto/otlp v0.19.0/go.mod h1:H7XAot3MsfNsj7EXtrA2q5xSNQ10UqI405h3+duxN4U= -go.temporal.io/api v1.13.0/go.mod h1:egkGgTG/L4wDvVsv9jK2aLWzg18oCs5ycQViN0G/jiE= -go.temporal.io/api v1.13.1-0.20221110200459-6a3cb21a3415 h1:Ie7tICdY8uXwc9HWXrPxC8cOVw3eYt1L5OuHybKVPbU= -go.temporal.io/api v1.13.1-0.20221110200459-6a3cb21a3415/go.mod h1:VB+lPjotzLphGp+PUXkEbpahkjk1tlEtVFd/3MJeje4= -go.temporal.io/sdk v1.19.0 h1:qGSU8SRbwWoJy0XJpDFtEu/PUpU7Q9oE+5OhT11je3U= -go.temporal.io/sdk v1.19.0/go.mod h1:d+iTyxAZzRdhemExMVJ/9GyHv93eHO0vYeaAqcLchss= +go.temporal.io/api v1.14.0 h1:sGPQJ2hQaucXDDTnw8wBXIGeuoVQv9vfUlwXvAXscac= +go.temporal.io/api v1.14.0/go.mod h1:tfiIwNOKqwboFAyJ6t+Wz0dtZQlydZqlGetFEU1em6o= go.temporal.io/version v0.3.0 h1:dMrei9l9NyHt8nG6EB8vAwDLLTwx2SvRyucCSumAiig= go.temporal.io/version v0.3.0/go.mod h1:UA9S8/1LaKYae6TyD9NaPMJTZb911JcbqghI2CBSP78= go.uber.org/atomic v1.4.0/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE= @@ -956,8 +970,8 @@ golang.org/x/net v0.0.0-20220909164309-bea034e7d591/go.mod h1:YDH+HFinaLZZlnHAfS golang.org/x/net v0.0.0-20221012135044-0b7e1fb9d458/go.mod h1:YDH+HFinaLZZlnHAfSS6ZXJJ9M9t4Dl22yv3iI2vPwk= golang.org/x/net v0.0.0-20221014081412-f15817d10f9b/go.mod h1:YDH+HFinaLZZlnHAfSS6ZXJJ9M9t4Dl22yv3iI2vPwk= golang.org/x/net v0.1.0/go.mod h1:Cx3nUiGt4eDBEyega/BKRp+/AlGL8hYe7U9odMt2Cco= -golang.org/x/net v0.2.0 h1:sZfSu1wtKLGlWI4ZZayP0ck9Y73K1ynO6gqzTdBVdPU= -golang.org/x/net v0.2.0/go.mod h1:KqCZLdyyvdV855qA2rE3GC2aiw5xGR5TEjj8smXukLY= +golang.org/x/net v0.4.0 h1:Q5QPcMlvfxFTAPV0+07Xz/MpK9NTXu2VDUuy0FeMfaU= +golang.org/x/net v0.4.0/go.mod h1:MBQ8lrhLObU/6UmLb4fmbmk5OcyYmqtbGd/9yIeKjEE= golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U= golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw= golang.org/x/oauth2 v0.0.0-20190604053449-0f29369cfe45/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw= @@ -1077,12 +1091,12 @@ golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBc golang.org/x/sys v0.0.0-20220728004956-3c1f35247d10/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.1.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/sys v0.2.0 h1:ljd4t30dBnAvMZaQCevtY0xLLD0A+bRZXbgLMLU1F/A= -golang.org/x/sys v0.2.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.3.0 h1:w8ZOecv6NaNa/zC8944JTU3vz4u6Lagfk4RPQxv92NQ= +golang.org/x/sys v0.3.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8= golang.org/x/term v0.1.0/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8= -golang.org/x/term v0.2.0/go.mod h1:TVmDHMZPmdnySmBfhjOoOdhjzdE1h4u1VwSiw2l1Nuc= +golang.org/x/term v0.3.0/go.mod h1:q750SLmJuPmVoN1blW3UFBPREJfb1KmY3vwxfr+nFDA= golang.org/x/text v0.0.0-20170915032832-14c0d48ead0c/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= golang.org/x/text v0.3.1-0.20180807135948-17ff2d5776d2/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= @@ -1093,12 +1107,14 @@ golang.org/x/text v0.3.5/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ= golang.org/x/text v0.3.8/go.mod h1:E6s5w1FMmriuDzIBO73fBruAKo1PCIq6d2Q6DHfQ8WQ= -golang.org/x/text v0.4.0 h1:BrVqGRd7+k1DiOgtnFvAkoQEWQvBc25ouMJM6429SFg= golang.org/x/text v0.4.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8= +golang.org/x/text v0.5.0 h1:OLmvp0KP+FVG99Ct/qFiL/Fhk4zp4QQnZ7b2U+5piUM= +golang.org/x/text v0.5.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8= golang.org/x/time v0.0.0-20181108054448-85acf8d2951c/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= golang.org/x/time v0.0.0-20190308202827-9d24e82272b4/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= golang.org/x/time v0.0.0-20191024005414-555d28b269f0/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= -golang.org/x/time v0.0.0-20210723032227-1f47c861a9ac/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= +golang.org/x/time v0.0.0-20220922220347-f3bd1da661af/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= +golang.org/x/time v0.1.0/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= golang.org/x/time v0.2.0 h1:52I/1L54xyEQAYdtcSuxtiT84KGYTBGXwayxmIpNJhE= golang.org/x/time v0.2.0/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= golang.org/x/tools v0.0.0-20180525024113-a5b4c53f6e8b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= @@ -1339,9 +1355,12 @@ google.golang.org/genproto v0.0.0-20221014213838-99cd37c6964a/go.mod h1:1vXfmgAz google.golang.org/genproto v0.0.0-20221024153911-1573dae28c9c/go.mod h1:9qHF0xnpdSfF6knlcsnpzUu5y+rpwgbvsyGAZPBMg4s= google.golang.org/genproto v0.0.0-20221024183307-1bc688fe9f3e/go.mod h1:9qHF0xnpdSfF6knlcsnpzUu5y+rpwgbvsyGAZPBMg4s= google.golang.org/genproto v0.0.0-20221027153422-115e99e71e1c/go.mod h1:CGI5F/G+E5bKwmfYo09AXuVN4dD894kIKUFmVbP2/Fo= -google.golang.org/genproto v0.0.0-20221109142239-94d6d90a7d66/go.mod h1:rZS5c/ZVYMaOGBfO68GWtjOw/eLaZM1X6iVtgjZ+EWg= -google.golang.org/genproto v0.0.0-20221201204527-e3fa12d562f3 h1:BCcW+lhENGqZ2R2MsM9oty220E8vY9E4QC1Tq05hN1E= -google.golang.org/genproto v0.0.0-20221201204527-e3fa12d562f3/go.mod h1:rZS5c/ZVYMaOGBfO68GWtjOw/eLaZM1X6iVtgjZ+EWg= +google.golang.org/genproto v0.0.0-20221114212237-e4508ebdbee1/go.mod h1:rZS5c/ZVYMaOGBfO68GWtjOw/eLaZM1X6iVtgjZ+EWg= +google.golang.org/genproto v0.0.0-20221117204609-8f9c96812029/go.mod h1:rZS5c/ZVYMaOGBfO68GWtjOw/eLaZM1X6iVtgjZ+EWg= +google.golang.org/genproto v0.0.0-20221118155620-16455021b5e6/go.mod h1:rZS5c/ZVYMaOGBfO68GWtjOw/eLaZM1X6iVtgjZ+EWg= +google.golang.org/genproto v0.0.0-20221201164419-0e50fba7f41c/go.mod h1:rZS5c/ZVYMaOGBfO68GWtjOw/eLaZM1X6iVtgjZ+EWg= +google.golang.org/genproto v0.0.0-20221207170731-23e4bf6bdc37 h1:jmIfw8+gSvXcZSgaFAGyInDXeWzUhvYH57G/5GKMn70= +google.golang.org/genproto v0.0.0-20221207170731-23e4bf6bdc37/go.mod h1:RGgjbofJ8xD9Sq1VVhDM1Vok1vRONV+rg+CjzG4SZKM= google.golang.org/grpc v1.12.0/go.mod h1:yo6s7OP7yaDglbqo1J04qKzAhqBH6lvTonzMVmEdcZw= google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c= google.golang.org/grpc v1.20.1/go.mod h1:10oTOabMzJvdu6/UiuZezV6QK5dSlG84ov/aaiqXj38= diff --git a/service/worker/archiver/testdata/archival_workflow_history_v1.json b/service/worker/archiver/testdata/archival_workflow_history_v1.json deleted file mode 100755 index ba3c0aa34bf..00000000000 --- a/service/worker/archiver/testdata/archival_workflow_history_v1.json +++ /dev/null @@ -1,1661 +0,0 @@ -{ - "events": [ - { - "eventId": 1, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowExecutionStarted", - "version": -24, - "taskId": 6291586, - "workflowExecutionStartedEventAttributes": { - "workflowType": { - "name": "archivalWorkflow" - }, - "taskQueue": { - "name": "temporal-archival-tq" - }, - "input": null, - "workflowExecutionTimeout": "2592000s", - "workflowRunTimeout": "2502000s", - "workflowTaskTimeout": "60s", - "originalExecutionRunId": "2dbedb91-4d8f-4c74-a979-4b7b9c204077", - "identity": "59844@ycyang-C02XW41WJGH6@", - "firstExecutionRunId": "2dbedb91-4d8f-4c74-a979-4b7b9c204077", - "attempt": 1, - "cronSchedule": "", - "firstWorkflowTaskBackoff": "0s", - "header": {} - } - }, - { - "eventId": 2, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowExecutionSignaled", - "version": -24, - "taskId": 6291587, - "workflowExecutionSignaledEventAttributes": { - "signalName": "temporal-archival-signal", - "input": null, - "identity": "59844@ycyang-C02XW41WJGH6@" - } - }, - { - "eventId": 3, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskScheduled", - "version": -24, - "taskId": 6291590, - "workflowTaskScheduledEventAttributes": { - "taskQueue": { - "name": "temporal-archival-tq" - }, - "startToCloseTimeout": "60s", - "attempt": 1 - } - }, - { - "eventId": 4, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskStarted", - "version": -24, - "taskId": 6291595, - "workflowTaskStartedEventAttributes": { - "scheduledEventId": 3, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "requestId": "de9215e7-2bcc-4294-9fac-1dc75ed159fc" - } - }, - { - "eventId": 5, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskCompleted", - "version": -24, - "taskId": 6291598, - "workflowTaskCompletedEventAttributes": { - "scheduledEventId": 3, - "startedEventId": 4, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "binaryChecksum": "a3f549be2faf4819fc3dcb4732046568" - } - }, - { - "eventId": 6, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "MarkerRecorded", - "version": -24, - "taskId": 6291599, - "markerRecordedEventAttributes": { - "markerName": "SideEffect", - "details": { - "side-effect-id": {"payloads": [{"metadata":{"encoding":"anNvbi9wbGFpbg=="},"data":"MQ=="}]}, - "data": {"payloads": [{"metadata":{"encoding":"anNvbi9wbGFpbg=="},"data":"MQ=="}]} - }, - "workflowTaskCompletedEventId": 5 - } - }, - { - "eventId": 7, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "TimerStarted", - "version": -24, - "taskId": 6291600, - "timerStartedEventAttributes": { - "timerId": "7", - "startToFireTimeout": "1296000s", - "workflowTaskCompletedEventId": 5 - } - }, - { - "eventId": 8, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskScheduled", - "version": -24, - "taskId": 6291601, - "activityTaskScheduledEventAttributes": { - "activityId": "8", - "activityType": { - "name": "uploadHistoryActivity" - }, - "taskQueue": { - "name": "temporal-archival-tq" - }, - "input": null, - "scheduleToCloseTimeout": "300s", - "scheduleToStartTimeout": "300s", - "startToCloseTimeout": "60s", - "heartbeatTimeout": "0s", - "workflowTaskCompletedEventId": 5, - "retryPolicy": { - "initialInterval": "1s", - "backoffCoefficient": 2, - "maximumInterval": "0s", - "maximumAttempts": 1, - "nonRetryableErrorTypes": [ - "temporalInternal:Panic", - "upload non-retryable error" - ] - }, - "header": {} - } - }, - { - "eventId": 9, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskStarted", - "version": -24, - "taskId": 6291607, - "activityTaskStartedEventAttributes": { - "scheduledEventId": 8, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "requestId": "7dccfd5f-fb84-450f-b452-3a5dd5f382e9", - "attempt": 1 - } - }, - { - "eventId": 10, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskCompleted", - "version": -24, - "taskId": 6291608, - "activityTaskCompletedEventAttributes": { - "scheduledEventId": 8, - "startedEventId": 9, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq" - } - }, - { - "eventId": 11, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskScheduled", - "version": -24, - "taskId": 6291611, - "workflowTaskScheduledEventAttributes": { - "taskQueue": { - "name": "ycyang-C02XW41WJGH6:7ce34128-dace-4a8a-a3ca-6eaa9c97dd13" - }, - "startToCloseTimeout": "60s", - "attempt": 1 - } - }, - { - "eventId": 12, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskStarted", - "version": -24, - "taskId": 6291615, - "workflowTaskStartedEventAttributes": { - "scheduledEventId": 11, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-sys-tq-scanner-taskqueue-0", - "requestId": "774fa75d-7cef-47c8-96be-4a6db8a4cb99" - } - }, - { - "eventId": 13, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskCompleted", - "version": -24, - "taskId": 6291618, - "workflowTaskCompletedEventAttributes": { - "scheduledEventId": 11, - "startedEventId": 12, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "binaryChecksum": "a3f549be2faf4819fc3dcb4732046568" - } - }, - { - "eventId": 14, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "MarkerRecorded", - "version": -24, - "taskId": 6291619, - "markerRecordedEventAttributes": { - "markerName": "LocalActivity", - "details": null, - "workflowTaskCompletedEventId": 13 - } - }, - { - "eventId": 15, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowExecutionSignaled", - "version": -24, - "taskId": 6291621, - "workflowExecutionSignaledEventAttributes": { - "signalName": "temporal-archival-signal", - "input": null, - "identity": "59844@ycyang-C02XW41WJGH6@" - } - }, - { - "eventId": 16, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskScheduled", - "version": -24, - "taskId": 6291623, - "workflowTaskScheduledEventAttributes": { - "taskQueue": { - "name": "ycyang-C02XW41WJGH6:7ce34128-dace-4a8a-a3ca-6eaa9c97dd13" - }, - "startToCloseTimeout": "60s", - "attempt": 1 - } - }, - { - "eventId": 17, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskStarted", - "version": -24, - "taskId": 6291627, - "workflowTaskStartedEventAttributes": { - "scheduledEventId": 16, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "requestId": "081890a8-8942-4434-ac52-9e668a406ee2" - } - }, - { - "eventId": 18, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskCompleted", - "version": -24, - "taskId": 6291630, - "workflowTaskCompletedEventAttributes": { - "scheduledEventId": 16, - "startedEventId": 17, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "binaryChecksum": "a3f549be2faf4819fc3dcb4732046568" - } - }, - { - "eventId": 19, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskScheduled", - "version": -24, - "taskId": 6291631, - "activityTaskScheduledEventAttributes": { - "activityId": "19", - "activityType": { - "name": "uploadHistoryActivity" - }, - "taskQueue": { - "name": "temporal-archival-tq" - }, - "input": null, - "scheduleToCloseTimeout": "300s", - "scheduleToStartTimeout": "300s", - "startToCloseTimeout": "60s", - "heartbeatTimeout": "0s", - "workflowTaskCompletedEventId": 18, - "retryPolicy": { - "initialInterval": "1s", - "backoffCoefficient": 2, - "maximumInterval": "0s", - "maximumAttempts": 1, - "nonRetryableErrorTypes": [ - "temporalInternal:Panic", - "upload non-retryable error" - ] - }, - "header": {} - } - }, - { - "eventId": 20, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskStarted", - "version": -24, - "taskId": 6291636, - "activityTaskStartedEventAttributes": { - "scheduledEventId": 19, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "requestId": "d8b8a27d-e66d-4ae5-89ac-058cd336b660", - "attempt": 1 - } - }, - { - "eventId": 21, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskCompleted", - "version": -24, - "taskId": 6291637, - "activityTaskCompletedEventAttributes": { - "scheduledEventId": 19, - "startedEventId": 20, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq" - } - }, - { - "eventId": 22, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskScheduled", - "version": -24, - "taskId": 6291640, - "workflowTaskScheduledEventAttributes": { - "taskQueue": { - "name": "ycyang-C02XW41WJGH6:7ce34128-dace-4a8a-a3ca-6eaa9c97dd13" - }, - "startToCloseTimeout": "60s", - "attempt": 1 - } - }, - { - "eventId": 23, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskStarted", - "version": -24, - "taskId": 6291644, - "workflowTaskStartedEventAttributes": { - "scheduledEventId": 22, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-sys-processor-parent-close-policy", - "requestId": "b66d91d8-f367-4ddd-aad3-1071f937bc48" - } - }, - { - "eventId": 24, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskCompleted", - "version": -24, - "taskId": 6291647, - "workflowTaskCompletedEventAttributes": { - "scheduledEventId": 22, - "startedEventId": 23, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "binaryChecksum": "a3f549be2faf4819fc3dcb4732046568" - } - }, - { - "eventId": 25, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "MarkerRecorded", - "version": -24, - "taskId": 6291648, - "markerRecordedEventAttributes": { - "markerName": "LocalActivity", - "details": null, - "workflowTaskCompletedEventId": 24 - } - }, - { - "eventId": 26, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowExecutionSignaled", - "version": -24, - "taskId": 6291650, - "workflowExecutionSignaledEventAttributes": { - "signalName": "temporal-archival-signal", - "input": null, - "identity": "59844@ycyang-C02XW41WJGH6@" - } - }, - { - "eventId": 27, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskScheduled", - "version": -24, - "taskId": 6291652, - "workflowTaskScheduledEventAttributes": { - "taskQueue": { - "name": "ycyang-C02XW41WJGH6:7ce34128-dace-4a8a-a3ca-6eaa9c97dd13" - }, - "startToCloseTimeout": "60s", - "attempt": 1 - } - }, - { - "eventId": 28, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowExecutionSignaled", - "version": -24, - "taskId": 6291656, - "workflowExecutionSignaledEventAttributes": { - "signalName": "temporal-archival-signal", - "input": null, - "identity": "59844@ycyang-C02XW41WJGH6@" - } - }, - { - "eventId": 29, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowExecutionSignaled", - "version": -24, - "taskId": 6291658, - "workflowExecutionSignaledEventAttributes": { - "signalName": "temporal-archival-signal", - "input": null, - "identity": "59844@ycyang-C02XW41WJGH6@" - } - }, - { - "eventId": 30, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskStarted", - "version": -24, - "taskId": 6291660, - "workflowTaskStartedEventAttributes": { - "scheduledEventId": 27, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-sys-tq-scanner-taskqueue-0", - "requestId": "a4207044-03be-4913-857c-1caadff199f6" - } - }, - { - "eventId": 31, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskCompleted", - "version": -24, - "taskId": 6291663, - "workflowTaskCompletedEventAttributes": { - "scheduledEventId": 27, - "startedEventId": 30, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "binaryChecksum": "a3f549be2faf4819fc3dcb4732046568" - } - }, - { - "eventId": 32, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskScheduled", - "version": -24, - "taskId": 6291664, - "activityTaskScheduledEventAttributes": { - "activityId": "32", - "activityType": { - "name": "uploadHistoryActivity" - }, - "taskQueue": { - "name": "temporal-archival-tq" - }, - "input": null, - "scheduleToCloseTimeout": "300s", - "scheduleToStartTimeout": "300s", - "startToCloseTimeout": "60s", - "heartbeatTimeout": "0s", - "workflowTaskCompletedEventId": 31, - "retryPolicy": { - "initialInterval": "1s", - "backoffCoefficient": 2, - "maximumInterval": "0s", - "maximumAttempts": 1, - "nonRetryableErrorTypes": [ - "temporalInternal:Panic", - "upload non-retryable error" - ] - }, - "header": {} - } - }, - { - "eventId": 33, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskScheduled", - "version": -24, - "taskId": 6291665, - "activityTaskScheduledEventAttributes": { - "activityId": "33", - "activityType": { - "name": "uploadHistoryActivity" - }, - "taskQueue": { - "name": "temporal-archival-tq" - }, - "input": null, - "scheduleToCloseTimeout": "300s", - "scheduleToStartTimeout": "300s", - "startToCloseTimeout": "60s", - "heartbeatTimeout": "0s", - "workflowTaskCompletedEventId": 31, - "retryPolicy": { - "initialInterval": "1s", - "backoffCoefficient": 2, - "maximumInterval": "0s", - "maximumAttempts": 1, - "nonRetryableErrorTypes": [ - "temporalInternal:Panic", - "upload non-retryable error" - ] - }, - "header": {} - } - }, - { - "eventId": 34, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskScheduled", - "version": -24, - "taskId": 6291666, - "activityTaskScheduledEventAttributes": { - "activityId": "34", - "activityType": { - "name": "uploadHistoryActivity" - }, - "taskQueue": { - "name": "temporal-archival-tq" - }, - "input": null, - "scheduleToCloseTimeout": "300s", - "scheduleToStartTimeout": "300s", - "startToCloseTimeout": "60s", - "heartbeatTimeout": "0s", - "workflowTaskCompletedEventId": 31, - "retryPolicy": { - "initialInterval": "1s", - "backoffCoefficient": 2, - "maximumInterval": "0s", - "maximumAttempts": 1, - "nonRetryableErrorTypes": [ - "temporalInternal:Panic", - "upload non-retryable error" - ] - }, - "header": {} - } - }, - { - "eventId": 35, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskStarted", - "version": -24, - "taskId": 6291679, - "activityTaskStartedEventAttributes": { - "scheduledEventId": 32, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "requestId": "57e8b0cb-14b3-46c5-9549-5910a4c17cc4", - "attempt": 1 - } - }, - { - "eventId": 36, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskCompleted", - "version": -24, - "taskId": 6291680, - "activityTaskCompletedEventAttributes": { - "scheduledEventId": 32, - "startedEventId": 35, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq" - } - }, - { - "eventId": 37, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskScheduled", - "version": -24, - "taskId": 6291683, - "workflowTaskScheduledEventAttributes": { - "taskQueue": { - "name": "ycyang-C02XW41WJGH6:7ce34128-dace-4a8a-a3ca-6eaa9c97dd13" - }, - "startToCloseTimeout": "60s", - "attempt": 1 - } - }, - { - "eventId": 38, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskStarted", - "version": -24, - "taskId": 6291690, - "activityTaskStartedEventAttributes": { - "scheduledEventId": 33, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "requestId": "de068cc4-efd0-4ddf-afd8-c4e2272c134c", - "attempt": 1 - } - }, - { - "eventId": 39, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskCompleted", - "version": -24, - "taskId": 6291691, - "activityTaskCompletedEventAttributes": { - "scheduledEventId": 33, - "startedEventId": 38, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq" - } - }, - { - "eventId": 40, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskStarted", - "version": -24, - "taskId": 6291698, - "activityTaskStartedEventAttributes": { - "scheduledEventId": 34, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "requestId": "6bfef50a-28cb-4f05-b8d5-915d58347891", - "attempt": 1 - } - }, - { - "eventId": 41, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskCompleted", - "version": -24, - "taskId": 6291699, - "activityTaskCompletedEventAttributes": { - "scheduledEventId": 34, - "startedEventId": 40, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq" - } - }, - { - "eventId": 42, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskStarted", - "version": -24, - "taskId": 6291703, - "workflowTaskStartedEventAttributes": { - "scheduledEventId": 37, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "requestId": "9008323e-b89d-4c43-967f-e23846522466" - } - }, - { - "eventId": 43, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskCompleted", - "version": -24, - "taskId": 6291713, - "workflowTaskCompletedEventAttributes": { - "scheduledEventId": 37, - "startedEventId": 42, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "binaryChecksum": "a3f549be2faf4819fc3dcb4732046568" - } - }, - { - "eventId": 44, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "MarkerRecorded", - "version": -24, - "taskId": 6291714, - "markerRecordedEventAttributes": { - "markerName": "LocalActivity", - "details": null, - "workflowTaskCompletedEventId": 43 - } - }, - { - "eventId": 45, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "MarkerRecorded", - "version": -24, - "taskId": 6291715, - "markerRecordedEventAttributes": { - "markerName": "LocalActivity", - "details": null, - "workflowTaskCompletedEventId": 43 - } - }, - { - "eventId": 46, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "MarkerRecorded", - "version": -24, - "taskId": 6291716, - "markerRecordedEventAttributes": { - "markerName": "LocalActivity", - "details": null, - "workflowTaskCompletedEventId": 43 - } - }, - { - "eventId": 47, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowExecutionSignaled", - "version": -24, - "taskId": 6291728, - "workflowExecutionSignaledEventAttributes": { - "signalName": "temporal-archival-signal", - "input": null, - "identity": "59844@ycyang-C02XW41WJGH6@" - } - }, - { - "eventId": 48, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskScheduled", - "version": -24, - "taskId": 6291730, - "workflowTaskScheduledEventAttributes": { - "taskQueue": { - "name": "ycyang-C02XW41WJGH6:7ce34128-dace-4a8a-a3ca-6eaa9c97dd13" - }, - "startToCloseTimeout": "60s", - "attempt": 1 - } - }, - { - "eventId": 49, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskStarted", - "version": -24, - "taskId": 6291734, - "workflowTaskStartedEventAttributes": { - "scheduledEventId": 48, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-sys-processor-parent-close-policy", - "requestId": "82a5d9c2-1deb-494c-98ae-bb0c3681abd3" - } - }, - { - "eventId": 50, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskCompleted", - "version": -24, - "taskId": 6291737, - "workflowTaskCompletedEventAttributes": { - "scheduledEventId": 48, - "startedEventId": 49, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "binaryChecksum": "a3f549be2faf4819fc3dcb4732046568" - } - }, - { - "eventId": 51, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskScheduled", - "version": -24, - "taskId": 6291738, - "activityTaskScheduledEventAttributes": { - "activityId": "51", - "activityType": { - "name": "uploadHistoryActivity" - }, - "taskQueue": { - "name": "temporal-archival-tq" - }, - "input": null, - "scheduleToCloseTimeout": "300s", - "scheduleToStartTimeout": "300s", - "startToCloseTimeout": "60s", - "heartbeatTimeout": "0s", - "workflowTaskCompletedEventId": 50, - "retryPolicy": { - "initialInterval": "1s", - "backoffCoefficient": 2, - "maximumInterval": "0s", - "maximumAttempts": 1, - "nonRetryableErrorTypes": [ - "temporalInternal:Panic", - "upload non-retryable error" - ] - }, - "header": {} - } - }, - { - "eventId": 52, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskStarted", - "version": -24, - "taskId": 6291743, - "activityTaskStartedEventAttributes": { - "scheduledEventId": 51, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "requestId": "640f192d-c9b3-4ff7-8e71-3234d7bb09c5", - "attempt": 1 - } - }, - { - "eventId": 53, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskCompleted", - "version": -24, - "taskId": 6291744, - "activityTaskCompletedEventAttributes": { - "scheduledEventId": 51, - "startedEventId": 52, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq" - } - }, - { - "eventId": 54, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskScheduled", - "version": -24, - "taskId": 6291747, - "workflowTaskScheduledEventAttributes": { - "taskQueue": { - "name": "ycyang-C02XW41WJGH6:7ce34128-dace-4a8a-a3ca-6eaa9c97dd13" - }, - "startToCloseTimeout": "60s", - "attempt": 1 - } - }, - { - "eventId": 55, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskStarted", - "version": -24, - "taskId": 6291751, - "workflowTaskStartedEventAttributes": { - "scheduledEventId": 54, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-sys-tl-scanner-taskqueue-0", - "requestId": "0f0ce318-bc46-4439-81c9-c6288e063df5" - } - }, - { - "eventId": 56, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskCompleted", - "version": -24, - "taskId": 6291754, - "workflowTaskCompletedEventAttributes": { - "scheduledEventId": 54, - "startedEventId": 55, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "binaryChecksum": "a3f549be2faf4819fc3dcb4732046568" - } - }, - { - "eventId": 57, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "MarkerRecorded", - "version": -24, - "taskId": 6291755, - "markerRecordedEventAttributes": { - "markerName": "LocalActivity", - "details": null, - "workflowTaskCompletedEventId": 56 - } - }, - { - "eventId": 58, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowExecutionSignaled", - "version": -24, - "taskId": 6291757, - "workflowExecutionSignaledEventAttributes": { - "signalName": "temporal-archival-signal", - "input": null, - "identity": "59844@ycyang-C02XW41WJGH6@" - } - }, - { - "eventId": 59, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskScheduled", - "version": -24, - "taskId": 6291759, - "workflowTaskScheduledEventAttributes": { - "taskQueue": { - "name": "ycyang-C02XW41WJGH6:7ce34128-dace-4a8a-a3ca-6eaa9c97dd13" - }, - "startToCloseTimeout": "60s", - "attempt": 1 - } - }, - { - "eventId": 60, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskStarted", - "version": -24, - "taskId": 6291763, - "workflowTaskStartedEventAttributes": { - "scheduledEventId": 59, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "requestId": "8ee8cc2f-88ce-476d-b40f-e82544a9a3f9" - } - }, - { - "eventId": 61, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskCompleted", - "version": -24, - "taskId": 6291766, - "workflowTaskCompletedEventAttributes": { - "scheduledEventId": 59, - "startedEventId": 60, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "binaryChecksum": "a3f549be2faf4819fc3dcb4732046568" - } - }, - { - "eventId": 62, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskScheduled", - "version": -24, - "taskId": 6291767, - "activityTaskScheduledEventAttributes": { - "activityId": "62", - "activityType": { - "name": "uploadHistoryActivity" - }, - "taskQueue": { - "name": "temporal-archival-tq" - }, - "input": null, - "scheduleToCloseTimeout": "300s", - "scheduleToStartTimeout": "300s", - "startToCloseTimeout": "60s", - "heartbeatTimeout": "0s", - "workflowTaskCompletedEventId": 61, - "retryPolicy": { - "initialInterval": "1s", - "backoffCoefficient": 2, - "maximumInterval": "0s", - "maximumAttempts": 1, - "nonRetryableErrorTypes": [ - "temporalInternal:Panic", - "upload non-retryable error" - ] - }, - "header": {} - } - }, - { - "eventId": 63, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskStarted", - "version": -24, - "taskId": 6291772, - "activityTaskStartedEventAttributes": { - "scheduledEventId": 62, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "requestId": "870d2b5f-3286-4992-9b83-911d9cb10842", - "attempt": 1 - } - }, - { - "eventId": 64, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskCompleted", - "version": -24, - "taskId": 6291773, - "activityTaskCompletedEventAttributes": { - "scheduledEventId": 62, - "startedEventId": 63, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq" - } - }, - { - "eventId": 65, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskScheduled", - "version": -24, - "taskId": 6291776, - "workflowTaskScheduledEventAttributes": { - "taskQueue": { - "name": "ycyang-C02XW41WJGH6:7ce34128-dace-4a8a-a3ca-6eaa9c97dd13" - }, - "startToCloseTimeout": "60s", - "attempt": 1 - } - }, - { - "eventId": 66, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskStarted", - "version": -24, - "taskId": 6291780, - "workflowTaskStartedEventAttributes": { - "scheduledEventId": 65, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-sys-processor-parent-close-policy", - "requestId": "44177a34-efe8-4efc-a406-4018f9a46a87" - } - }, - { - "eventId": 67, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskCompleted", - "version": -24, - "taskId": 6291783, - "workflowTaskCompletedEventAttributes": { - "scheduledEventId": 65, - "startedEventId": 66, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "binaryChecksum": "a3f549be2faf4819fc3dcb4732046568" - } - }, - { - "eventId": 68, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "MarkerRecorded", - "version": -24, - "taskId": 6291784, - "markerRecordedEventAttributes": { - "markerName": "LocalActivity", - "details": null, - "workflowTaskCompletedEventId": 67 - } - }, - { - "eventId": 69, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowExecutionSignaled", - "version": -24, - "taskId": 6291786, - "workflowExecutionSignaledEventAttributes": { - "signalName": "temporal-archival-signal", - "input": null, - "identity": "59844@ycyang-C02XW41WJGH6@" - } - }, - { - "eventId": 70, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskScheduled", - "version": -24, - "taskId": 6291788, - "workflowTaskScheduledEventAttributes": { - "taskQueue": { - "name": "ycyang-C02XW41WJGH6:7ce34128-dace-4a8a-a3ca-6eaa9c97dd13" - }, - "startToCloseTimeout": "60s", - "attempt": 1 - } - }, - { - "eventId": 71, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskStarted", - "version": -24, - "taskId": 6291792, - "workflowTaskStartedEventAttributes": { - "scheduledEventId": 70, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-sys-tl-scanner-taskqueue-0", - "requestId": "c7ee25d5-3d85-464d-a3ad-197f30ad4c13" - } - }, - { - "eventId": 72, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskCompleted", - "version": -24, - "taskId": 6291795, - "workflowTaskCompletedEventAttributes": { - "scheduledEventId": 70, - "startedEventId": 71, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "binaryChecksum": "a3f549be2faf4819fc3dcb4732046568" - } - }, - { - "eventId": 73, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskScheduled", - "version": -24, - "taskId": 6291796, - "activityTaskScheduledEventAttributes": { - "activityId": "73", - "activityType": { - "name": "uploadHistoryActivity" - }, - "taskQueue": { - "name": "temporal-archival-tq" - }, - "input": null, - "scheduleToCloseTimeout": "300s", - "scheduleToStartTimeout": "300s", - "startToCloseTimeout": "60s", - "heartbeatTimeout": "0s", - "workflowTaskCompletedEventId": 72, - "retryPolicy": { - "initialInterval": "1s", - "backoffCoefficient": 2, - "maximumInterval": "0s", - "maximumAttempts": 1, - "nonRetryableErrorTypes": [ - "temporalInternal:Panic", - "upload non-retryable error" - ] - }, - "header": {} - } - }, - { - "eventId": 74, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskStarted", - "version": -24, - "taskId": 6291801, - "activityTaskStartedEventAttributes": { - "scheduledEventId": 73, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "requestId": "3a35e9d7-790f-41df-a518-0f4d6a5bc0f2", - "attempt": 1 - } - }, - { - "eventId": 75, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskCompleted", - "version": -24, - "taskId": 6291802, - "activityTaskCompletedEventAttributes": { - "scheduledEventId": 73, - "startedEventId": 74, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq" - } - }, - { - "eventId": 76, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskScheduled", - "version": -24, - "taskId": 6291805, - "workflowTaskScheduledEventAttributes": { - "taskQueue": { - "name": "ycyang-C02XW41WJGH6:7ce34128-dace-4a8a-a3ca-6eaa9c97dd13" - }, - "startToCloseTimeout": "60s", - "attempt": 1 - } - }, - { - "eventId": 77, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskStarted", - "version": -24, - "taskId": 6291809, - "workflowTaskStartedEventAttributes": { - "scheduledEventId": 76, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "requestId": "3bd96a83-c2fa-4979-8abb-c3ae80cc6ebb" - } - }, - { - "eventId": 78, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskCompleted", - "version": -24, - "taskId": 6291812, - "workflowTaskCompletedEventAttributes": { - "scheduledEventId": 76, - "startedEventId": 77, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "binaryChecksum": "a3f549be2faf4819fc3dcb4732046568" - } - }, - { - "eventId": 79, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "MarkerRecorded", - "version": -24, - "taskId": 6291813, - "markerRecordedEventAttributes": { - "markerName": "LocalActivity", - "details": null, - "workflowTaskCompletedEventId": 78 - } - }, - { - "eventId": 80, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowExecutionSignaled", - "version": -24, - "taskId": 6291846, - "workflowExecutionSignaledEventAttributes": { - "signalName": "temporal-archival-signal", - "input": null, - "identity": "59844@ycyang-C02XW41WJGH6@" - } - }, - { - "eventId": 81, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskScheduled", - "version": -24, - "taskId": 6291848, - "workflowTaskScheduledEventAttributes": { - "taskQueue": { - "name": "ycyang-C02XW41WJGH6:7ce34128-dace-4a8a-a3ca-6eaa9c97dd13" - }, - "startToCloseTimeout": "60s", - "attempt": 1 - } - }, - { - "eventId": 82, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskStarted", - "version": -24, - "taskId": 6291852, - "workflowTaskStartedEventAttributes": { - "scheduledEventId": 81, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-sys-processor-parent-close-policy", - "requestId": "304f5dac-44a4-4af2-a759-c206b5a3ec46" - } - }, - { - "eventId": 83, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskCompleted", - "version": -24, - "taskId": 6291855, - "workflowTaskCompletedEventAttributes": { - "scheduledEventId": 81, - "startedEventId": 82, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "binaryChecksum": "a3f549be2faf4819fc3dcb4732046568" - } - }, - { - "eventId": 84, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskScheduled", - "version": -24, - "taskId": 6291856, - "activityTaskScheduledEventAttributes": { - "activityId": "84", - "activityType": { - "name": "uploadHistoryActivity" - }, - "taskQueue": { - "name": "temporal-archival-tq" - }, - "input": null, - "scheduleToCloseTimeout": "300s", - "scheduleToStartTimeout": "300s", - "startToCloseTimeout": "60s", - "heartbeatTimeout": "0s", - "workflowTaskCompletedEventId": 83, - "retryPolicy": { - "initialInterval": "1s", - "backoffCoefficient": 2, - "maximumInterval": "0s", - "maximumAttempts": 1, - "nonRetryableErrorTypes": [ - "temporalInternal:Panic", - "upload non-retryable error" - ] - }, - "header": {} - } - }, - { - "eventId": 85, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskStarted", - "version": -24, - "taskId": 6291861, - "activityTaskStartedEventAttributes": { - "scheduledEventId": 84, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "requestId": "b247c133-bc34-472b-9bbd-a4e5e1f942d3", - "attempt": 1 - } - }, - { - "eventId": 86, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskCompleted", - "version": -24, - "taskId": 6291862, - "activityTaskCompletedEventAttributes": { - "scheduledEventId": 84, - "startedEventId": 85, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq" - } - }, - { - "eventId": 87, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskScheduled", - "version": -24, - "taskId": 6291865, - "workflowTaskScheduledEventAttributes": { - "taskQueue": { - "name": "ycyang-C02XW41WJGH6:7ce34128-dace-4a8a-a3ca-6eaa9c97dd13" - }, - "startToCloseTimeout": "60s", - "attempt": 1 - } - }, - { - "eventId": 88, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskStarted", - "version": -24, - "taskId": 6291869, - "workflowTaskStartedEventAttributes": { - "scheduledEventId": 87, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-sys-tl-scanner-taskqueue-0", - "requestId": "26054030-971f-486e-99d8-4151f7f3535b" - } - }, - { - "eventId": 89, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskCompleted", - "version": -24, - "taskId": 6291872, - "workflowTaskCompletedEventAttributes": { - "scheduledEventId": 87, - "startedEventId": 88, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "binaryChecksum": "a3f549be2faf4819fc3dcb4732046568" - } - }, - { - "eventId": 90, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "MarkerRecorded", - "version": -24, - "taskId": 6291873, - "markerRecordedEventAttributes": { - "markerName": "LocalActivity", - "details": null, - "workflowTaskCompletedEventId": 89 - } - }, - { - "eventId": 91, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowExecutionSignaled", - "version": -24, - "taskId": 6291875, - "workflowExecutionSignaledEventAttributes": { - "signalName": "temporal-archival-signal", - "input": null, - "identity": "59844@ycyang-C02XW41WJGH6@" - } - }, - { - "eventId": 92, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskScheduled", - "version": -24, - "taskId": 6291877, - "workflowTaskScheduledEventAttributes": { - "taskQueue": { - "name": "ycyang-C02XW41WJGH6:7ce34128-dace-4a8a-a3ca-6eaa9c97dd13" - }, - "startToCloseTimeout": "60s", - "attempt": 1 - } - }, - { - "eventId": 93, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskStarted", - "version": -24, - "taskId": 6291881, - "workflowTaskStartedEventAttributes": { - "scheduledEventId": 92, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "requestId": "d0a8f7d9-ed21-4c69-8656-348d497ae0ac" - } - }, - { - "eventId": 94, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskCompleted", - "version": -24, - "taskId": 6291884, - "workflowTaskCompletedEventAttributes": { - "scheduledEventId": 92, - "startedEventId": 93, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "binaryChecksum": "a3f549be2faf4819fc3dcb4732046568" - } - }, - { - "eventId": 95, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskScheduled", - "version": -24, - "taskId": 6291885, - "activityTaskScheduledEventAttributes": { - "activityId": "95", - "activityType": { - "name": "uploadHistoryActivity" - }, - "taskQueue": { - "name": "temporal-archival-tq" - }, - "input": null, - "scheduleToCloseTimeout": "300s", - "scheduleToStartTimeout": "300s", - "startToCloseTimeout": "60s", - "heartbeatTimeout": "0s", - "workflowTaskCompletedEventId": 94, - "retryPolicy": { - "initialInterval": "1s", - "backoffCoefficient": 2, - "maximumInterval": "0s", - "maximumAttempts": 1, - "nonRetryableErrorTypes": [ - "temporalInternal:Panic", - "upload non-retryable error" - ] - }, - "header": {} - } - }, - { - "eventId": 96, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskStarted", - "version": -24, - "taskId": 6291890, - "activityTaskStartedEventAttributes": { - "scheduledEventId": 95, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "requestId": "8b9abe6e-e31f-4fd0-ba44-761d7ec7f4b7", - "attempt": 1 - } - }, - { - "eventId": 97, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskCompleted", - "version": -24, - "taskId": 6291891, - "activityTaskCompletedEventAttributes": { - "scheduledEventId": 95, - "startedEventId": 96, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq" - } - }, - { - "eventId": 98, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskScheduled", - "version": -24, - "taskId": 6291894, - "workflowTaskScheduledEventAttributes": { - "taskQueue": { - "name": "ycyang-C02XW41WJGH6:7ce34128-dace-4a8a-a3ca-6eaa9c97dd13" - }, - "startToCloseTimeout": "60s", - "attempt": 1 - } - }, - { - "eventId": 99, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskStarted", - "version": -24, - "taskId": 6291898, - "workflowTaskStartedEventAttributes": { - "scheduledEventId": 98, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-sys-processor-parent-close-policy", - "requestId": "0cd5dc7b-2a41-49d7-9db8-e952f8ce5cc2" - } - }, - { - "eventId": 100, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskCompleted", - "version": -24, - "taskId": 6291901, - "workflowTaskCompletedEventAttributes": { - "scheduledEventId": 98, - "startedEventId": 99, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "binaryChecksum": "a3f549be2faf4819fc3dcb4732046568" - } - }, - { - "eventId": 101, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "MarkerRecorded", - "version": -24, - "taskId": 6291902, - "markerRecordedEventAttributes": { - "markerName": "LocalActivity", - "details": null, - "workflowTaskCompletedEventId": 100 - } - }, - { - "eventId": 102, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowExecutionSignaled", - "version": -24, - "taskId": 6291904, - "workflowExecutionSignaledEventAttributes": { - "signalName": "temporal-archival-signal", - "input": null, - "identity": "59844@ycyang-C02XW41WJGH6@" - } - }, - { - "eventId": 103, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskScheduled", - "version": -24, - "taskId": 6291906, - "workflowTaskScheduledEventAttributes": { - "taskQueue": { - "name": "ycyang-C02XW41WJGH6:7ce34128-dace-4a8a-a3ca-6eaa9c97dd13" - }, - "startToCloseTimeout": "60s", - "attempt": 1 - } - }, - { - "eventId": 104, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskStarted", - "version": -24, - "taskId": 6291910, - "workflowTaskStartedEventAttributes": { - "scheduledEventId": 103, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-sys-tl-scanner-taskqueue-0", - "requestId": "9ed3f383-bfe8-4f05-b7af-3ebe0763f3ec" - } - }, - { - "eventId": 105, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskCompleted", - "version": -24, - "taskId": 6291913, - "workflowTaskCompletedEventAttributes": { - "scheduledEventId": 103, - "startedEventId": 104, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "binaryChecksum": "a3f549be2faf4819fc3dcb4732046568" - } - }, - { - "eventId": 106, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskScheduled", - "version": -24, - "taskId": 6291914, - "activityTaskScheduledEventAttributes": { - "activityId": "106", - "activityType": { - "name": "uploadHistoryActivity" - }, - "taskQueue": { - "name": "temporal-archival-tq" - }, - "input": null, - "scheduleToCloseTimeout": "300s", - "scheduleToStartTimeout": "300s", - "startToCloseTimeout": "60s", - "heartbeatTimeout": "0s", - "workflowTaskCompletedEventId": 105, - "retryPolicy": { - "initialInterval": "1s", - "backoffCoefficient": 2, - "maximumInterval": "0s", - "maximumAttempts": 1, - "nonRetryableErrorTypes": [ - "temporalInternal:Panic", - "upload non-retryable error" - ] - }, - "header": {} - } - }, - { - "eventId": 107, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskStarted", - "version": -24, - "taskId": 6291919, - "activityTaskStartedEventAttributes": { - "scheduledEventId": 106, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "requestId": "0e6ba111-0876-423c-9962-6f20948f48fa", - "attempt": 1 - } - }, - { - "eventId": 108, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "ActivityTaskCompleted", - "version": -24, - "taskId": 6291920, - "activityTaskCompletedEventAttributes": { - "scheduledEventId": 106, - "startedEventId": 107, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq" - } - }, - { - "eventId": 109, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskScheduled", - "version": -24, - "taskId": 6291923, - "workflowTaskScheduledEventAttributes": { - "taskQueue": { - "name": "ycyang-C02XW41WJGH6:7ce34128-dace-4a8a-a3ca-6eaa9c97dd13" - }, - "startToCloseTimeout": "60s", - "attempt": 1 - } - }, - { - "eventId": 110, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskStarted", - "version": -24, - "taskId": 6291927, - "workflowTaskStartedEventAttributes": { - "scheduledEventId": 109, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "requestId": "c0bbf240-9a0e-4323-a182-a06decb5b2f0" - } - }, - { - "eventId": 111, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "WorkflowTaskCompleted", - "version": -24, - "taskId": 6291930, - "workflowTaskCompletedEventAttributes": { - "scheduledEventId": 109, - "startedEventId": 110, - "identity": "59844@ycyang-C02XW41WJGH6@temporal-archival-tq", - "binaryChecksum": "a3f549be2faf4819fc3dcb4732046568" - } - }, - { - "eventId": 112, - "eventTime": "2020-07-30T00:30:02.971655189Z", - "eventType": "MarkerRecorded", - "version": -24, - "taskId": 6291931, - "markerRecordedEventAttributes": { - "markerName": "LocalActivity", - "details": null, - "workflowTaskCompletedEventId": 111 - } - } - ] -} \ No newline at end of file diff --git a/service/worker/archiver/workflow_test.go b/service/worker/archiver/workflow_test.go index 16398e0eab4..78aa2289704 100644 --- a/service/worker/archiver/workflow_test.go +++ b/service/worker/archiver/workflow_test.go @@ -171,23 +171,6 @@ func (s *workflowSuite) TestArchivalWorkflow_Success() { env.AssertExpectations(s.T()) } -func (s *workflowSuite) TestReplayArchiveHistoryWorkflow() { - logger := log.NewTestLogger() - globalLogger = workflowTestLogger - globalMetricsHandler = workflowTestMetrics - - globalConfig = &Config{ - ArchiverConcurrency: dynamicconfig.GetIntPropertyFn(50), - ArchivalsPerIteration: dynamicconfig.GetIntPropertyFn(1000), - TimeLimitPerArchivalIteration: dynamicconfig.GetDurationPropertyFn(MaxArchivalIterationTimeout()), - } - - replayer := worker.NewWorkflowReplayer() - s.registerWorkflowsForReplayer(replayer) - err := replayer.ReplayWorkflowHistoryFromJSONFile(log.NewSdkLogger(logger), "testdata/archival_workflow_history_v1.json") - s.NoError(err) -} - func archivalWorkflowTest(ctx workflow.Context) error { return archivalWorkflowHelper(ctx, workflowTestLogger, workflowTestMetrics, workflowTestConfig, workflowTestHandler, workflowTestPump, nil) }