fix subscription data source ix

atomist-skills · Feb 15, 2024 · 4e05d75 · 4e05d75
1 parent 424f469
commit 4e05d75
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/policy/data/subscription.go b/policy/data/subscription.go
@@ -2,8 +2,6 @@ package data
 
 import (
 	"context"
-	"fmt"
-
 	"olympos.io/encoding/edn"
 )
 
@@ -28,8 +26,8 @@ func (ds SubscriptionDataSource) Query(_ context.Context, queryName string, _ st
 		return nil, nil
 	}
 
-	if ix >= len(ds.subscriptionResults) {
-		return nil, fmt.Errorf("can't get subscription query %s (index %d) from result length %d", queryName, ix, len(ds.subscriptionResults))
+	if len(ds.subscriptionResults) == 0 || ix >= len(ds.subscriptionResults[0]) {
+		return nil, nil
 	}
 
 	err := edn.Unmarshal(ds.subscriptionResults[0][ix], output)