Skip to content

Commit

Permalink
couple small items
Browse files Browse the repository at this point in the history
Signed-off-by: Yee Hing Tong <[email protected]>
  • Loading branch information
wild-endeavor committed Oct 30, 2023
1 parent bdddc93 commit 23d5fc2
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 6 deletions.
5 changes: 2 additions & 3 deletions flyteadmin/flyteadmin_config.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -118,9 +118,8 @@ externalEvents:
eventTypes: all
cloudEvents:
enable: true
type: redis
redis:
addr: "localhost:6379"
cloudEventVersion: v2
type: sandbox
Logger:
show-source: true
level: 5
Expand Down
3 changes: 0 additions & 3 deletions flyteadmin/pkg/async/cloudevent/implementations/sender.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,10 +24,7 @@ type PubSubSender struct {
}

func (s *PubSubSender) Send(ctx context.Context, notificationType string, event cloudevents.Event) error {
// gatepr: investigate why the previous statement didn't work.
// perhaps only because of redis.
eventByte, err := pbcloudevents.Protobuf.Marshal(&event)
//eventByte, err := json.Marshal(&event)
if err != nil {
logger.Errorf(ctx, "Failed to marshal cloudevent with error: %v", err)
return err
Expand Down

0 comments on commit 23d5fc2

Please sign in to comment.