Merged in feature/init-runner-decode (pull request #189)
Feature/init runner decode * comment * Merge remote-tracking branch 'origin/main' * init runner decode Approved-by: Mark Tomcza
This commit is contained in:
@@ -37,7 +37,7 @@ type Body struct {
|
||||
func (s Runner) Process(ctx context.Context, body Body) bool {
|
||||
key, err := objectstore.ParseBucketKey(body.Key)
|
||||
if err != nil {
|
||||
slog.Error("unable to parse key", "key", body.Key)
|
||||
slog.Error("unable to parse key", "key", body.Key, "error", err)
|
||||
return false
|
||||
}
|
||||
|
||||
|
||||
@@ -49,11 +49,11 @@ func (s *Service) Process(ctx context.Context, params Params) error {
|
||||
queueParams.QueueURL = s.cfg.GetDocInitURL()
|
||||
queueParams.Body = docinitrunner.Body{
|
||||
Bucket: params.Bucket,
|
||||
Key: params.Key,
|
||||
Key: decodedKey,
|
||||
Hash: params.Hash,
|
||||
}
|
||||
default:
|
||||
slog.Info("unsupported key", "key", params.Key)
|
||||
slog.Info("unsupported key", "key", decodedKey)
|
||||
return nil
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user