Re-enable test_e2e.sh in the CI pipeline (#2860)

.github/workflows/test.yaml

@@ -111,6 +111,7 @@ jobs:
           PKG_CONFIG_PATH: "/home/runner/compiled/lib/pkgconfig"
         run: |
           ./test.sh
+          ./test_e2e.sh
 
       - name: Upload coverage reports
         uses: codecov/codecov-action@v3

test/e2e/e2e.go

@@ -280,7 +280,7 @@ func depositBroadcaster(t *testing.T, b *livepeer, amount *big.Int) {
 	require.Zero(info.Reserve.FundsRemaining.Cmp(amount))
 
 	// Ensure that on-chain deposit event handlers have time to process
-	time.Sleep(1 * time.Second)
+	time.Sleep(3 * time.Second)
 }
 
 func pushSegmentsBroadcaster(t *testing.T, b *livepeer, numSegs int) {
@@ -289,23 +289,13 @@ func pushSegmentsBroadcaster(t *testing.T, b *livepeer, numSegs int) {
 	mid := common.RandName()
 	for i := 0; i < numSegs; i++ {
 		require.Nil(pushSegmentBroadcaster(b, mid, i))
-	}
-}
-
-func pushSegmentsParallelBroadcaster(t *testing.T, b *livepeer, numSegs int) {
-	assert := assert.New(t)
+		// Wait at least 2 second between sending each segment to simulate the usual streaming scenario.
+		// In the Broadcaster's selection algorithm the Orchestrator's session is reused only if the previous
+		// segment is transcoded in a timely manner, so sending a new segment before the last one completed
+		// causes O's switch, which in turn causes the test failure (because we have only 1 O in this test).
+		time.Sleep(2 * time.Second)
 
-	var wg sync.WaitGroup
-	mid := common.RandName()
-	for i := 0; i < numSegs; i++ {
-		wg.Add(1)
-		go func(mid string, seqNo int) {
-			assert.Nil(pushSegmentBroadcaster(b, mid, i))
-			wg.Done()
-		}(mid, i)
 	}
-
-	wg.Wait()
 }
 
 func pushSegmentBroadcaster(b *livepeer, manifestID string, seqNo int) error {

test/e2e/http_push_broadcaster_test.go

@@ -27,7 +27,4 @@ func TestHTTPPushBroadcaster(t *testing.T) {
 
 	// Sequential requests
 	pushSegmentsBroadcaster(t, b, 3)
-
-	// Parallel requests
-	pushSegmentsParallelBroadcaster(t, b, 5)
 }