Skip to content

Commit 3e6b040

Browse files
Arta AsadiArta Asadi
authored andcommitted
fix:remove grpc auth token
1 parent b3a205a commit 3e6b040

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

discovery/worker/worker.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -231,13 +231,13 @@ func (w *Worker) ProcessMessage(ctx context.Context, msg jetstream.Msg) (err err
231231
}
232232
}()
233233

234-
token, err := getJWTAuthToken()
235-
if err != nil {
236-
return fmt.Errorf("failed to get JWT token: %w", err)
237-
}
234+
//token, err := getJWTAuthToken()
235+
//if err != nil {
236+
// return fmt.Errorf("failed to get JWT token: %w", err)
237+
//}
238238

239239
msgLogger.Info("Starting task execution")
240-
taskRunner, err := task.NewTaskRunner(ctxWithCancel, w.jq, envs.InventoryServiceEndpoint, token, w.esClient, msgLogger, request, response)
240+
taskRunner, err := task.NewTaskRunner(ctxWithCancel, w.jq, envs.InventoryServiceEndpoint, "", w.esClient, msgLogger, request, response)
241241
if err != nil {
242242
msgLogger.Error("failed to create task runner", zap.Error(err))
243243
return err

0 commit comments

Comments
 (0)