diff --git a/protocol/app/flags/flags.go b/protocol/app/flags/flags.go index 657196ac5c..cb1715ba62 100644 --- a/protocol/app/flags/flags.go +++ b/protocol/app/flags/flags.go @@ -187,10 +187,6 @@ func (f *Flags) Validate() error { } } - if f.FullNodeStreamingSnapshotInterval > 0 && f.FullNodeStreamingSnapshotInterval < 50 { - return fmt.Errorf("full node streaming snapshot interval must be >= 50 blocks or zero") - } - return nil } diff --git a/protocol/app/flags/flags_test.go b/protocol/app/flags/flags_test.go index e2c390eeb7..50e3a32c72 100644 --- a/protocol/app/flags/flags_test.go +++ b/protocol/app/flags/flags_test.go @@ -202,7 +202,7 @@ func TestValidate(t *testing.T) { }, expectedErr: fmt.Errorf("full node streaming batch size must be positive number"), }, - "failure - full node streaming enabled with <= 49 snapshot interval": { + "success - full node streaming enabled with 20 snapshot interval": { flags: flags.Flags{ NonValidatingFullNode: true, GrpcEnable: true, @@ -210,19 +210,7 @@ func TestValidate(t *testing.T) { GrpcStreamingFlushIntervalMs: 100, GrpcStreamingMaxBatchSize: 2000, GrpcStreamingMaxChannelBufferSize: 2000, - FullNodeStreamingSnapshotInterval: 49, - }, - expectedErr: fmt.Errorf("full node streaming snapshot interval must be >= 50 blocks or zero"), - }, - "success - full node streaming enabled with 50 snapshot interval": { - flags: flags.Flags{ - NonValidatingFullNode: true, - GrpcEnable: true, - GrpcStreamingEnabled: true, - GrpcStreamingFlushIntervalMs: 100, - GrpcStreamingMaxBatchSize: 2000, - GrpcStreamingMaxChannelBufferSize: 2000, - FullNodeStreamingSnapshotInterval: 50, + FullNodeStreamingSnapshotInterval: 20, }, }, }