Merge branch 'haris/fix-filtered-records-holding-up-pipeline' of gith…

…ub.com:ConduitIO/conduit into haris/fix-filtered-records-holding-up-pipeline

pkg/lifecycle/stream/destination_test.go

@@ -188,5 +188,5 @@ func TestDestinationNode_HandleFilteredMessage(t *testing.T) {
 	is.Equal(msg, gotMsg)
 
 	err = (*csync.WaitGroup)(&nodeStopped).WaitTimeout(ctx, 100*time.Millisecond)
-	is.NoErr(err) // timed out waiting for node to be done running}
+	is.NoErr(err) // timed out waiting for node to be done running
 }