Merge branch '99designs-integration'

runner/cloudwatch.go

@@ -54,10 +54,10 @@ func (lw *logWaiter) streamExists() (bool, error) {
 				// return early if we match the log stream
 				if *stream.LogStreamName == lw.LogStreamName {
 					exists = true
-					return true
+					return false
 				}
 			}
-			return lastPage
+			return !lastPage
 		})
 
 	return exists, err
@@ -212,7 +212,7 @@ func (lw *logWatcher) printEventsAfter(ctx context.Context, ts int64) (int64, er
 					ts = *event.Timestamp
 				}
 			}
-			return lastPage
+			return !lastPage
 		})
 	if err != nil {
 		log.Printf("Printed %d events in %v", count, time.Now().Sub(t))

runner/cloudwatch_test.go

@@ -188,7 +188,7 @@ func (cw *mockCloudWatchLogs) FilterLogEventsPages(input *cloudwatchlogs.FilterL
 			output.Events = append(output.Events, e)
 		}
 
-		if fn(output, len(cw.filterLogEvents) == 0) {
+		if !fn(output, len(cw.filterLogEvents) == 0) {
 			cw.Unlock()
 			return nil
 		}