Skip to content

Commit

Permalink
Dial back added debug/logging
Browse files Browse the repository at this point in the history
Signed-off-by: Daniel DeLeo <dan@chef.io>
  • Loading branch information
danielsdeleo committed Feb 21, 2020
1 parent adbc5ae commit 7f00294
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -124,7 +124,7 @@ func CreateCfgmgmtActionsDiagnostic() diagnostics.Diagnostic {
maxTries := 5

for _, entity := range loaded.CreatedEntities {
reqPath := fmt.Sprintf("/api/v0/eventfeed?collapse=true&page_size=100&start=%d&end=%d", entity.RecordedAtMillis-600000, entity.RecordedAtMillis+600000)
reqPath := fmt.Sprintf("/api/v0/eventfeed?collapse=true&page_size=100&start=%d&end=%d", entity.RecordedAtMillis-1, entity.RecordedAtMillis+1)
found := false

type eventsFeedResp struct {
Expand Down
11 changes: 6 additions & 5 deletions components/ingest-service/pipeline/publisher/chef_action.go
Original file line number Diff line number Diff line change
Expand Up @@ -35,11 +35,12 @@ func ChefAction(in <-chan message.ChefAction, client backend.Client, out chan<-
err := client.InsertAction(msg.Ctx, msg.InternalChefAction)
if err != nil {
log.WithError(err).WithFields(log.Fields{
"publisher_id": number,
"message_id": msg.ID,
"buffer_size": len(out),
"internal_action": msg.InternalChefAction,
"entity": msg.InternalChefAction.EntityName,
"publisher_id": number,
"message_id": msg.ID,
"buffer_size": len(out),
"entity_name": msg.InternalChefAction.EntityName,
"entity_type": msg.InternalChefAction.EntityType,
"entity_task": msg.InternalChefAction.Task,
}).Error("Failed to insert Chef Action")
msg.FinishProcessing(status.Errorf(codes.Internal, err.Error()))
} else {
Expand Down

0 comments on commit 7f00294

Please sign in to comment.