Skip to content

Commit 3f4f913

Browse files
committed
fix unit test
1 parent cb10cd8 commit 3f4f913

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

internal/internal_worker_test.go

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -264,8 +264,8 @@ func (s *internalWorkerTestSuite) TestCreateWorkerRun() {
264264
func (s *internalWorkerTestSuite) TestNoActivitiesOrWorkflows() {
265265
t := s.T()
266266
w := createWorker(s.T(), s.service)
267-
// assert.Empty(t, w.GetRegisteredActivities())
268-
// assert.Empty(t, w.GetRegisteredWorkflows())
267+
assert.Empty(t, w.GetRegisteredActivities())
268+
assert.Empty(t, w.GetRegisteredWorkflows())
269269
assert.NoError(t, w.Start())
270270
w.Stop()
271271
}
@@ -292,6 +292,8 @@ func (s *internalWorkerTestSuite) TestWorkerStartFailsWithInvalidDomain() {
292292
}).Times(2)
293293

294294
worker := createWorker(s.T(), service)
295+
worker.RegisterWorkflow(testWorkflowSample) // at least register one workflow otherwise workflow worker will not be started
296+
worker.RegisterActivity(testActivity) // at least register one activity otherwise activity worker will not be started
295297
if tc.isErrFatal {
296298
err := worker.Start()
297299
assert.Error(t, err, "worker.start() MUST fail when domain is invalid")
@@ -405,7 +407,7 @@ func createWorkerWithThrottle(
405407
workerOptions.WorkerActivitiesPerSecond = 20
406408
workerOptions.TaskListActivitiesPerSecond = activitiesPerSecond
407409
workerOptions.Logger = testlogger.NewZap(t)
408-
workerOptions.EnableSessionWorker = true
410+
workerOptions.EnableSessionWorker = false
409411

410412
// Start Worker.
411413
worker, err := NewWorker(

0 commit comments

Comments
 (0)