Merge pull request #499 from kube-tarian/contrib-changes

Updted configuration worker contribution code snippet
kube-tarian · May 30, 2024 · 0f8e275 · 0f8e275
2 parents 7dabbaf + 606497b
commit 0f8e275
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/contribution.md b/contribution.md
@@ -198,11 +198,15 @@ func Start() {
  logger := logging.NewLogger()
  logger.Infof("Starting config worker..\n")
 
- worker, err := workerframework.NewWorker(WorkflowTaskQueueName, workflows.Workflow, &activities.Activities{}, logger)
+ worker, err := workerframework.NewWorkerV2(WorkflowTaskQueueName, logger)
  if err != nil {
- logger.Fatalf("Worker initialization failed, Reason: %v\n", err)
+ logger.Fatalf("Worker initialization failed, Reason: %v", err)
  }
 
+ worker.RegisterWorkflows([]interface{}{workflows.Workflow}...)
+
+ worker.RegisterActivities([]interface{}{&activities.Activities{}}...)
+
  logger.Infof("Running config worker..\n")
  if err := worker.Run(); err != nil {
  logger.Fatalf("failed to start the config-worker, err: %v", err)