allow retrying of async query

atomist-skills · Jan 8, 2024 · 8244497 · 8244497
1 parent 360870f
commit 8244497
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/policy/policy_handler/handler.go b/policy/policy_handler/handler.go
@@ -94,6 +94,9 @@ func (h EventHandler) handle(ctx context.Context, req skill.RequestContext) skil
 	for _, provider := range h.dataSourceProviders {
 		ds, err := provider(ctx, req)
 		if err != nil {
+			if err.Error() == "An unexpected error has occurred" {
+				return skill.NewRetryableStatus(fmt.Sprintf("Failed to create data source [%s]", err.Error()))
+			}
 			return skill.NewFailedStatus(fmt.Sprintf("failed to create data source [%s]", err.Error()))
 		}
 		sources = append(sources, ds...)